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, "
相关文章
相关标签/搜索