clear query| facets| time Search criteria: .   Results from 1 to 10 from 716 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-6858] Support side inputs injected into a DoFn - Beam - [issue]
...Beam currently supports injecting main inputs into a DoFn process method. A user can write the following:@ProcessElement public void process(@Element InputT element)And Beam will (using Byte...
http://issues.apache.org/jira/browse/BEAM-6858    Author: Reuven Lax , 2019-03-19, 00:46
[BEAM-6857] Support dynamic timers - Beam - [issue]
...The Beam timers API currently requires each timer to be statically specified in the DoFn. The user must provide a separate callback method per timer. For example:DoFn<String, String>()...
http://issues.apache.org/jira/browse/BEAM-6857    Author: Reuven Lax , 2019-03-19, 00:34
[BEAM-6856] Support dynamic MapState on Dataflow - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-6856    Author: Reuven Lax , 2019-03-19, 00:19
[BEAM-6855] Side inputs are not supported when using the state API - Beam - [issue]
http://issues.apache.org/jira/browse/BEAM-6855    Author: Reuven Lax , 2019-03-19, 00:11
[expand - 1 more] - JIRA hygiene - Beam - [mail # dev]
...Oh I agree with this. I'm just saying that an automated close on mergemight not always do the right thing.On Mon, Mar 18, 2019 at 4:51 AM Etienne Chauchot wrote:> Well, I agree but a cont...
   Author: Reuven Lax , 2019-03-18, 21:22
[BEAM-6772] Select transform has non-intuitive semantics - Beam - [issue]
...Consider the following schema:User:    name: STRING    location: Location Location:    latitude: DOUBLE    longitude: DOUBLE If you apply Select.fieldNames("location"), most users expect to ...
http://issues.apache.org/jira/browse/BEAM-6772    Author: Reuven Lax , 2019-03-15, 17:59
[expand - 10 more] - KafkaIO Exactly-Once & Flink Runner - Beam - [mail # dev]
...I think this attribute needs to be added to the portability protos.On Fri, Mar 15, 2019 at 9:49 AM Thomas Weise  wrote:>>> On Tue, Mar 12, 2019 at 10:13 AM Maximilian Michels &...
   Author: Reuven Lax , 2019-03-15, 16:59
[ANNOUNCE] New committer announcement: Raghu Angadi - Beam - [mail # dev]
...Congratulations!On Mon, Mar 11, 2019 at 8:51 PM Raghu Angadi  wrote:> Thank you all!>> On Mon, Mar 11, 2019 at 6:11 AM Maximilian Michels  wrote:>>> Congrats! :)&...
   Author: Reuven Lax , 2019-03-12, 22:36
Cross-language transform API - Beam - [mail # dev]
...About schemas, pr/7952 adds schemas to the runner API.This PR focuses on the Dataflow runner (not the portability runner).However after some community discussion on the design (we are still ...
   Author: Reuven Lax , 2019-03-12, 22:11
Always get to LGTM in Committer Guide - Beam - [mail # dev]
...You are right that it was decided that a contributor can review acommitter's PR. I think the committer guide was never updated, and weshould do so.On Tue, Mar 12, 2019 at 10:28 AM Gleb Kante...
   Author: Reuven Lax , 2019-03-12, 17:37