I think ResultPartition is a pretty accurate description of what it is: a partition of the result of an operator. ResultStream on the other hand, seems very generic to me. Just because we like to think of Flink nowadays as a "streaming data flow" engine, we don't have to change the core classes' names :)
On Thu, Jun 4, 2015 at 1:57 PM, Ufuk Celebi <u...@apache.org> wrote: > > On 04 Jun 2015, at 13:10, Maximilian Michels <m...@apache.org> wrote: > > > Rename what to streams? Do you mean "ResultPartition" => > "StreamPartition"? > > Exactly along those lines, but maybe "ResultStream". > > > I'm not sure if that makes it easier to understand what the classes do. > > It fits better into the terminology of a "streaming data flow" engines. > > > > > >
