Streamz
latest
Contents
Core Streams
DataFrames
Streaming GPU DataFrames (cudf)
Supported Operations
Dask Integration
Collections
API
Collections API
Asynchronous Computation
Visualizing streamz
Plugins
Streamz
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
M
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
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)
Read the Docs
v: latest
Versions
latest
stable
Downloads
pdf
html
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.