flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fábio Dias <fabiodio...@gmail.com>
Subject Re: Writing the results of the stream onto a CSV File
Date Fri, 28 Apr 2017 09:46:11 GMT
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 Regards,
Fábio Dias.

Abdul Salam Shaikh <abd.salam.shaikh@gmail.com> escreveu no dia sexta,
28/04/2017 às 10:18:

> 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<DetectorStatistics> objectStream = windowedStream.flatMap(new
> WindowObjectStreamTransformer());
>         objectStream.writeAsText("H:\\data.csv", new
> TextFormatter<DetectorStatistics>() {
>             public String format (DetectorStatistics value) {
>                 return value.getDetectorId() + " ," +
> value.getActualPhaseTime() ;
>             }
>         });
>
> ​What am I doing wrong here ? Or is there an alternative way to write
> records onto a CSV file ? ​
>
> ​Thanks!
>
>

Mime
View raw message