public static class PubsubLiteReadSchemaTransformProvider.ErrorFn extends DoFn<com.google.cloud.pubsublite.proto.SequencedMessage,Row>
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 and Description |
---|
ErrorFn(java.lang.String name,
SerializableFunction<byte[],Row> valueMapper,
Schema errorSchema,
boolean handleErrors) |
ErrorFn(java.lang.String name,
SerializableFunction<byte[],Row> valueMapper,
Schema errorSchema,
java.util.List<java.lang.String> attributes,
java.lang.String attributeMap,
Schema attributeSchema,
boolean handleErrors) |
Modifier and Type | Method and Description |
---|---|
void |
finish(DoFn.FinishBundleContext c) |
void |
process(com.google.cloud.pubsublite.proto.SequencedMessage seqMessage,
DoFn.MultiOutputReceiver receiver) |
getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing
public ErrorFn(java.lang.String name, SerializableFunction<byte[],Row> valueMapper, Schema errorSchema, boolean handleErrors)
public ErrorFn(java.lang.String name, SerializableFunction<byte[],Row> valueMapper, Schema errorSchema, java.util.List<java.lang.String> attributes, java.lang.String attributeMap, Schema attributeSchema, boolean handleErrors)
@DoFn.ProcessElement public void process(@DoFn.Element com.google.cloud.pubsublite.proto.SequencedMessage seqMessage, DoFn.MultiOutputReceiver receiver)
@DoFn.FinishBundle public void finish(DoFn.FinishBundleContext c)