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