Error a simple window example

[philippe]

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