FunctionalStream
Function Usage
Constructor.
Prototype
def __init__(self, stream_name: str, src_nodes: List[stream.PluginNode], sink_nodes: List[stream.PluginNode]) -> None:
Input Parameter Description
Parameter |
Type |
Description |
|---|---|---|
stream_name |
str |
Stream identifier |
src_nodes |
List |
Header plugin array |
sink_nodes |
List |
Tail plugin array |
Parent topic: FunctionalStream