Great, thanks!

The fact that it's actually written on the documentation is really
misleading.

Thank you very much for your response

Federico D'Ambrosio

Il 15 set 2017 13:26, "Gábor Gévay" <gga...@gmail.com> ha scritto:

> Hi Federico,
>
> Sorry, nested field expressions are not supported in these methods at
> the moment. I have created a JIRA issue for this:
> https://issues.apache.org/jira/browse/FLINK-7629
> I think this should be easy to fix, as all the infrastructure for
> supporting this is already in place. I'll try to do it over the
> weekend.
>
> Best,
> Gábor
>
>
>
>
> On Thu, Sep 14, 2017 at 3:51 PM, Federico D'Ambrosio
> <federico.dambro...@smartlab.ws> wrote:
> > Hi,
> >
> > I have the following case classes:
> >
> > case class Event(instantValues: InstantValues)
> > case class InstantValues(speed: Int, altitude: Int, time: DateTime)
> >
> >
> > in a DataStream[Event] I'd like to perform a maxBy operation on the field
> > time of instantValue for each event and according to the docs here it
> would
> > be possible to use the dot notation such the following:
> >
> > val events = stream
> >   .keyBy("otherField")
> >   .window(TumblingEventTimeWindows.of(Time.seconds(5)))
> >   .maxBy("instantValues.time")
> >
> > positionToMaxBy - In case of a POJO, Scala case class, or Tuple type, the
> > name of the public) field on which to perform the aggregation.
> Additionally,
> > a dot can be used to drill down into nested objects, as in
> "field1.fieldxy"
> > . Furthermore "*" can be specified in case of a basic type (which is
> > considered as having only one field).
> >
> >
> > Still, I'm getting the following error:
> >
> > Fields 'instantValues.time' are not valid for
> 'package.Event(instantValues:
> > package.InstantValues(speed: Integer, altitude: Integer, time:
> > GenericType<org.joda.time.DateTime>))'
> >
> > whereas if, for instance, use only "instantValues" (while implementing
> its
> > compareTo method) the aggregation works as usual.
> >
> > Any idea as to why this isn't working? Am I doing something wrong?
> >
> > Thanks a lot,
> > Federico
>

Reply via email to