public class SpannerWriteResult
extends java.lang.Object
implements org.apache.beam.sdk.values.POutput
SpannerIO.write()
transform.
Use getFailedMutations()
to access a PCollection
of MutationGroups that
failed to write.
The PCollection
returned by getOutput()
can be used in batch pipelines as a
completion signal to Wait.OnSignal
to indicate when
all input has been written. Note that in streaming pipelines, this signal will never be triggered
as the input is unbounded and this PCollection
is using the GlobalWindow
.
Constructor and Description |
---|
SpannerWriteResult(org.apache.beam.sdk.Pipeline pipeline,
org.apache.beam.sdk.values.PCollection<java.lang.Void> output,
org.apache.beam.sdk.values.PCollection<MutationGroup> failedMutations,
org.apache.beam.sdk.values.TupleTag<MutationGroup> failedMutationsTag) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,org.apache.beam.sdk.values.PValue> |
expand() |
void |
finishSpecifyingOutput(java.lang.String transformName,
org.apache.beam.sdk.values.PInput input,
org.apache.beam.sdk.transforms.PTransform<?,?> transform) |
org.apache.beam.sdk.values.PCollection<MutationGroup> |
getFailedMutations() |
org.apache.beam.sdk.values.PCollection<java.lang.Void> |
getOutput() |
org.apache.beam.sdk.Pipeline |
getPipeline() |
public SpannerWriteResult(org.apache.beam.sdk.Pipeline pipeline, org.apache.beam.sdk.values.PCollection<java.lang.Void> output, org.apache.beam.sdk.values.PCollection<MutationGroup> failedMutations, org.apache.beam.sdk.values.TupleTag<MutationGroup> failedMutationsTag)
public org.apache.beam.sdk.Pipeline getPipeline()
getPipeline
in interface org.apache.beam.sdk.values.POutput
public java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,org.apache.beam.sdk.values.PValue> expand()
expand
in interface org.apache.beam.sdk.values.POutput
public org.apache.beam.sdk.values.PCollection<MutationGroup> getFailedMutations()
public org.apache.beam.sdk.values.PCollection<java.lang.Void> getOutput()
public void finishSpecifyingOutput(java.lang.String transformName, org.apache.beam.sdk.values.PInput input, org.apache.beam.sdk.transforms.PTransform<?,?> transform)
finishSpecifyingOutput
in interface org.apache.beam.sdk.values.POutput