Ok, I added lib exec/opt to my class path, and now I can import the package.
But still
the assigner seems unknown.
Scala-Flink> import
org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate._
import
org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate._
Scala-Flink> :paste
// 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>:71: error: not found: value TumblingProcessingTimeWindows
.windowAll(TumblingProcessingTimeWindows.of(Time.seconds(5)))
^
> Le 10 sept. 2017 à 18:50, Ted Yu <[email protected]> a écrit :
>
> Looks like flink-table jar was not on the classpath.
>
> On Sun, Sep 10, 2017 at 9:39 AM, philippe <[email protected]> wrote:
>
>> Hum
>>
>> Scala-Flink> import org.apache.flink.table.plan.nodes.datastream.
>> DataStreamGroupWindowAggregate._
>> <console>:62: error: object table is not a member of package
>> org.apache.flink
>> import org.apache.flink.table.plan.nodes.datastream.
>> DataStreamGroupWindowAggregate._
>> ^
>>
>>
>>
>>
>>> Le 10 sept. 2017 à 18:31, Ted Yu <[email protected]> a écrit :
>>>
>>> What if you add the following at the beginning:
>>>
>>> import
>>> org.apache.flink.table.plan.nodes.datastream.
>> DataStreamGroupWindowAggregate._
>>>
>>> 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
>>>>>>
>>>>
>>>>
>>
>>
