Bulk Operation

BEAM-7514 Timers with same family ids in same stage (but different transforms) are buffered together

BEAM-7514 Support custom window fns on TriggerManager

BEAM-7514 Profile and improve performance for the local FnApiRunner

BEAM-7514 A trigger manager for the FnApiRunner

BEAM-7514 Track performance of FnApiRunner over the changes to support streaming

BEAM-7514 Split timers to multiple workers in ParallelBundleManager

BEAM-7514 Track PCollection watermark across bundle executions

BEAM-7514 Abstract bundle execution logic from stage execution logic

BEAM-7514 StateServicer should be owned by FnApiRunnerContextManager

BEAM-7514 Add context managers for FnApiRunner to manage execution of each bundle

BEAM-7514 Refactor FnApiRunner into its own package

BEAM-7514 Delete python DirectRunner after FnApiRunner fully supports Batch & Streaming

BEAM-7514 Make FnApiRunner work by executing ready elements instead of stages

BEAM-7514 Add a watermark manager for the fn_api_runner

BEAM-7514 Support TestStream on the fn_api_runner