Streaming non window left outer join是flink1.6中的一个新特性。当我在两个动态表之间执行此操作时。join结果顺序错误。如何正确使用此功能?这两个动态表都是按data_update_time排序。NonWindowJoin左表的状态和右表的状态都使用flink托管状态MapState。当我查看flink的non window join代码时。我搞混了:(1) MapState的关键字是Row
我查询一个数据库,并按表中的日期列排序,也按另一个表中的另一列排序。这是完美的工作。SELECT * FROM myTable1 LEFT JOIN myTable2 b ON myTable1.id = b.id WHERE myTable1.id !='foo' ORDER BY myTable1.dateColumn DESC, b.column2 ASC
我想要做的是,仅当在b.column2中没有该特定记