层 Storey是一个异步流媒体库,用于实时事件处理和功能提取。 在本文件中 :play_button: 有关更多信息,请参见。 API演练 Storey流包含由build_flow函数链接在一起的步骤,每个步骤都执行其指定的工作。 支持的步骤 输入步骤 Source AsyncSource ReadCSV ReadParquet DataframeSource 处理步骤 Filter Map FlatMap MapWithState Batch(max_events, timeout) -批量处理事件。 此步骤每隔max_events个事件发出一个批处理,或者从接收到批处理中的第一个事件起经过超时秒数后,将发出一个批处理。 Choice JoinWithV3IOTable SendToHttp AggregateByKey(aggregations,cache, key=None,