clear query| facets| time Search criteria: .   Results from 1 to 10 from 594 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-4461] Create a library of useful transforms that use schemas - Beam - [issue]
...e.g. JoinBy(fields). Project, Filter, etc....    Author: Reuven Lax , 2018-11-20, 08:45
[expand - 2 more] - Bigquery streaming TableRow size limit - Beam - [mail # dev]
...This sounds a bit more specific, so I wouldn't add this to BigQueryIO yet.On Thu, Nov 15, 2018 at 6:58 PM Wout Scheepers <[EMAIL PROTECTED]> wrote:> Thanks for your thoughts.>>...
   Author: Reuven Lax , 2018-11-17, 02:37
[expand - 3 more] - Design review for supporting AutoValue Coders and conversions to Row - Beam - [mail # dev]
...I would hope so if possible.On Fri, Nov 16, 2018, 4:36 AM Kenneth Knowles <[EMAIL PROTECTED] wrote:> Just some low-level detail: If there is no @DefaultSchema annotation but> it is ...
   Author: Reuven Lax , 2018-11-15, 21:37
[expand - 1 more] - Evolving a Coder for an added field - Beam - [mail # dev]
...A few thoughts:1. I agree with you about coder versioning. The lack of a good story aroundversioning has been a huge pain here, and it's unfortunate that nobody everworked on this.2. I think...
   Author: Reuven Lax , 2018-11-13, 01:23
[expand - 3 more] - [DISCUSS] More precision supported by DATETIME field in Schema - Beam - [mail # dev]
...As you said, this would be update incompatible across all streamingpipelines. At the very least this would be a big problem for Dataflowusers, and I believe many Flink users as well. I'm not...
   Author: Reuven Lax , 2018-11-07, 09:15
How to isSet() check for a Timer - Beam - [mail # dev]
...Those apis might make sense, but I'm not sure how they would be"blindwrites." I assume we would implement them by adding a hidden ValueState.On Fri, Nov 2, 2018, 11:01 PM Kenneth Knowles <...
   Author: Reuven Lax , 2018-11-03, 04:12
[BEAM-1438] The default behavior for the Write transform doesn't work well with the Dataflow streaming runner - Beam - [issue]
...If a Write specifies 0 output shards, that implies the runner should pick an appropriate sharding. The default behavior is to write one shard per input bundle. This works well with the Dataf...    Author: Reuven Lax , 2018-10-26, 12:40
[expand - 1 more] - Unbalanced FileIO writes on Flink - Beam - [mail # user]
...FYI the Dataflow runner automatically sets the default number of shards (Ibelieve to be 2 * num_workers). Probably we should do something similar forthe Flink runner.This needs to be done by...
   Author: Reuven Lax , 2018-10-25, 20:37
KafkaIO - Deadletter output - Beam - [mail # user]
...On Wed, Oct 24, 2018, 10:26 PM Raghu Angadi  wrote:> Well, if every input record's timestamp is X, watermark staying at X is> the right answer, no? But I am not sure where the dis...
   Author: Reuven Lax , 2018-10-25, 06:54
[PROPOSAL] Move sorting to sdks-java-core - Beam - [mail # dev]
...One concern would be merging windows. This happens after shuffle, so evenif the shuffle were sorted you would need to do a sorted merge of twosorted buffers.On Wed, Oct 17, 2018 at 2:08 PM D...
   Author: Reuven Lax , 2018-10-17, 21:10