[jira] [Created] (FLINK-1872) How can generation dataset in flink automatic depend on number of filed and data type

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1872) How can generation dataset in flink automatic depend on number of filed and data type

Shang Yuanchun (Jira)
hagersaleh created FLINK-1872:
---------------------------------

             Summary: How can generation dataset in flink automatic depend on number of filed and data type
                 Key: FLINK-1872
                 URL: https://issues.apache.org/jira/browse/FLINK-1872
             Project: Flink
          Issue Type: Bug
            Reporter: hagersaleh


when read csv file want generate dataset function automatic
Example write this Mnola
but want generate this code automatic for any csv flie input
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
 
DataSet<Tuple5<Integer, String, String, Integer, Double>> customers = getCustomerDataSet(env);

private static DataSet<Tuple5<Integer, String, String, Integer, Double>> getCustomerDataSet(ExecutionEnvironment env) {
                return env.readCsvFile(customerPath)
                                        .fieldDelimiter("|")
                                        .includeFields("11110100")
                                        .types(Integer.class, String.class, String.class, Integer.class, Double.class);
        }




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)