org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn

Class PostProcessingMetricsDoFn

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<DataChangeRecord,DataChangeRecord>

org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn.PostProcessingMetricsDoFn

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

public class PostProcessingMetricsDoFn
extends DoFn<DataChangeRecord,DataChangeRecord>
implements java.io.Serializable

A DoFn class to gather metrics about the emitted DataChangeRecords. It will simply delegate the metrics gathering to the ChangeStreamMetrics. The metrics measured in this component are:

1. The number of data records emitted.
2. The latency between a record's Cloud Spanner commit timestamp and the time it reached this component (referred as emit timestamp).
3. The streaming latency of a record from the change stream query.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn

DoFn.AlwaysFetched, DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetInitialWatermarkEstimatorState, DoFn.GetRestrictionCoder, DoFn.GetSize, DoFn.GetWatermarkEstimatorStateCoder, DoFn.Key, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.NewWatermarkEstimator, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnTimerFamily, DoFn.OnWindowExpiration, DoFn.OnWindowExpirationContext, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.RequiresTimeSortedInput, DoFn.Restriction, DoFn.Setup, DoFn.SideInput, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerFamily, DoFn.TimerId, DoFn.Timestamp, DoFn.TruncateRestriction, DoFn.UnboundedPerElement, DoFn.WatermarkEstimatorState, DoFn.WindowedContext

Constructor Summary

Constructors

Constructor and Description
PostProcessingMetricsDoFn(ChangeStreamMetrics metrics)

Method Summary

Modifier and Type	Method and Description
void	processElement(DataChangeRecord dataChangeRecord, DoFn.OutputReceiver<DataChangeRecord> receiver) Stage to measure a data records latencies and metrics.

Methods inherited from class org.apache.beam.sdk.transforms.DoFn

getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

PostProcessingMetricsDoFn

public PostProcessingMetricsDoFn(ChangeStreamMetrics metrics)

Method Detail

processElement

@DoFn.ProcessElement
public void processElement(@DoFn.Element
                                                DataChangeRecord dataChangeRecord,
                                                DoFn.OutputReceiver<DataChangeRecord> receiver)

Stage to measure a data records latencies and metrics. The metrics gathered are:

1. The number of data records emitted.
2. The latency between a record's Cloud Spanner commit timestamp and the time it reached this component (referred as emit timestamp).
3. The streaming latency of a record from the change stream query.

After measurement the record is re-emitted to the next stage.

Parameters:

dataChangeRecord - the record to gather metrics for

receiver - the output receiver of the PostProcessingMetricsDoFn SDF