You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by ri...@sina.cn on 2016/09/03 03:01:44 UTC
fromParallelCollection
Hi，val env = StreamExecutionEnvironment.getExecutionEnvironment val tr = env.fromParallelCollection(data)
the data i do not know initialize,some one can tell me..
--------------------------------
Re: fromParallelCollection
Posted by Maximilian Michels <mx...@apache.org>.
Please give us a bit more insight on what you're trying to do.
On Sat, Sep 3, 2016 at 5:01 AM, <ri...@sina.cn> wrote:
> Hi，
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> val tr = env.fromParallelCollection(data)
>
> the data i do not know initialize,some one can tell me..
> --------------------------------
>
>
>