sebastianliu opened a new pull request #82: URL: https://github.com/apache/bahir-flink/pull/82
It was glad to see that community's Flink-kudu connector has been reworked recently. The table api has been supported which enable better interaction between Flink SQL and Kudu. However, there is no support for flink batch SQL currently, include filter pushing down. In this PR, I change KuduTableSource to inherit from InputFormatTableSource to support both streaming SQL and Batch SQL at the same time. In order to reduce unnecessary data transmission, I also added the filter push down to the KuduTableSource. ---------------------------------------------------------------- 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: [email protected]
