aflik 读取csv格式

aflik 读取csv格式

    String filePath = "F:\flink\data\iris.csv";
        String schema
                = "sepal_length double, sepal_width double, petal_length double, petal_width double, category string";
        CsvSourceBatchOp csvSource = new CsvSourceBatchOp()
                .setFilePath(filePath)
                .setSchemaStr(schema)
                .setFieldDelimiter(",");
        csvSource.print();

官方提供读取

filePath 可以Url,也可以是本地文件