Flink組件一:state

1.state 1.1.狀態管理: flink有兩種狀態:keyedState和operatorState state keyedState operatorState 支持的算子 keyedState只能用在keyedStream的算子中每個key對應一個state 可以用於所有算子常用於source,例如:FlinkKafkaConsumer key和state 一個operator實例處理多
相關文章
相關標籤/搜索