flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <rimin...@sina.cn>
Subject 回复:Re: fromParallelCollection
Date Tue, 06 Sep 2016 07:46:36 GMT
fromCollection is not parallelization,the data is huge,so i want to use env.fromParallelCollection(data),but
the data i do not know how to  initialize,
----- 原始邮件 -----
发件人:Maximilian Michels <mxm@apache.org>
收件人:"user@flink.apache.org" <user@flink.apache.org>, rimin515@sina.cn
主题:Re: fromParallelCollection
日期:2016年09月05日 16点58分


Please give us a bit more insight on what you're trying to do.
On Sat, Sep 3, 2016 at 5:01 AM,  <rimin515@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..
> --------------------------------
>
>
>
Mime
View raw message