Hello,
I am just wondering, does Flink use Apache Calcite's query optimizer to
generate an optimal logical plan for stream queries, or does it have its
own independent query optimizer?
>From what I observed so far, the Flink's query optimizer only groups
operator together without changing the orde
Thank you for your responses and suggestions. I appreciate it.
Albert
On Wed, Apr 26, 2017 at 4:19 AM, Ufuk Celebi wrote:
> Adding to what Zhijiang said: I think the way to go would be to create
> multiple "read views" over the pipelined subpartition. You would have
> to make sure that the init
