Bulk Operation

BEAM-2939 Make Dataflow executed UnboundedSources using SDF as the default

BEAM-2939 Migrate from ProcessContext#updateWatermark to WatermarkEstimators

BEAM-2939 Add support for splitting at fractions > 0 to org.apache.beam.sdk.transforms.splittabledofn.ByteKeyRangeTracker

BEAM-2939 Make the standard double coder well known within the Java SDK

BEAM-2939 Make Dataflow service receive required restriction encoding parameter on SplittableParDo

BEAM-2939 Python SDK harness should understand a BundleSplitRequest and respond with a BundleSplit before bundle finishes

BEAM-2939 Java SDK harness should understand a BundleSplitRequest and respond with a BundleSplit before bundle finishes

BEAM-2939 Streaming Dataflow runner harness should understand a BundleSplit returned during execution of a bundle

BEAM-2939 Python SDK harness should detect SDF ProcessFn and proactively checkpoint it

BEAM-2939 Java SDK harness should detect SDF ProcessFn and proactively checkpoint it

BEAM-2939 Streaming Dataflow runner harness should understand BundleSplit returned from ProcessBundle

BEAM-2939 Support for SDF splitting protocol in ULR

BEAM-2939 Support for running a streaming SDF in Python SDK

BEAM-2939 Proto changes for splitting over Fn API