Hi Andrea, you can use any OutputFormat to emit data from a DataStream using the writeUsingOutputFormat() method. However, this method does not guarantee exactly-once processing. In case of a failure, it might emit some records a second time. Hence the results will be written at least once.
Hope this helps, Fabian 2016-05-06 12:45 GMT+02:00 Andrea Sella <andrea.se...@radicalbit.io>: > Hi, > > I created a custom OutputFormat to send data to a remote actor, there are > issues to use an OutputFormat into a stream job? Or it will treat like a > Sink? > > I prefer to use it in order to create a custom ActorSystem per TM in the > configure method. > > Cheers, > Andrea >
