Got it, it's clear, TableStats is the important functions of ExternalCatalog.
It is right way.
Best, JingsongLee
--
From:Felipe Gutierrez
Send Time:2019年6月27日(星期四) 14:53
To:JingsongLee
Cc:user
Subject:Re: Hello-world example of
Hi JingsongLee,
Sorry for not explain very well. I am gonna try a clarification of my idea.
1 - I want to use InMemoryExternalCatalog in a way to save some statistics
which I create by listening to a stream.
2 - Then I will have my core application using Table API to execute some
aggregation/join.
Hi Felipe:
Yeah, you can use InMemoryExternalCatalog and CalciteConfig,
but I don't quite understand what you mean.
InMemoryExternalCatalog provides methods to create, drop, and
alter (sub-)catalogs or tables. And CalciteConfig is for defining a
custom Calcite configuration. They are two separa
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 ho
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].
1.https://github.com/apache/flink/blob/release-1.8/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/batch/table/Co
