FunctionalStream
函数功能
构造函数。
函数原型
def __init__(self, stream_name: str, src_nodes: List[stream.PluginNode], sink_nodes: List[stream.PluginNode]) -> None:
输入参数说明
参数名 |
类型 |
说明 |
|---|---|---|
stream_name |
str |
Stream标识名。 |
src_nodes |
List |
头插件数组。 |
sink_nodes |
List |
尾插件数组。 |
父主题： FunctionalStream