Package org.apache.beam.sdk.values

Class PDone

java.lang.Object

org.apache.beam.sdk.values.PDone

All Implemented Interfaces:

POutput

public class PDone
extends Object
implements POutput

PDone is the output of a PTransform that has a trivial result, such as a WriteFiles.

Method Summary

Modifier and Type	Method	Description
Map<TupleTag<?>,PValue>	expand()	A PDone contains no PValues.
void	finishSpecifyingOutput(String transformName, PInput input, PTransform<?,?> transform)	Does nothing; there is nothing to finish specifying.
Pipeline	getPipeline()	Returns the owning Pipeline of this POutput.
static PDone	in(Pipeline pipeline)	Creates a PDone in the given Pipeline.

Methods inherited from class java.lang.Object

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

Method Details

in

public static PDone in(Pipeline pipeline)

Creates a PDone in the given Pipeline.

getPipeline

public Pipeline getPipeline()

Description copied from interface: POutput

Returns the owning Pipeline of this POutput.

Specified by:

getPipeline in interface POutput

expand

public Map<TupleTag<?>,PValue> expand()

A PDone contains no PValues.

Specified by:

expand in interface POutput

finishSpecifyingOutput

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

Does nothing; there is nothing to finish specifying.

Specified by:

finishSpecifyingOutput in interface POutput