框架
- 运行时进程
- 与其它运行时进程通信
- 跨机
- 环路
- 监听输入
- 调用相应算子
- 收集和转发输出
- 算子
- 连接到运行时
- 通过TCP套接字(可以是一个隔离的进程)
- 具有高级消息格式的单个连接,或
- 隔离连接每个输入/输出
- 动态链接为共享库
- 运行时直接调用特定输入消息句柄
- 输出:
- 返回一个集合做为结果
- 调用运行时函数至发送输出结果
- 通过TCP套接字(可以是一个隔离的进程)
- 输入聚合(即等待多个输入可用)
- 由运行时 -> 在配置文件中聚合指定输入
- 由算子 -> 自定义动作可能性
- 连接到运行时
库
- 所有源/算子/接收器都是链接运行时库的隔离进程
- "协调程序" 进程
- 读取配置文件
- 据此启动进程
- 传递节点配置
- 做为参数
- 加载环境变量
- 包含输入与输出名称
- 运行时库提供(异步)函数至
- 等待一个或多个输入
- 超时
- 发送输出