public class DoFnRunnerWithMetricsUpdate<InputT,OutputT>
extends java.lang.Object
implements org.apache.beam.runners.core.DoFnRunner<InputT,OutputT>
DoFnRunner
decorator which registers MetricsContainerImpl
. It updates metrics to
Flink metrics and accumulators in finishBundle()
.Constructor and Description |
---|
DoFnRunnerWithMetricsUpdate(java.lang.String stepName,
org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> delegate,
FlinkMetricContainer metricContainer) |
Modifier and Type | Method and Description |
---|---|
void |
finishBundle() |
DoFn<InputT,OutputT> |
getFn() |
void |
onTimer(java.lang.String timerId,
java.lang.String timerFamilyId,
BoundedWindow window,
Instant timestamp,
Instant outputTimestamp,
TimeDomain timeDomain) |
void |
processElement(org.apache.beam.sdk.util.WindowedValue<InputT> elem) |
void |
startBundle() |
public DoFnRunnerWithMetricsUpdate(java.lang.String stepName, org.apache.beam.runners.core.DoFnRunner<InputT,OutputT> delegate, FlinkMetricContainer metricContainer)
public void startBundle()
public void processElement(org.apache.beam.sdk.util.WindowedValue<InputT> elem)
public void onTimer(java.lang.String timerId, java.lang.String timerFamilyId, BoundedWindow window, Instant timestamp, Instant outputTimestamp, TimeDomain timeDomain)
public void finishBundle()