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 <m...@apache.org> 收件人："user@flink.apache.org" <user@flink.apache.org>, rimin...@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, <rimin...@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.. > -------------------------------- > > >
