PDone (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.values

Class PDone

• java.lang.Object
• • com.google.cloud.dataflow.sdk.values.POutputValueBase
  • • com.google.cloud.dataflow.sdk.values.PDone

• All Implemented Interfaces:

  POutput

  ---

  
  

  public class PDone
  extends POutputValueBase

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

• • Method Summary

    All Methods Static Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    Collection<? extends PValue>	expand() Expands this POutput into a list of its component output PValues.
    static PDone	in(Pipeline pipeline) Creates a PDone in the given Pipeline.

    • Methods inherited from class com.google.cloud.dataflow.sdk.values.POutputValueBase

      finishSpecifyingOutput, getPipeline, getProducingTransformInternal, recordAsOutput

    • 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.

    • expand

      public Collection<? extends PValue> expand()

      Description copied from interface: POutput
      Expands this POutput into a list of its component output PValues.

      • A PValue expands to itself.
      • A tuple or list of PValues (such as PCollectionTuple or PCollectionList) expands to its component PValue PValues.

      Not intended to be invoked directly by user code.