Fixed! (earlier today in the quickstart)
On Fri, Dec 9, 2016 at 1:46 PM, Trevor Pering
wrote:
> I'm trying the Beam Quickstart on http://beam.incubator.
> apache.org/get-started/quickstart/ and it can't find the default
> DIrectRunner. If I try to specify a --runner
Beam's codebase is "fairly stable" right now. We've done the majority of
backward-incompatible changes that were planned and known. There are still
some remaining, but they shouldn't cause excessive pain. From the code
stability perspective, you might want to try Beam right away, with the
Yes -- MinimalWordCount example currently defaults to the
DataflowPipelineRunner, which runs pipelines on the Google Cloud Dataflow
service. (We'll be changing this.) In general, Cloud-based runners don't
have access to your local machine, hence the exception you saw.
DirectPipelineRunner can
The question of displaying contents of a (small) PCollection has been asked
several times. There are various reasons why this is challenging, primarily
centered around leading users into a sub-optimal outcome / experience. On
the other hand, usefulness and educational value is certainly there.
I think you want: user-subscr...@beam.incubator.apache.org.
On Tue, Mar 22, 2016 at 3:55 PM, Dongjoon Hyun wrote:
>
>
Of course, this functionality can be implemented manually in a DoFn -- this
wouldn't be a primitive. That said, an argument could be made that a Beam
SDK should provide a composite that logs elements in a PCollection. This
can further be augmented with proposals like "log_every_n_seconds" or
You probably wanted to email: user-subscr...@beam.incubator.apache.org.
On Fri, Mar 4, 2016 at 4:07 PM, Anandha L Ranganathan wrote:
>
>