Hi Abdul,
the DataStream#writeAsText does not support a TextFormatter as argument.
You either have to implement your own OutputFormat and calling
DataStream#writeUsingOutputFormat or as Fabio recommended simply use
DataStream#writeAsCsv.
Cheers,
Till
On Fri, Apr 28, 2017 at 11:46 AM, Fábio
Hi,
Instead of use writeAsText you have a writeAsCsv
https://ci.apache.org/projects/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/datastream/DataStream.html
You can use just with the string path (like you have) or you can use the
overwrite flag if it suit your needs.
Best
Hi,
I am trying to write the results of my stream into a CSV format using the
following code and it has compilation issues:
DataStream objectStream = windowedStream.flatMap(new
WindowObjectStreamTransformer());
objectStream.writeAsText("H:\\data.csv", new
TextFormatter() {
