Re: 回复：Re: 回复：Re: fromParallelCollection

2016-09-07 Thread Timo Walther
g 主题：Re: 回复：Re: fromParallelCollection 日期：2016年09月06日 17点03分 Hi, you have to implement a class that extends "org.apache.flink.util.SplittableIterator". The runtime will ask this class for multiple "java.util.Iterator"s over your split data. How you split your data and how

回复：Re: 回复：Re: fromParallelCollection

2016-09-06 Thread rimin515
@flink.apache.org 主题：Re: 回复：Re: fromParallelCollection 日期：2016年09月06日 17点03分 Hi, you have to implement a class that extends "org.apache.flink.util.SplittableIterator". The runtime will ask this class for multiple "java.util.Iterator"s over your s

Re: 回复：Re: fromParallelCollection

2016-09-06 Thread Timo Walther
- 发件人：Maximilian Michels 收件人："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, wrote: > Hi， > val env = StreamExecutionEnv

回复：Re: fromParallelCollection

2016-09-06 Thread rimin515
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 收件人："user@flink.apache.org" , rimin...@sina.cn 主题：Re: fromParallelCollection 日期：2016年09月

Re: fromParallelCollection

2016-09-05 Thread 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, wrote: > Hi， > val env = StreamExecutionEnvironment.getExecutionEnvironment > val tr = env.fromParallelCollection(data) > > the data i do not know initialize,some one can tell me.. >

fromParallelCollection

2016-09-02 Thread rimin515
Hi，val env = StreamExecutionEnvironment.getExecutionEnvironment val tr = env.fromParallelCollection(data) the data i do not know initialize,some one can tell me..