Hi, Shekhar
> 1. Optimizer does not use both - ProjectableTableSource and
> FilterableTableSource - in a single query even if the source implements both
> interfaces. Each interface works correctly if implemented independently.
I didn’t see your custom source implementation, but I think the tw
Hi, Shekhar
> 1. Optimizer does not use both - ProjectableTableSource and
> FilterableTableSource - in a single query even if the source implements both
> interfaces. Each interface works correctly if implemented independently.
I didn’t your custom source implementation, but I think the two int
Hi Satyam,
Currently, the community is using the new table source/sink API and the
`FilterableTableSource`, `ProjectableTableSource` have been deprecated. The
interface `SupportsProjectionPushDown` and `SupportsFilterPushDown` are the
new interfaces to push down the `projection` and `filter`.
You
Hello,
I am using Flink 1.11.2 as the execution engine for an alerting
application. Our application builds atop Flink's SQL API to run streaming
and batch jobs on a proprietary storage engine. We have a custom
StreamTableSource implementation that connects to our storage engine. The
connector curr
