org.apache.beam.sdk.io.gcp.bigquery

Class StorageApiConvertMessages.ConvertMessagesDoFn<DestinationT,ElementT>

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<KV<DestinationT,ElementT>,KV<DestinationT,StorageApiWritePayload>>

org.apache.beam.sdk.io.gcp.bigquery.StorageApiConvertMessages.ConvertMessagesDoFn<DestinationT,ElementT>

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Enclosing class:

StorageApiConvertMessages<DestinationT,ElementT>

public static class StorageApiConvertMessages.ConvertMessagesDoFn<DestinationT,ElementT>
extends DoFn<KV<DestinationT,ElementT>,KV<DestinationT,StorageApiWritePayload>>

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 and Description
void	onTeardown()
void	processElement(DoFn.ProcessContext c, PipelineOptions pipelineOptions, KV<DestinationT,ElementT> element, DoFn.OutputReceiver<KV<DestinationT,StorageApiWritePayload>> o)

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 Detail

onTeardown

@DoFn.Teardown
public void onTeardown()

processElement

@DoFn.ProcessElement
public void processElement(DoFn.ProcessContext c,
                                                PipelineOptions pipelineOptions,
                                                @DoFn.Element
                                                KV<DestinationT,ElementT> element,
                                                DoFn.OutputReceiver<KV<DestinationT,StorageApiWritePayload>> o)
                                         throws java.lang.Exception

Throws:

java.lang.Exception