The iterable is the entirety of the contents of the PCollection. So empty iterable -> empty PCollection.
It is actually main purpose/complexity in this transform to make sure it is non-empty, because otherwise downstream asserts do not run. On Wed, Nov 2, 2016 at 5:20 AM Amit Sela <amitsel...@gmail.com> wrote: > I've proposed https://github.com/apache/incubator-beam/pull/1257 (also > opened a ticket). > Tested locally Direct/Flink/Spark runners, and it looks fine, I've issued a > PR to see if it affects Dataflow runner. > > Amit. > > On Wed, Nov 2, 2016 at 11:56 AM Jean-Baptiste Onofré <j...@nanthrax.net> > wrote: > > > Agree, this element should be removed. > > > > Regards > > JB > > > > On 11/02/2016 10:53 AM, Amit Sela wrote: > > > Hi all, > > > > > > I've been looking at PAssert and I've notice that > PAssert.GroupedGlobally > > > points > > > < > > > https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java#L825 > > > > > > that it will result in a singe empty iterable even if the input > > PCollection > > > is empty. > > > This is a weird behaviour as it may cause following assertions to fail. > > > > > > Wouldn't it be more correct to remove (filter out ?) this element ? > > > > > > Thanks, > > > Amit > > > > > > > -- > > Jean-Baptiste Onofré > > jbono...@apache.org > > http://blog.nanthrax.net > > Talend - http://www.talend.com > > >
