public interface BundleProgressHandler
Methods on this interface will only be called serially, and after onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse)
no more
calls will be made.
Modifier and Type | Method and Description |
---|---|
void |
onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
Handles the bundle's completion report.
|
void |
onProgress(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleProgressResponse progress)
Handles a progress report from the bundle while it is executing.
|
static BundleProgressHandler |
unsupported()
Returns a handler that ignores metrics and throws on splits (as splits can not be ignored).
|
void onProgress(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleProgressResponse progress)
void onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
static BundleProgressHandler unsupported()