public abstract static class JsonToRow.JsonToRowWithErrFn extends PTransform<PCollection<java.lang.String>,JsonToRow.ParseResult>
Modifier and Type | Class and Description |
---|---|
static class |
JsonToRow.JsonToRowWithErrFn.Builder |
protected static class |
JsonToRow.JsonToRowWithErrFn.ParseWithError |
Modifier and Type | Field and Description |
---|---|
static Schema |
ERROR_ROW_SCHEMA |
static Schema |
ERROR_ROW_WITH_ERR_MSG_SCHEMA |
name, resourceHints
Constructor and Description |
---|
JsonToRowWithErrFn() |
Modifier and Type | Method and Description |
---|---|
JsonToRow.ParseResult |
expand(PCollection<java.lang.String> jsonStrings)
Override this method to specify how this
PTransform should be expanded on the given
InputT . |
JsonToRow.JsonToRowWithErrFn |
setErrorField(java.lang.String errorField)
Adds the error message to the returned error Row.
|
JsonToRow.JsonToRowWithErrFn |
setLineField(java.lang.String lineField)
Sets the field name for the line field in the returned Row.
|
JsonToRow.JsonToRowWithErrFn |
withExtendedErrorInfo()
Adds the error message to the returned error Row.
|
JsonToRow.JsonToRowWithErrFn |
withNullBehavior(org.apache.beam.sdk.util.RowJson.RowJsonDeserializer.NullBehavior nullBehavior)
Sets the behavior of the deserializer according to
RowJson.RowJsonDeserializer.NullBehavior . |
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public static final Schema ERROR_ROW_SCHEMA
public static final Schema ERROR_ROW_WITH_ERR_MSG_SCHEMA
public JsonToRow.JsonToRowWithErrFn withExtendedErrorInfo()
JsonToRow
public JsonToRow.JsonToRowWithErrFn setLineField(java.lang.String lineField)
JsonToRow
public JsonToRow.JsonToRowWithErrFn setErrorField(java.lang.String errorField)
JsonToRow
public JsonToRow.JsonToRowWithErrFn withNullBehavior(org.apache.beam.sdk.util.RowJson.RowJsonDeserializer.NullBehavior nullBehavior)
RowJson.RowJsonDeserializer.NullBehavior
.JsonToRow
public JsonToRow.ParseResult expand(PCollection<java.lang.String> jsonStrings)
PTransform
PTransform
should be expanded on the given
InputT
.
NOTE: This method should not be called directly. Instead apply the PTransform
should
be applied to the InputT
using the apply
method.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
expand
in class PTransform<PCollection<java.lang.String>,JsonToRow.ParseResult>