Re: Contributing Beam Kata (Java & Python)

+1 :-) *From: *Lukasz Cwik *Date: *Wed, 15 May 2019 at 04:29 *To: *dev *Cc: *Lars Francke +1 > > *From: *Pablo Estrada > *Date: *Tue, May 14, 2019 at 1:27 PM > *To: *dev > *Cc: *Lars Francke > > +1 on merging. >> >> *From: *Reuven Lax >> *Date: *Tue, May 14, 2019 at 1:23 PM >> *To: *dev >> *Cc

SqlTransform Metadata

Hi, What are folks thoughts about adding something like SqlTransform.withMetadata().query(...)to enable users to be able to access things like Timestamp information from within the query without having to refiy the information into the element itself? Cheers Reza -- This email may be confide

Re: Beam Summit at ApacheCon

Hi, Kenn and I have submitted a talk on state and timers and dealing with timeseries. Cheers Reza *From: *Austin Bennett *Date: *Sun, 12 May 2019, 00:47 *To: *dev *Cc: * Hi All, > > Deadline for CfP is the morning of 13 May (this Monday) Pacific Time, as > decided by ApacheCon. Please subm

Re: [DISCUSS] Reconciling ValueState in Java and Python (was: [docs] Python State & Timers)

a CombiningValueState is not ideal because I'd need to >> implement a merge_accumulators function that combines several in-progress >> batches. I could certainly implement that, but I'd prefer that it never be >> called unless absolutely necessary, which doesn't seem to be the case

Re: Beam at Google Summer of Code 2019

+1 Congratulations! Looking forward to using your work ! *From: *Valentyn Tymofieiev *Date: *Tue, 7 May 2019 at 05:40 *To: *dev *Cc: * Congrats & good luck Tanay & Pablo! > > *From: *Connell O'Callaghan > *Date: *Mon, May 6, 2019 at 4:15 PM > *To: * > *Cc: * > > Well done Tanay - good luck w

Re: Better naming for runner specific options

ple, if there were was >>>> "optionX" >>>> in class A and B, we could use "A#optionX" to refer to it from class A. >>>> >>> > I think this solves the original problem. Runner specific options will > have unique names that

Re: Better naming for runner specific options

, it makes sense to use a namespace prefix. The >>>>> primary issue here is that, such a change will very likely be a backward >>>>> incompatible change and would be hard to do before the next major version. >>>>> >>>>> [1] https://issues.apache.org

Re: [ANNOUNCE] New committer announcement: Udi Meiri

Congratulations ! *From: *Reuven Lax *Date: *Sat, 4 May 2019, 06:42 *To: *dev Thank you! > > On Fri, May 3, 2019 at 3:15 PM Ankur Goenka wrote: > >> Congratulations Udi! >> >> On Fri, May 3, 2019 at 3:00 PM Connell O'Callaghan >> wrote: >> >>> Well done Udi!!! Congratulations and thank you for

Better naming for runner specific options

Hi, Was reading this SO question: https://stackoverflow.com/questions/53833171/googlecloudoptions-doesnt-have-all-options-that-pipeline-options-has And noticed that in https://beam.apache.org/releases/pydoc/2.12.0/_modules/apache_beam/options/pipeline_options.html#WorkerOptions The option is c

Re: Congrats to Beam's first 6 Google Open Source Peer Bonus recipients!

Congratulations! On Thu, 2 May 2019 at 10:53, Connell O'Callaghan wrote: > Well done - congratulations to you all!!! Rose thank you for sharing this > news!!! > > On Wed, May 1, 2019 at 19:45 Rose Nguyen wrote: > >> Matthias Baetens, Lukazs Gajowy, Suneel Marthi, Maximilian Michels, Alex >> Van

Re: [DISCUSS] Reconciling ValueState in Java and Python (was: [docs] Python State & Timers)

>>>> retractions, you really need this callback, so you can issue retractions >>>> manually for any output your stateful DoFn emitted in windows that no >>>> longer exist. >>>> >>>> I agree we'll probably need an @OnMerge. On the other hand,

Re: [DISCUSS] Reconciling ValueState in Java and Python (was: [docs] Python State & Timers)

+1 on the metadata use case. For performance reasons the Timer API does not support a read() operation, which for the vast majority of use cases is not a required feature. In the small set of use cases where it is needed, for example when you need to set a Timer in EventTime based on the smallest

Re: Hello from Hannah Jiang

Welcome! On Fri, 26 Apr 2019 at 04:36, Hannah Jiang wrote: > Thanks Cyrus! > > On Thu, Apr 25, 2019 at 1:34 PM Cyrus Maden wrote: > >> Welcome!! >> >> On Thu, Apr 25, 2019 at 4:30 PM Hannah Jiang >> wrote: >> >>> Thank you Robin! >>> >>> On Thu, Apr 25, 2019 at 1:27 PM Robin Qiu wrote: >>> >>

Re: [ANNOUNCE] New committer announcement: Yifan Zou

Congrats Yifan! On Fri, 26 Apr 2019 at 08:02, jincheng sun wrote: > Congrats Yifan! > > Griselda Cuevas 于2019年4月26日周五 上午1:56写道： > >> Congrats Yifan! >> >> >> >> >> On Mon, 22 Apr 2019 at 08:26, Kenneth Knowles wrote: >> >>> Hi all, >>> >>> Please join me and the rest of the Beam PMC in welcomi

Re: Beam Summits!

Hi, So after a few chats, would love to help enable a event in APAC later in Q3 / early Q4 timeframe. Cheers Reza On Tue, 8 Jan 2019 at 14:49, Reza Rokni wrote: > Hya, > > Yes. although need to work through timing, maybe something around the > later part of the year. > >

Re: [Proposal] Beam Newsletter

+1 On Sep 22, 2017 2:32 AM, "Griselda Cuevas" wrote: > Hi Beam Community, > > I have a proposal to start sending *monthly newsletters* to our dev and > user mailing lists. The idea is to summarize what's happening in the > project and keep everyone informed of what's happening, specially new > m

<    1   2