Flink之流處理API之Source

Flink流處理流程：html Source分類:java 從已有集合讀取數據：val stream1 = env.fromCollection(List(  SensorReading("sensor_1", 1547718159, 4),  SensorReading("sensor_2", 1547718261, 1)) 讀取任意類型的數據：env.fromElements(1, 34, "

>>阅读原文<<