How can I convert a DataSet into a Table?

[podunk]

 

My code is:

 

package flinkTest2;

 

import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

 

public class flinkTest2 {
    public static void main(String[] args) throws Exception {

  

   ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();    
    
    // read a CSV file with five fields, taking only two of them
    DataSet<Tuple2<String, Double>> csvInput = env.readCsvFile("c:/CSV/file")
                               .includeFields("10010")  // take the first and the fourth field
                               .types(String.class, Double.class);
    
    //register and create table
    EnvironmentSettings settings = EnvironmentSettings
            .newInstance()
            //.inStreamingMode()
            .inBatchMode()
            .build();

    TableEnvironment tEnv = TableEnvironment.create(settings);

 

 

   //Insert CSV content into table, define column names and read some rows from it
    

 }
}

 

What to do create table, insert DataSet csvInput into table and read some rows from it (into text file)?

Thanks for help

 

Mike