Re: Hello-world example of Flink Table API using a edited Calcite rule

-- From:Felipe Gutierrez Send Time:2019年6月26日(星期三) 20:58 To:JingsongLee Cc:user Subject:Re: Hello-world example of Flink Table API using a edited Calcite rule Hi JingsongLee, it is still not very clear to me. I imagine that I can create an InMemoryExternalCatalog and insert some tuples there (which

Re: Hello-world example of Flink Table API using a edited Calcite rule

e/flink/table/descriptors/OldCsv.scala > > Best, JingsongLee > > -- > From:Felipe Gutierrez > Send Time:2019年6月26日(星期三) 20:58 > To:JingsongLee > Cc:user > Subject:Re: Hello-world example of Flink Table API using a edited Calcite >

Re: Hello-world example of Flink Table API using a edited Calcite rule

-- From:Felipe Gutierrez Send Time:2019年6月26日(星期三) 20:58 To:JingsongLee Cc:user Subject:Re: Hello-world example of Flink Table API using a edited Calcite rule Hi JingsongLee, it is still not very clear to me. I imagine that I can create an InMemoryExternalCatalog and insert

Re: Hello-world example of Flink Table API using a edited Calcite rule

Hi JingsongLee, it is still not very clear to me. I imagine that I can create an InMemoryExternalCatalog and insert some tuples there (which will be in memory). Then I can use Calcite to use the values of my InMemoryExternalCatalog and change my plan. Is that correct? Do you have an example of

Re: Hello-world example of Flink Table API using a edited Calcite rule

Hi Felipe: I think your approach is absolutely right. You can try to do some plan test just like [1]. You can find more CalciteConfigBuilder API test in [2].

Hello-world example of Flink Table API using a edited Calcite rule

Hi, does someone have a simple example using Table API and a Calcite rule which change/optimize the query execution plan of a query in Flink? >From the official documentation, I know that I have to create a CalciteConfig object [1]. Then, I based my firsts tests on this stackoverflow post [2]