Can you add the following ?
import
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows;
Make sure flink-streaming-java jar is on the classpath.
Thanks
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
> >>
>
>
