Details
-
Improvement
-
Status: Open
-
P2
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Add an implementation for https://s.apache.org/batched-dofns to the Python SDK.
Attachments
Issue Links
- blocks
-
BEAM-14044 Hook In Batching DoFn Apis to RunInference
- Open
- is related to
-
BEAM-14540 Native implementation for serialized Rows to/from Arrow
- Open
- links to
1.
|
Add @DoFn.yields_batches and @DoFn.yields_elements decorators to override defaults | Open | Brian Hulette |
|
||||||||
2.
|
More verbose errors when BatchConverter fails to match | Open | Unassigned | |||||||||
3.
|
Consider providing a dynamic API for declaring batch input type | Open | Unassigned | |||||||||
4.
|
Add a TimestampedBatch analogue for TimestampedValue | Open | Unassigned | |||||||||
5.
|
batch-consuming DoFns should estimate byte size | Open | Brian Hulette |
|
||||||||
6.
|
Support per-key DoFn params in process_batch | Open | Unassigned |
This issue is assigned but has not received an update in 30 days so it has been labeled "stale-assigned". If you are still working on the issue, please give an update and remove the label. If you are no longer working on the issue, please unassign so someone else may work on it. In 7 days the issue will be automatically unassigned.