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 |
---|---|
static BundleProgressHandler |
ignored()
Returns a handler that ignores metrics.
|
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.
|
void onProgress(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleProgressResponse progress)
void onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
static BundleProgressHandler ignored()