Looks like flink-table jar was not on the classpath.
On Sun, Sep 10, 2017 at 9:39 AM, philippe <philippe.rig...@cnam.fr> wrote:
> Hum
>
> Scala-Flink> import org.apache.flink.table.plan.nodes.datastream.
> DataStreamGroupWindowAggregate._
> <console>:62: error: object table is not a member of package
> org.apache.flink
> import org.apache.flink.table.plan.nodes.datastream.
> DataStreamGroupWindowAggregate._
> ^
>
>
>
>
> > Le 10 sept. 2017 à 18:31, Ted Yu <yuzhih...@gmail.com> a écrit :
> >
> > What if you add the following at the beginning:
> >
> > import
> > org.apache.flink.table.plan.nodes.datastream.
> DataStreamGroupWindowAggregate._
> >
> > On Sun, Sep 10, 2017 at 9:18 AM, philippe <philippe.rig...@cnam.fr>
> wrote:
> >
> >> Thanks.
> >>
> >> Sorry, that’s a copy/paste artefact. Here is an exact copy:
> >>
> >> // Entering paste mode (ctrl-D to finish)
> >>
> >> case class MonEntier(classe: Int, valeur: Int)
> >> val stream = senv.socketTextStream("localhost", 9000, '\n')
> >>
> >> val w = stream.map ( { x => Tuple1(x.toInt) } )
> >> .map( {y => MonEntier(y._1 % 3, y._1) } )
> >> .windowAll(TumblingProcessingTimeWindows.
> >> of(Time.seconds(5)))
> >> .fold("") { (acc, v) => acc + " - " + v.valeur }
> >> .print()
> >>
> >> senv.execute("Ma gestion de fenêtres ")
> >>
> >>
> >> // Exiting paste mode, now interpreting.
> >>
> >> <console>:68: error: not found: value TumblingProcessingTimeWindows
> >> .windowAll(TumblingProcessingTimeWindows.
> >> of(Time.seconds(5)))
> >>
> >>
> >>
> >>
> >>> Le 10 sept. 2017 à 18:14, Ted Yu <yuzhih...@gmail.com> a écrit :
> >>>
> >>> Is there extra '=' before the windowAll() call ?
> >>>
> >>> On Sun, Sep 10, 2017 at 1:01 AM, philippe <philippe.rig...@cnam.fr>
> >> wrote:
> >>>
> >>>>
> >>>> Hi all,
> >>>>
> >>>> I am trying to run a simple example in the Scala shell:
> >>>>
> >>>>
> >>>> case class MonEntier(classe: Int, valeur: Int)
> >>>> val stream =3D senv.socketTextStream("localhost", 9000, '\n')
> >>>> val w =3D stream.map ( { x =3D> Tuple1(x.toInt) } )
> >>>> .map( {y =3D> MonEntier(y._1 % 3, y._1) } )
> >>>> =
> >>>> .windowAll(TumblingProcessingTimeWindows.of(Time.seconds(5)))
> >>>> .print()
> >>>>
> >>>>
> >>>> The socket at 9000 sends a stream of integers
> >>>>
> >>>> I get a compilation error:
> >>>>
> >>>> <console>:68: error: not found: value TumblingProcessingTimeWindows
> >>>> .windowAll(new =
> >>>> TumblingProcessingTimeWindows.of(Time.seconds(5)))
> >>>>
> >>>>
> >>>> The snippet directly comes from the doc. Help welcome !
> >>>>
> >>>> Philippe
> >>>>
> >>
> >>
>
>
