1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
API
===
Stream
------
.. currentmodule:: streamz
.. autosummary::
Stream
.. autosummary::
Stream.connect
Stream.destroy
Stream.disconnect
Stream.visualize
accumulate
buffer
collect
combine_latest
delay
filter
flatten
map
partition
rate_limit
scatter
sink
sink_to_textfile
slice
sliding_window
starmap
timed_window
union
unique
pluck
zip
zip_latest
.. automethod:: Stream.connect
.. automethod:: Stream.disconnect
.. automethod:: Stream.destroy
.. automethod:: Stream.emit
.. automethod:: Stream.frequencies
.. automethod:: Stream.register_api
.. automethod:: Stream.sink
.. automethod:: Stream.sink_to_list
.. automethod:: Stream.sink_to_textfile
.. automethod:: Stream.to_websocket
.. automethod:: Stream.to_mqtt
.. automethod:: Stream.update
.. automethod:: Stream.visualize
Sources
-------
.. autosummary::
from_iterable
filenames
from_kafka
from_kafka_batched
from_mqtt
from_process
from_websocket
from_textfile
from_tcp
from_http_server
DaskStream
----------
.. currentmodule:: streamz.dask
.. autosummary::
DaskStream
gather
Definitions
-----------
.. currentmodule:: streamz
.. autofunction:: accumulate
.. autofunction:: buffer
.. autofunction:: collect
.. autofunction:: combine_latest
.. autofunction:: delay
.. autofunction:: filter
.. autofunction:: flatten
.. autofunction:: map
.. autofunction:: partition
.. autofunction:: rate_limit
.. autofunction:: sink
.. autofunction:: sink_to_textfile
.. autofunction:: sliding_window
.. autofunction:: Stream
.. autofunction:: timed_window
.. autofunction:: union
.. autofunction:: unique
.. autofunction:: pluck
.. autofunction:: zip
.. autofunction:: zip_latest
.. autofunction:: from_iterable
.. autofunction:: filenames
.. autofunction:: from_kafka
.. autofunction:: from_kafka_batched
.. autofunction:: from_textfile
.. currentmodule:: streamz.dask
.. autofunction:: DaskStream
.. autofunction:: gather
|
