目前Flink SQL 中的connector都没实现异步io关联维表,接口是上已经支持了的,如果是自己实现可以参考[1] 另外,HBase connector 社区有人正在支持异步io关联维表,预计1.13可以使用[2]
祝好 [1]https://github.com/apache/flink/blob/73cdd3d0d9f6a807b3e47c09eef7983c9aa180c7/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java#L618 [2] https://github.com/apache/flink/pull/14684#pullrequestreview-604148209 <https://github.com/apache/flink/pull/14684#pullrequestreview-604148209> > 在 2021年3月4日,14:22,HunterXHunter <[email protected]> 写道: > > 定义一个 sourcetable > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
