public interface BundleSplitHandler
The returned split response contains a description of work that has been performed containing
primary portion that the SDK is responsible for processing and a
the runner is responsible for scheduling for future processing. See breaking the fusion barrier for further
|Modifier and Type||Method and Description|
Returns a bundle split handler that throws on any split response.
void split(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleSplitResponse splitResponse)
static BundleSplitHandler unsupported()