You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by philippe <ph...@cnam.fr> on 2017/09/08 16:15:01 UTC
Error a simple window example
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