You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@beam.apache.org by Shen LI <cs...@gmail.com> on 2017/04/29 19:43:38 UTC

How to create an unbounded PCollection?

It seems that Create.of(Iterable) can only create a BoundedSource. Is there
a convenient way to read from an unbounded Iterable object without writing
application code to wrap it into an UnboundedSource object?

Thanks,

Shen

Re: How to create an unbounded PCollection?

Posted by Shen Li <cs...@gmail.com>.

Sorry about the duplication. Please ignore the above email.

Shen

On Sat, Apr 29, 2017 at 3:43 PM, Shen LI <cs...@gmail.com> wrote:

> It seems that Create.of(Iterable) can only create a BoundedSource. Is there
> a convenient way to read from an unbounded Iterable object without writing
> application code to wrap it into an UnboundedSource object?
>
> Thanks,
>
> Shen
>