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 <[email protected]> 收件人："[email protected]" <[email protected]>, [email protected] 主题：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, <[email protected]> wrote: > Hi， > val env = StreamExecutionEnvironment.getExecutionEnvironment > val tr = env.fromParallelCollection(data) > > the data i do not know initialize,some one can tell me.. > -------------------------------- > > >
