Documentation
¶
Overview ¶
Package stream_ops exposes kernel stream operations to Flow DSL.
Typical use:
fs.walk -> stream.batch @{ size: 100 } -> process
Index ¶
Constants ¶
View Source
const ID = "stream_ops"
Variables ¶
This section is empty.
Functions ¶
func Operators ¶
func Operators() []action.NamedOperator
Operators exposes the stateless stream manipulators into the DSL.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.