File tree Expand file tree Collapse file tree 2 files changed +13
-13
lines changed Expand file tree Collapse file tree 2 files changed +13
-13
lines changed Original file line number Diff line number Diff line change @@ -12,24 +12,24 @@ Before branching, only this was possible:
12
12
13
13
```
14
14
sdf
15
- └── A
16
- └── B
17
- └── C
18
- └── D
15
+ └── apply()
16
+ └── apply()
17
+ └── apply()
18
+ └── apply()
19
19
```
20
20
21
21
But with branching, you could do something like:
22
22
23
23
```
24
24
sdf
25
- └── A
26
- └── B
27
- ├── C
28
- │ └── D
29
- └── E
30
- ├── F
31
- ├── G
32
- └── H
25
+ └── apply()
26
+ └── apply()
27
+ ├── apply()
28
+ │ └── apply()
29
+ └── filter() - (does following operations only to this filtered subset)
30
+ ├── apply()
31
+ ├── apply()
32
+ └── apply()
33
33
```
34
34
35
35
## Branching Use Cases
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ This is the base class for all sources. It handles configuring the source and re
46
46
* ` stop ` : This method is called, in the subporcess, when the application is shutting down.
47
47
* ` default_topic ` : This method is called, in the main process, when a topic is not provided with the source.
48
48
49
- For more information, see [ ` quixstreams.sources.base.BaseSource ` ] ( ../../api-reference/sources.md#BaseSource ) docstrings.
49
+ For more information, see [ ` quixstreams.sources.base.BaseSource ` ] ( ../../api-reference/sources.md#basesource ) docstrings.
50
50
51
51
## Custom Sources and Jupyter Notebook
52
52
You can’t perform that action at this time.
0 commit comments