File tree 3 files changed +5
-9
lines changed
3 files changed +5
-9
lines changed Original file line number Diff line number Diff line change @@ -103,12 +103,6 @@ operations together on a single line like `sdf = sdf.apply().filter().print()`.
103
103
Chaining can be used alongside branching; the operations will be collectively treated
104
104
as a single branch addition.
105
105
106
- ### Branching vs. Multiple Topics (Multi-SDF)
107
-
108
- [ Consuming multiple topics] ( consuming-multiple-topics.md ) is independent of branching;
109
- branches can be used in each of the ` SDF ` s from multiple topics, but they cannot
110
- interact with one another in any way.
111
-
112
106
#### Clarifying Multiple SDFs
113
107
` SDF ` 's are delineated by the topic they are initialized with;
114
108
branches just generate additional nodes you can manipulate on them,
Original file line number Diff line number Diff line change 157
157
"quixstreams.sources.community.kinesis.kinesis" ,
158
158
"quixstreams.sources.community.pubsub.pubsub" ,
159
159
"quixstreams.sources.community.pandas" ,
160
+ "quixstreams.sources.community.influxdb3.influxdb3" ,
160
161
]
161
162
},
162
163
}
Original file line number Diff line number Diff line change @@ -12,6 +12,7 @@ Use it when you need:
12
12
** Example 1:** Aggregate e-commerce orders from different locations into one stream and calculate the average order size in 1h windows.
13
13
14
14
``` python
15
+
15
16
from datetime import timedelta
16
17
17
18
from quixstreams import Application
@@ -43,11 +44,11 @@ if __name__ == '__main__':
43
44
app.run()
44
45
```
45
46
46
-
47
47
** Example 2:** Combine branches of the same ` StreamingDataFrame ` back together.
48
- See the [ Branching] ( branching.md ) page for more details about branching.
48
+ See the [ Branching StreamingDataFrames ] ( branching.md ) page for more details about branching.
49
49
50
50
``` python
51
+
51
52
from quixstreams import Application
52
53
app = Application(... )
53
54
@@ -73,7 +74,7 @@ all_orders.to_topic(output_topic)
73
74
74
75
if __name__ == ' __main__' :
75
76
app.run()
76
- ```
77
+ ```
77
78
78
79
79
80
## Message ordering between partitions
You can’t perform that action at this time.
0 commit comments