flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@apache.org>
Subject Re: ConstantFields in Java API
Date Wed, 25 Jun 2014 20:47:41 GMT
@Sebastian, Thanks for the correction!
I thought the code was already merged.

Cheers, Fabian


2014-06-25 20:18 GMT+02:00 Sebastian Kunert <skunert49@gmail.com>:

> Hi,
>
> @Fabian: Are you sure that is the case? I don't think that the annotations
> are set correctly automatically at the moment. There is a pullrequest open,
> but it was not yet merged.
>
> Your UDF looks like field 1 of the first tuple input is also constant:
>  @ConstantFieldsFirst("1->1;2 -> 2")
>  @ConstantFieldsSecond("0 -> 0")
>
> Regards,
>
> Sebastian
>
>
> 2014-06-25 20:09 GMT+02:00 Fabian Hueske <fhueske@apache.org>:
>
> > Hi Janani,
> >
> > You can also use the projection join as:
> >
> >
> >
> ds1.join(ds2).where(0).equalTo(0).projectFirst(0).projectSecond(1,2).types(Long.class,
> > Long.class, Long.class)
> >
> > That should also automatically set the correct annotations.
> >
> > Best, Fabian
> > On Jun 25, 2014 7:41 PM, "Janani Chakkaradhari" <janani.cse05@gmail.com>
> > wrote:
> >
> > > Hi,
> > >
> > > Can someone check the following UDF for constantFileds setup?
> > >
> > > In simple, I wanted to do :
> > > First Input of Join :    Tuple3<Long, FMCounter, Double> first,
> > > Second Input of Join: Tuple2<Long, Long> second
> > > Output:                     Tuple3<second.f0, first.f1, first.f1>
> > >
> > >
> > > UDF:
> > >     @ConstantFieldsFirst("2 -> 2")
> > >     @ConstantFieldsSecond("0 -> 0")
> > >     public static final class SendingMessageToNeighbors
> > >         extends
> > >         JoinFunction<Tuple3<Long, FMCounter, Double>,
> > >         Tuple2<Long, Long>, Tuple3<Long, FMCounter, Double>>
{
> > >
> > >         @Override
> > >         public Tuple3<Long, FMCounter, Double> join(
> > >             Tuple3<Long, FMCounter, Double> vertex_workset,
> > >             Tuple2<Long, Long> neighbors) throws Exception {
> > >             return new Tuple3<Long,
> > >                     FMCounter,
> > > Double>(neighbors.f0,vertex_workset.f1,vertex_workset.f2);
> > >         }
> > >
> > >     }
> > >
> > > Here, I only mapped for two fields (0 and 2) in output tuple. Is it
> fine?
> > >
> > > Regards,
> > > Janani
> > >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message