flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From philippe <philippe.rig...@cnam.fr>
Subject Re: Problem with basic example
Date Sun, 10 Sep 2017 17:01:31 GMT
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 <yuzhihong@gmail.com> a écrit :
> 
> Looks like flink-table jar was not on the classpath.
> 
> On Sun, Sep 10, 2017 at 9:39 AM, philippe <philippe.rigaux@cnam.fr> 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 <yuzhihong@gmail.com> 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 <philippe.rigaux@cnam.fr>
>> 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 <yuzhihong@gmail.com> a écrit
:
>>>>> 
>>>>> Is there extra '=' before the windowAll() call ?
>>>>> 
>>>>> On Sun, Sep 10, 2017 at 1:01 AM, philippe <philippe.rigaux@cnam.fr>
>>>> 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
>>>>>> 
>>>> 
>>>> 
>> 
>> 


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message