Package org.apache.beam.sdk.transforms
Class JsonToRow.ParseResult
- java.lang.Object
-
- org.apache.beam.sdk.transforms.JsonToRow.ParseResult
-
- All Implemented Interfaces:
POutput
- Enclosing class:
- JsonToRow
public abstract static class JsonToRow.ParseResult extends java.lang.Object implements POutput
The result of aJsonToRow.withExceptionReporting(Schema)
transform.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
JsonToRow.ParseResult.Builder
-
Constructor Summary
Constructors Constructor Description ParseResult()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Map<TupleTag<?>,PValue>
expand()
void
finishSpecifyingOutput(java.lang.String transformName, PInput input, PTransform<?,?> transform)
As part of applying the producingPTransform
, finalizes this output to make it ready for being used as an input and for running.PCollection<Row>
getFailedToParseLines()
Returns aPCollection
containing theRow
s that didn't parse.Pipeline
getPipeline()
PCollection<Row>
getResults()
Returns aPCollection
containing theRow
s that have been parsed.static JsonToRow.ParseResult.Builder
resultBuilder()
-
-
-
Method Detail
-
resultBuilder
public static JsonToRow.ParseResult.Builder resultBuilder()
-
getPipeline
public Pipeline getPipeline()
Description copied from interface:POutput
- Specified by:
getPipeline
in interfacePOutput
-
expand
public java.util.Map<TupleTag<?>,PValue> expand()
Description copied from interface:POutput
Expands thisPOutput
into a list of its component outputPValues
.- A
PValue
expands to itself. - A tuple or list of
PValues
(such asPCollectionTuple
orPCollectionList
) expands to its componentPValue PValues
.
Not intended to be invoked directly by user code.
- A
-
finishSpecifyingOutput
public void finishSpecifyingOutput(java.lang.String transformName, PInput input, PTransform<?,?> transform)
Description copied from interface:POutput
As part of applying the producingPTransform
, finalizes this output to make it ready for being used as an input and for running.This includes ensuring that all
PCollections
haveCoders
specified or defaulted.Automatically invoked whenever this
POutput
is output, afterPOutput.finishSpecifyingOutput(String, PInput, PTransform)
has been called on each componentPValue
returned byPOutput.expand()
.- Specified by:
finishSpecifyingOutput
in interfacePOutput
-
getResults
public PCollection<Row> getResults()
Returns aPCollection
containing theRow
s that have been parsed.
-
getFailedToParseLines
public PCollection<Row> getFailedToParseLines()
Returns aPCollection
containing theRow
s that didn't parse.If
JsonToRow.JsonToRowWithErrFn.withExtendedErrorInfo()
was set then the schema will also include the error message.
-
-