org.apache.beam.sdk.values

Class PDone

java.lang.Object

org.apache.beam.sdk.values.PDone

All Implemented Interfaces:

POutput

public class PDone
extends java.lang.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 and Description
java.util.Map<TupleTag<?>,PValue>	expand() A PDone contains no PValues.
void	finishSpecifyingOutput(java.lang.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 Detail

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 java.util.Map<TupleTag<?>,PValue> expand()

A PDone contains no PValues.

Specified by:

expand in interface POutput

finishSpecifyingOutput

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

Does nothing; there is nothing to finish specifying.

Specified by:

finishSpecifyingOutput in interface POutput