Package org.apache.beam.sdk.transforms

Class JsonToRow.JsonToRowWithErrFn.ParseWithError

java.lang.Object

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

org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.ParseWithError

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

JsonToRow.JsonToRowWithErrFn

protected abstract static class JsonToRow.JsonToRowWithErrFn.ParseWithError
extends DoFn<String,Row>

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JsonToRow.JsonToRowWithErrFn.ParseWithError.Builder

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

Modifier	Constructor	Description
protected	ParseWithError()

Method Summary

Modifier and Type	Method	Description
static JsonToRow.JsonToRowWithErrFn.ParseWithError	create(JsonToRow.JsonToRowWithErrFn jsonToRowWithErrFn)
abstract JsonToRow.JsonToRowWithErrFn	getJsonToRowWithErrFn()
void	processElement(String element, DoFn.MultiOutputReceiver output)
abstract JsonToRow.JsonToRowWithErrFn.ParseWithError.Builder	toBuilder()

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 Details

ParseWithError

protected ParseWithError()

Method Details

getJsonToRowWithErrFn

public abstract JsonToRow.JsonToRowWithErrFn getJsonToRowWithErrFn()

toBuilder

public abstract JsonToRow.JsonToRowWithErrFn.ParseWithError.Builder toBuilder()

create

public static JsonToRow.JsonToRowWithErrFn.ParseWithError create(JsonToRow.JsonToRowWithErrFn jsonToRowWithErrFn)

processElement

@ProcessElement
public void processElement(@Element
 String element,
 DoFn.MultiOutputReceiver output)