Hello,
I am still looking into that same issue and I am not sure how to continue
forward.
We want to upgrade to the latest versions of flink (1.14) and I couldn't
find any examples on how to properly do that.
Does anybody help me on translating the example from the docs:
https://ci.apache.org/pr
Hi Nikola,
for the ORC source it is fine to use `TableEnvironment#fromTableSource`.
It is true that this method is deprecated, but as I said not all
connectors have been ported to be supported in the SQL DDL via string
properties. Therefore, `TableEnvironment#fromTableSource` is still
accessi
Hi Timo,
I need to read ORC files and run a query on them as in the example above.
Since the example given in docs is not recommended what should I use?
I looked into the method you suggest - TableEnvironment#fromTableSource -
it shows as Deprecated on the docs:
https://ci.apache.org/projects/fli
Hi Nikola,
the OrcTableSource has not been updated to be used in a SQL DDL. You can
define your own table factory [1] that translates properties into a
object to create instances or use
`org.apache.flink.table.api.TableEnvironment#fromTableSource`. I
recommend the latter option.
Please kee
Hello,
I am trying to find some examples of how to use the OrcTableSource and
query it.
I got to the documentation here:
https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/orc/OrcTableSource.html
and it says that an OrcTableSource is used as below:
OrcTableSou
