OrcTableSource in flink 1.12

Posted by Nikola Hrusov on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/OrcTableSource-in-flink-1-12-tp42410.html

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.