Hi Stefan,
right now you have to use something like this:
val words = input.flatMap { ... }
words.contract.setName("the name")contract is a field of DataSet with which you can access the underlying Operator. Cheers, Aljoscha On Thu, Jul 31, 2014 at 5:28 PM, Stefan Bunk <[email protected]> wrote: > Hi, > > is there a way to give a name to some operators in the Scala API? > So that the log lines > Reduce(<Unnamed Reducer>) (1/1) switched to READY > are more helpful? > > Cheers > Stefan >
