Index

A

accumulate() (in module streamz)

accumulate_partitions() (streamz.collection.Streaming method) aggregate() (streamz.dataframe.Rolling method)

B

buffer() (in module streamz)

C

collect() (in module streamz)

combine_latest() (in module streamz) count() (streamz.dataframe.Rolling method)

D

DaskStream() (in module streamz.dask)

delay() (in module streamz)

F

filenames() (in module streamz) filter() (in module streamz)

flatten() (in module streamz) from_kafka() (in module streamz) from_textfile() (in module streamz)

G

gather() (in module streamz.dask)

M

map() (in module streamz) map_partitions() (streamz.collection.Streaming method) max() (streamz.dataframe.Rolling method)

mean() (streamz.dataframe.Rolling method) median() (streamz.dataframe.Rolling method) min() (streamz.dataframe.Rolling method)

P

partition() (in module streamz)

pluck() (in module streamz)

Q

quantile() (streamz.dataframe.Rolling method)

R

Random (class in streamz.dataframe)

rate_limit() (in module streamz) Rolling (class in streamz.dataframe)

S

sink() (in module streamz) sliding_window() (in module streamz) std() (streamz.dataframe.Rolling method)

Stream() (in module streamz) Streaming (class in streamz.collection) sum() (streamz.dataframe.Rolling method)

T

timed_window() (in module streamz)

U

union() (in module streamz)

unique() (in module streamz)

V

var() (streamz.dataframe.Rolling method)

verify() (streamz.collection.Streaming method)

Z

zip() (in module streamz)

zip_latest() (in module streamz)