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!

Reply via email to