Hi Chen
I haven't tried the following code out but it should be as easy as:
stream.addSink(new SinkFunction() {
private final Logger LOG = LogManager.getLogger("loggerName");
public void invoke(String value) throws Exception {
Log.info(value);
}
});
It's JAVA but I think it suffice to geht the b
hi,
the .print() method will print a dataset / datastream to the stdout.
how can I print the stream to the standard logger (logback/log4j)?
I'm using flink scala - so scala example code is much appreciated.
p.s - I noticed that there's a PrintFunction that I can implement but it
feels like I'm
