JIRA contributor access

2018-11-12 Thread Andrea Foegler
Hi all - I'm part of the Dataflow team at Google and would like to add a few features to the Dataflow Runner. Could someone add me as a JIRA contributor to track the work? Thanks! Andrea

Re: Does anyone have a strong intelliJ setup?

2018-10-26 Thread Andrea Foegler
ellij can't index java files for generated sources until those >> generated sources exist. >> >> On Fri, Oct 26, 2018 at 12:26 PM Andrea Foegler >> wrote: >> >>> So everything seems to build fine. But the analyzer shows missing >>> imports fo

Re: Does anyone have a strong intelliJ setup?

2018-10-26 Thread Andrea Foegler
ntelliJ docs and the wiki now has much more information: > https://cwiki.apache.org/confluence/display/BEAM/Using+IntelliJ+IDE > > If you're still having issues, take another look. And if you have a new > issues or tip that's not listed, please add it! > > On Fri, Oct

Re: Does anyone have a strong intelliJ setup?

2018-10-26 Thread Andrea Foegler
Thank you for the updated docs! I just set up IntelliJ from scratch and got the build smoothly the the point where it's happy to use up all the resources on my laptop :) It was great to be able to just follow the steps provided to get up and going! On Fri, Oct 19, 2018 at 2:34 AM Maximilian Mic

Re: External resources in Beam pipelines

2018-08-14 Thread Andrea Foegler
described the source. On Tue, Aug 14, 2018 at 10:43 AM Andrea Foegler wrote: > Hi folks - > > Many of you don't know me, as I don't contribute directly to Beam. But I > do a lot of work around the periphery, in particular considering how to > manage and monitor Beam pi

External resources in Beam pipelines

2018-08-14 Thread Andrea Foegler
Hi folks - Many of you don't know me, as I don't contribute directly to Beam. But I do a lot of work around the periphery, in particular considering how to manage and monitor Beam pipelines. I think there's room in Beam to greatly improve both the management and monitoring story, especially arou

Re: [VOTE] Community Examples Repository

2018-08-08 Thread Andrea Foegler
I guess I'm voting for 2. Tests obviously belong in the code repo, both as a sample usage (not "how-to", more like "man") and, well, for testing. These pipelines might not be annotated as completely and include hitting edge cases and other non-standard situations. Any example where the primary pu

Re: Updated [Proposal] Apache Beam Fn API : Defining and adding SDK Metrics

2018-04-13 Thread Andrea Foegler
On Fri, Apr 13, 2018 at 5:00 PM Robert Bradshaw wrote: > On Fri, Apr 13, 2018 at 3:28 PM Andrea Foegler wrote: > >> Thanks, Robert! >> >> I think my lack of clarity is around the MetricSpec. Maybe what's in my >> head and what's being proposed a

Re: Updated [Proposal] Apache Beam Fn API : Defining and adding SDK Metrics

2018-04-13 Thread Andrea Foegler
on metric representation could be a specific URN+payload >used for most metrics, while extensible ones use a different URN+payload. > > > Thanks for the discussion on this thread today. I'd like us to keep > engaging like this to come to an agreement. > Alex > > On Fri, A

Re: Updated [Proposal] Apache Beam Fn API : Defining and adding SDK Metrics

2018-04-13 Thread Andrea Foegler
"beam:counter::" or even >> "beam:metric::" since metrics have a type separate from >> their name. >> > > I proposed keeping the "user" in there to avoid possible clashes with the > system namespaces. (No preference on counter vs. metric, I wasn&#

Re: Updated [Proposal] Apache Beam Fn API : Defining and adding SDK Metrics

2018-04-13 Thread Andrea Foegler
> (and unknowable if one does not recognize the name). This makes things more >>> open-ended and easier to evolve and work with. >>> >>> Entity could be generalized to Label, or LabelSet if desired. But as >>> mentioned I think it makes sense to pull this out as a separate

Re: Updated [Proposal] Apache Beam Fn API : Defining and adding SDK Metrics

2018-04-13 Thread Andrea Foegler
Hi folks - Before we totally go down the path of highly structured metric protos, I'd like to propose considering a simple metrics interface between the SDK and the runner. Something more generic and closer to what most monitoring systems would use. To use Spark as an example, the Metric system