Alternatively static method FileSystem.get
> On 10. Mar 2018, at 10:36, flinkuser101 <sugandha.ama...@gmail.com> wrote:
>
> 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/
