flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: distinct() Java API
Date Fri, 17 Apr 2015 10:37:47 GMT
The problem is cause by the project() operator.
The Java compiler does infer its return type and defaults to Tuple.

You can help the compiler like this:

DataSet<Tuple1<String>> ds2 = ds.<Tuple1<String>project(0).distinct(0);


2015-04-17 4:33 GMT-05:00 Flavio Pompermaier <pompermaier@okkam.it>:

> I have errors in Eclipse doing something like:
>
> DataSet<Tuple5<String,String,String,String,String>> ds = ....
> DataSet<Tuple1<String>> ds2 = .ds.project(0).distinct(0);
>
> It says that I have to declare ds2 as a Dataset<Tuple>
>
> On Fri, Apr 17, 2015 at 11:15 AM, Maximilian Michels <mxm@apache.org>
> wrote:
>
>> Hi Flavio,
>>
>> Do you have an exapmple? The DistinctOperator should return a typed
>> output just like all the other operators do.
>>
>> Best,
>> Max
>>
>> On Fri, Apr 17, 2015 at 10:07 AM, Flavio Pompermaier <
>> pompermaier@okkam.it> wrote:
>>
>>> Hi guys,
>>>
>>> I'm trying to make (in Java) a project().distinct() but then I cannot
>>> create the generated dataset with a typed tuple because the distinct
>>> operator returns just an untyped Tuple.
>>> Is this an error in the APIs or am I doing something wrong?
>>>
>>> Best,
>>> Flavio
>>>
>>
>>
>
>
>

Mime
View raw message