|
|
|
BEAM-14409
|
BEAM-14213
Support per-key DoFn params in process_batch
|
Unassigned
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14408
|
BEAM-14213
batch-consuming DoFns should estimate byte size
|
Brian Hulette
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14352
|
BEAM-14213
Add a TimestampedBatch analogue for TimestampedValue
|
Unassigned
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14340
|
BEAM-14213
Consider providing a dynamic API for declaring batch input type
|
Unassigned
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14339
|
BEAM-14213
More verbose errors when BatchConverter fails to match
|
Unassigned
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14294
|
BEAM-14213
MVP for SDK worker changes to support process_batch
|
Brian Hulette
|
Brian Hulette
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
BEAM-14293
|
BEAM-14213
Add @DoFn.yields_batches and @DoFn.yields_elements decorators to override defaults
|
Brian Hulette
|
Brian Hulette
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
BEAM-14292
|
BEAM-14213
Add API and construction-time validation for process_batch (with assumptions)
|
Brian Hulette
|
Brian Hulette
|
|
Resolved |
Fixed
|
|
|
|
|