Package org.apache.beam.sdk.transforms
Class JsonToRow.JsonToRowWithErrFn.ParseWithError
- java.lang.Object
-
- org.apache.beam.sdk.transforms.DoFn<java.lang.String,Row>
-
- org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.ParseWithError
-
- All Implemented Interfaces:
java.io.Serializable
,HasDisplayData
- Enclosing class:
- JsonToRow.JsonToRowWithErrFn
protected abstract static class JsonToRow.JsonToRowWithErrFn.ParseWithError extends DoFn<java.lang.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
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description static JsonToRow.JsonToRowWithErrFn.ParseWithError
create(JsonToRow.JsonToRowWithErrFn jsonToRowWithErrFn)
abstract JsonToRow.JsonToRowWithErrFn
getJsonToRowWithErrFn()
void
processElement(java.lang.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
-
-
-
-
Method Detail
-
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 java.lang.String element, DoFn.MultiOutputReceiver output)
-
-