flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From philippe <philippe.rig...@cnam.fr>
Subject Error a simple window example
Date Fri, 08 Sep 2017 16:15:01 GMT

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 sniper directly comes from the doc. Help welcome !

Philippe

Mime
View raw message