Flink组件一:state

1.state 1.1.状态管理: flink有两种状态:keyedState和operatorState state keyedState operatorState 支持的算子 keyedState只能用在keyedStream的算子中每个key对应一个state 可以用于所有算子常用于source,例如:FlinkKafkaConsumer key和state 一个operator实例处理多
相关文章
相关标签/搜索