Index

A

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

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

B

Batch (class in rapidz.batch)

buffer() (in module rapidz)

C

collect() (in module rapidz) combine_latest() (in module rapidz) count() (rapidz.dataframe.DataFrame method) (rapidz.dataframe.GroupBy method) (rapidz.dataframe.Rolling method) (rapidz.dataframe.Window method)

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

D

DaskStream() (in module rapidz.dask)

DataFrame (class in rapidz.dataframe) delay() (in module rapidz)

F

filenames() (in module rapidz) filter() (in module rapidz) (rapidz.batch.Batch method)

flatten() (in module rapidz) from_kafka() (in module rapidz) from_textfile() (in module rapidz)

G

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

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

M

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

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

P

partition() (in module rapidz)

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

Q

quantile() (rapidz.dataframe.Rolling method)

R

Random (class in rapidz.dataframe) rate_limit() (in module rapidz) reset_index() (rapidz.dataframe.DataFrame method)

Rolling (class in rapidz.dataframe) rolling() (rapidz.dataframe.DataFrame method) round() (rapidz.dataframe.DataFrame method)

S

set_index() (rapidz.dataframe.DataFrame method) sink() (in module rapidz) size (rapidz.dataframe.DataFrame attribute) (rapidz.dataframe.Window attribute) size() (rapidz.dataframe.GroupBy method) sliding_window() (in module rapidz) std() (rapidz.dataframe.GroupBy method) (rapidz.dataframe.Rolling method) (rapidz.dataframe.Window method)

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

T

tail() (rapidz.dataframe.DataFrame method) timed_window() (in module rapidz)

to_dataframe() (rapidz.batch.Batch method) to_frame() (rapidz.dataframe.DataFrame method) to_stream() (rapidz.batch.Batch method)

U

union() (in module rapidz)

unique() (in module rapidz)

V

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

verify() (rapidz.batch.Batch method) (rapidz.collection.Streaming method) (rapidz.dataframe.DataFrame method)

W

Window (class in rapidz.dataframe)

window() (rapidz.dataframe.DataFrame method)

Z

zip() (in module rapidz)

zip_latest() (in module rapidz)