Flink有狀態計算入門示例

需求：從socket接收字符串，按空格分隔成單詞，統計單詞出現的次數。 直接看代碼吧。 主函數： FlinkStatefulCalcTest.java package com.ccclubs.flink; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.a

>>阅读原文<<