Hi,
thanks for that!
How about adding a name-method to the DataSet, that sets the name and
returns itself? That would allow to stay in the fluent interface, and make
naming intermediate results easier:
def name(name: String): DataSet[T] = {
contract.setName(name)
this
}
Something like that.
Cheers
Stefan
On Thu, Jul 31, 2014 at 6:32 PM, Aljoscha Krettek <[email protected]>
wrote:
> 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
>>
>
>
