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:
OrcTableSource orcSrc = OrcTableSource.builder()
.path("file:///my/data/file.orc")
.forOrcSchema("struct<col1:boolean,col2:tinyint,col3:smallint,col4:int>")
.build();
tEnv.registerTableSourceInternal("orcTable", orcSrc);
Table res = tableEnv.sqlQuery("SELECT * FROM orcTable");
My question is what should tEnv be so that I can use
the registerTableSourceInternal method?
My end goal is to query the orc source and then return a DataSet.
Regards
,
Nikola
