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
> >>>>
> >>
> >>
>
>

Reply via email to