Re: Naming Scala Operators

Posted by Aljoscha Krettek on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Naming-Scala-Operators-tp7p8.html

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 <[hidden email]> 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