Package org.apache.beam.sdk.io.gcp.healthcare

Class FhirIO.Write.AbstractResult

java.lang.Object

org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Write.AbstractResult

All Implemented Interfaces:

POutput

Direct Known Subclasses:

FhirIO.ExecuteBundlesResult, FhirIO.Write.Result

Enclosing class:

FhirIO.Write

public abstract static class FhirIO.Write.AbstractResult
extends Object
implements POutput

Constructor Summary

Constructors

Constructor	Description
AbstractResult()

Method Summary

Modifier and Type	Method	Description
void	finishSpecifyingOutput(String transformName, PInput input, PTransform<?,?> transform)	As part of applying the producing PTransform, finalizes this output to make it ready for being used as an input and for running.
abstract PCollection<HealthcareIOError<String>>	getFailedBodies()
abstract PCollection<HealthcareIOError<String>>	getFailedFiles()
Pipeline	getPipeline()	Returns the owning Pipeline of this POutput.
abstract PCollection<String>	getSuccessfulBodies()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.values.POutput

expand

Constructor Details

AbstractResult

public AbstractResult()

Method Details

getSuccessfulBodies

public abstract PCollection<String> getSuccessfulBodies()

getFailedBodies

public abstract PCollection<HealthcareIOError<String>> getFailedBodies()

getFailedFiles

public abstract PCollection<HealthcareIOError<String>> getFailedFiles()

getPipeline

public Pipeline getPipeline()

Description copied from interface: POutput

Returns the owning Pipeline of this POutput.

Specified by:

getPipeline in interface POutput

finishSpecifyingOutput

public void finishSpecifyingOutput(String transformName,
 PInput input,
 PTransform<?,?> transform)

Description copied from interface: POutput

As part of applying the producing PTransform, finalizes this output to make it ready for being used as an input and for running.

This includes ensuring that all PCollections have Coders specified or defaulted.

Automatically invoked whenever this POutput is output, after POutput.finishSpecifyingOutput(String, PInput, PTransform) has been called on each component PValue returned by POutput.expand().

Specified by:

finishSpecifyingOutput in interface POutput