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

Class SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow

java.lang.Object

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

org.apache.beam.sdk.io.gcp.spanner.changestreams.SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

SpannerChangestreamsReadSchemaTransformProvider

public static final class SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow
extends DoFn<DataChangeRecord,Row>

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

Method Summary

Modifier and Type	Method	Description
void	finish(DoFn<DataChangeRecord,Row>.FinishBundleContext c)
org.apache.beam.vendor.grpc.v1p69p0.com.google.gson.Gson	getGson()
void	process(DataChangeRecord record, DoFn.MultiOutputReceiver receiver)

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

Method Details

getGson

public org.apache.beam.vendor.grpc.v1p69p0.com.google.gson.Gson getGson()

process

@ProcessElement
public void process(@Element
 DataChangeRecord record,
 DoFn.MultiOutputReceiver receiver)

finish

@FinishBundle
public void finish(DoFn<DataChangeRecord,Row>.FinishBundleContext c)