Re: Move files read by flink

[flinkuser101]

Where does Flink expose filesystem? Is it from env? or inputstream?

 TextInputFormat format = new TextInputFormat(new
org.apache.flink.core.fs.Path(url.toString()));
DataStream<String> inputStream =
env.readFile(format,url.toString(),FileProcessingMode.PROCESS_CONTINUOUSLY,
1);

DataStream parsedStream = inputStream
                .map(new MapFunction<String, Content>() {})




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/