clear query| facets| time Search criteria: .   Results from 1 to 10 from 384 (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...    Author: Reuven Lax , 2019-08-23, 11:27
[BEAM-6855] Side inputs are not supported when using the state API - Beam - [issue]    Author: Reuven Lax , 2019-08-22, 04:11
[expand - 3 more] - Write-through-cache in State logic - Beam - [mail # dev]
...On Wed, Aug 21, 2019 at 2:16 AM Maximilian Michels  wrote:> Appreciate all your comments! Replying below.>>> @Luke:>> > Having cache tokens per key would be very ex...
   Author: Reuven Lax , 2019-08-21, 15:28
[BEAM-6675] The JdbcIO sink should accept schemas - Beam - [issue]
...If the input has a schema, there should be a default mapping to a PreparedStatement for writing based on that schema....    Author: Reuven Lax , 2019-08-20, 18:30
Support ZetaSQL as a new SQL dialect in BeamSQL - Beam - [mail # dev]
...I hear rumours that the Calcite project is planning on adding a zeta-SQLcompatible parser to Calcite itself, in which case there will be a Javaparser we can use as well. Does anyone know if ...
   Author: Reuven Lax , 2019-08-04, 22:54
[BEAM-6674] The JdbcIO source should produce schemas - Beam - [issue]    Author: Reuven Lax , 2019-08-02, 21:58
[DISCUSS] Moving FakeBigQueryServices to main/ rather than test/ - Beam - [mail # dev]
...The only concern is that we somewhat regularly have changed those classes,and I think we didn't want to have to support them as a stable interface.On Thu, Aug 1, 2019 at 5:23 PM Pablo Estrad...
   Author: Reuven Lax , 2019-08-02, 00:36
Choosing a coder for a class that contains a Row? - Beam - [mail # user]
...The metadata needed is already there - it's the encoding-position map inSchema. However the code needs to be written to examine an old schema and anew one in order to make the new schema enc...
   Author: Reuven Lax , 2019-07-26, 17:28
Stateful ParDo on Non-Keyed PCollection - Beam - [mail # user]
...Have you looked at the GroupIntoBatches transform?On Thu, Jul 25, 2019 at 9:34 AM rahul patwari wrote:> So, If an RPC call has to be performed for a batch of> Rows(PCollection), instea...
   Author: Reuven Lax , 2019-07-25, 16:38
[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>()...    Author: Reuven Lax , 2019-07-20, 10:06