Package org.apache.beam.runners.flink.metrics

Class ReaderInvocationUtil<OutputT,ReaderT extends Source.Reader<OutputT>>

java.lang.Object

org.apache.beam.runners.flink.metrics.ReaderInvocationUtil<OutputT,ReaderT>

public class ReaderInvocationUtil<OutputT,ReaderT extends Source.Reader<OutputT>>
extends Object

Util for invoking Source.Reader methods that might require a MetricsContainerImpl to be active. Source.Reader decorator which registers MetricsContainerImpl. It update metrics to Flink metric and accumulator in start and advance.

Constructor Summary

Constructors

Constructor	Description
ReaderInvocationUtil(String stepName, PipelineOptions options, org.apache.beam.runners.flink.metrics.FlinkMetricContainerBase container)

Method Summary

Modifier and Type	Method	Description
boolean	invokeAdvance(ReaderT reader)
boolean	invokeStart(ReaderT reader)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReaderInvocationUtil

public ReaderInvocationUtil(String stepName,
 PipelineOptions options,
 org.apache.beam.runners.flink.metrics.FlinkMetricContainerBase container)

Method Details

invokeStart

public boolean invokeStart(ReaderT reader)
                    throws IOException

Throws:

IOException

invokeAdvance

public boolean invokeAdvance(ReaderT reader)
                      throws IOException

Throws:

IOException