[GitHub] [flink] wuchong opened a new pull request #8576: Introduce new Interfaces for source and sink

[GitBox <gi...@apache.org>]

wuchong opened a new pull request #8576: Introduce new Interfaces for source and sink
URL: https://github.com/apache/flink/pull/8576
 
 
   In order to support Blink batch and temporal table join, we need some new source&sink interfaces and changes about TableSchema.
   
   - `AsyncTableFunction`:  used as async lookup function, to support async temporal table join (i.e. dimension table join.).
   - `LookupableTableSource`: The `LookupableTableSource` interface adds support for the table to be accessed via key column(s) in a lookup fashion in order to support temporal table join. 
   - `BoundedTableSource`: used for batch table source, returns a bounded DataStream, not a `InputFormat`, because we also want to reuse existing streaming source implementation to support bounded source, for example: bounded Kafka source.
   - `BoundedTableSink`: used for batch table sink, emit a bounded DataStream, not a `OutputFormat`. The reason is the same as above.
   - `TableSchema`: The `TableSchema` is extended to carry more information about primary key and unique keys. The key information will be used in optimization.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services