Index

A

accumulate() (in module streamz) accumulate_partitions() (streamz.batch.Batch method) (streamz.collection.Streaming method) (streamz.dataframe.DataFrame method)

aggregate() (streamz.dataframe.Rolling method) apply() (streamz.dataframe.Window method) assign() (streamz.dataframe.DataFrame method)

B

Batch (class in streamz.batch)

buffer() (in module streamz)

C

collect() (in module streamz) combine_latest() (in module streamz) connect() (streamz.Stream method) count() (streamz.dataframe.DataFrame method) (streamz.dataframe.GroupBy method) (streamz.dataframe.Rolling method) (streamz.dataframe.Window method)

cummax() (streamz.dataframe.DataFrame method) cummin() (streamz.dataframe.DataFrame method) cumprod() (streamz.dataframe.DataFrame method) cumsum() (streamz.dataframe.DataFrame method)

D

DaskStream() (in module streamz.dask) DataFrame (class in streamz.dataframe)

delay() (in module streamz) destroy() (streamz.Stream method) disconnect() (streamz.Stream method)

E

emit() (streamz.Stream method)

F

filenames() (in module streamz) filter() (in module streamz) (streamz.batch.Batch method) flatten() (in module streamz) frequencies() (streamz.Stream method)

from_iterable() (in module streamz) from_kafka() (in module streamz) from_kafka_batched() (in module streamz) from_periodic (streamz.dataframe.DataFrame attribute) from_textfile() (in module streamz)

G

gather() (in module streamz.dask) GroupBy (class in streamz.dataframe)

groupby() (streamz.dataframe.DataFrame method) (streamz.dataframe.Window method)

M

map() (in module streamz) (streamz.batch.Batch method) map_partitions() (streamz.batch.Batch static method) (streamz.collection.Streaming static method) (streamz.dataframe.DataFrame static method) max() (streamz.dataframe.Rolling method)

mean() (streamz.dataframe.DataFrame method) (streamz.dataframe.GroupBy method) (streamz.dataframe.Rolling method) (streamz.dataframe.Window method) median() (streamz.dataframe.Rolling method) min() (streamz.dataframe.Rolling method)

P

partition() (in module streamz)

pluck() (in module streamz) (streamz.batch.Batch method)

Q

quantile() (streamz.dataframe.Rolling method)

R

Random (class in streamz.dataframe) random (streamz.dataframe.DataFrame attribute) rate_limit() (in module streamz) register_api() (streamz.batch.Batch class method) (streamz.dataframe.DataFrame class method) (streamz.Stream class method)

reset_index() (streamz.dataframe.DataFrame method) Rolling (class in streamz.dataframe) rolling() (streamz.dataframe.DataFrame method) round() (streamz.dataframe.DataFrame method)

S

set_index() (streamz.dataframe.DataFrame method) sink() (in module streamz) (streamz.Stream method) sink_to_list() (streamz.Stream method) sink_to_textfile() (in module streamz) (streamz.Stream method) size (streamz.dataframe.DataFrame property) (streamz.dataframe.Window property) size() (streamz.dataframe.GroupBy method) sliding_window() (in module streamz)

std() (streamz.dataframe.GroupBy method) (streamz.dataframe.Rolling method) (streamz.dataframe.Window method) Stream() (in module streamz) Streaming (class in streamz.collection) sum() (streamz.batch.Batch method) (streamz.dataframe.DataFrame method) (streamz.dataframe.GroupBy method) (streamz.dataframe.Rolling method) (streamz.dataframe.Window method)

T

tail() (streamz.dataframe.DataFrame method) timed_window() (in module streamz) to_dataframe() (streamz.batch.Batch method)

to_frame() (streamz.dataframe.DataFrame method) to_mqtt() (streamz.Stream method) to_stream() (streamz.batch.Batch method) to_websocket() (streamz.Stream method)

U

union() (in module streamz)

unique() (in module streamz) update() (streamz.Stream method)

V

value_counts() (streamz.dataframe.Window method) var() (streamz.dataframe.GroupBy method) (streamz.dataframe.Rolling method) (streamz.dataframe.Window method)

verify() (streamz.batch.Batch method) (streamz.collection.Streaming method) (streamz.dataframe.DataFrame method) visualize() (streamz.Stream method)

W

Window (class in streamz.dataframe)

window() (streamz.dataframe.DataFrame method)

Z

zip() (in module streamz)

zip_latest() (in module streamz)