Problem with basic 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 snippet directly comes from the doc. Help welcome !

Philippe