fromParallelCollection

[rimin515]

Hi，

val env = StreamExecutionEnvironment.getExecutionEnvironment    

      val tr = env.fromParallelCollection(data)

the data i do not know initialize,some one can tell me..

--------------------------------

[Maximilian Michels]

Please give us a bit more insight on what you're trying to do.

On Sat, Sep 3, 2016 at 5:01 AM,  <[hidden email]> wrote:
> Hi，
> val env = StreamExecutionEnvironment.getExecutionEnvironment
>       val tr = env.fromParallelCollection(data)
>
> the data i do not know initialize,some one can tell me..
> --------------------------------
>
>
>

[Ranjit]

ArrayList<String> list = new ArrayList<String>();
list.add("Apache");
list.add("Flink");
       
DataStreamSource<String> stream = env.fromCollection(list);

This works for me!