org.apache.beam.runners.fnexecution.control

Interface BundleSplitHandler

public interface BundleSplitHandler

A handler which is invoked whenever an active bundle is split. The active bundle will continue to keep processing until it is complete.

The returned split response contains a description of work that has been performed containing a primary portion that the SDK is responsible for processing and a residual which the runner is responsible for scheduling for future processing. See breaking the fusion barrier for further details.

Method Summary

Modifier and Type	Method and Description
void	split(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleSplitResponse splitResponse)
static BundleSplitHandler	unsupported() Returns a bundle split handler that throws on any split response.

Method Detail

split

void split(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleSplitResponse splitResponse)

unsupported

static BundleSplitHandler unsupported()

Returns a bundle split handler that throws on any split response.