Соединение Flink-SQL Windowed-Table? - PullRequest
Новая
       25

Соединение Flink-SQL Windowed-Table?

0 голосов
/ 04 февраля 2019

Из-за ограничений я могу использовать только Flink v 1.4.2.Я просматриваю оконные объединения.

CustomObj.java (POJO) 

class CustomObj{
   public long timestampVal; 
   public int value;
}

У меня есть 2 потока данных, таких как: 

StreamExecutionEnvironment currentEnv = getEnv();
currentEnv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
StreamTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(currentEnv); TableEnvironment.getTableEnvironment(currentEnv);
DataStream<CustomObj> s1 = ...assignTimeStampsAndWatermarks(...)...
DataStream<CustomObj> s2 = ...assignTimeStampsAndWatermarks(...)...

tableEnv.registerDataStream("s1", s1);
tableEnv.registerDataStream("s2", s2);

Iхочу сделать: 

SELECT * FROM s1 INNER JOIN s2 ON s1.timestampVal = s2.timestampVal

Тем не менее, INNER JOIN для потоковой передачи не поддерживается в Flink V 1.4.2, поэтому мне интересно, могу ли я сделать какое-то соединение с TimeWindow?Как это работает точно?

...