Details
-
Bug
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
None
Description
A useful reference is the trigger manager for the Java direct runner: https://github.com/apache/beam/pull/3988/files
Attachments
1.
|
Support TestStream on the fn_api_runner | Open | Unassigned | |||||||||
2.
|
Make FnApiRunner work by executing ready elements instead of stages | Open | Unassigned |
|
||||||||
3.
|
Delete python DirectRunner after FnApiRunner fully supports Batch & Streaming | Open | Unassigned | |||||||||
4.
|
StateServicer should be owned by FnApiRunnerContextManager | Open | Unassigned | |||||||||
5.
|
Split timers to multiple workers in ParallelBundleManager | Open | Unassigned | |||||||||
6.
|
Profile and improve performance for the local FnApiRunner | Open | Unassigned | |||||||||
7.
|
Support custom window fns on TriggerManager | Open | Unassigned | |||||||||
8.
|
Timers with same family ids in same stage (but different transforms) are buffered together | Open | Unassigned |