Method List
-
#apply DStream::WithNext
-
#apply DStream::Compose
-
#apply DStream::Flatten2
-
#apply DStream::SimpleB
-
apply DStream
-
#apply DStream::Simple1
-
#apply DStream::Scan
-
#apply DStream::Buffer
-
#apply DStream::Zip
-
#apply DStream::Trickle
-
#apply DStream::Burst
-
buffer DStream
-
burst DStream
-
chunk_by DStream
-
compose DStream
-
flatten2 DStream
-
#initialize DStream::Buffer
-
#initialize DStream::Burst
-
#initialize DStream::Scan
-
#initialize DStream::SimpleB
-
#initialize DStream::Simple1
-
#initialize DStream::Trickle
-
#initialize DStream::Zip
-
#initialize DStream::Compose
-
#inspect DStream::Compose
-
#inspect DStream::Zip
-
#inspect DStream::Abstract
-
#inspect DStream::SimpleB
-
map DStream
-
reduce DStream
-
scan DStream
-
select DStream
-
take DStream
-
trickle DStream
-
with_next DStream
-
zip DStream