flink提取時間戳並指定使用eventTime

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //指定使用eventTime做爲時間標準 env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime
相關文章
相關標籤/搜索