1,1547718210,29.7
sensor_1,1547718213,30.9
代码实现
package windows
import org.apache.flink.streaming.api.TimeCharacteristic...StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime...1,1547718210,29.7
sensor_1,1547718213,30.9
实现代码
package windows
import org.apache.flink.streaming.api.TimeCharacteristic...1,1547718210,29.7
sensor_1,1547718213,30.9
编写代码
package windows
import org.apache.flink.streaming.api.TimeCharacteristic...1,1547718210,29.7
sensor_1,1547718213,30.9
代码分析:
package windows
import org.apache.flink.streaming.api.TimeCharacteristic