Yes, it works. Many, many thanks It may be worth to add this instruction in the doc.
Great system, I continue. Philippe > Le 10 sept. 2017 à 19:12, Ted Yu <[email protected]> a écrit : > > 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 <[email protected]> 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 <[email protected]> a écrit : >>> >>> Is there extra '=' before the windowAll() call ? >>> >>> On Sun, Sep 10, 2017 at 1:01 AM, philippe <[email protected]> >> 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 >>>> >> >>
