Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.values
Class POutputValueBase
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.values.POutputValueBase
-
- All Implemented Interfaces:
- POutput
- Direct Known Subclasses:
- PDone, PValueBase
public abstract class POutputValueBase extends Object implements POutput
APOutputValueBase
is the abstract base class ofPTransform
outputs.A
PValueBase
that adds tracking of its producingAppliedPTransform
.For internal use.
-
-
Constructor Summary
Constructors Modifier Constructor and Description protected
POutputValueBase()
No-arg constructor for Java serialization only.protected
POutputValueBase(Pipeline pipeline)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description void
finishSpecifyingOutput()
Default behavior forfinishSpecifyingOutput()
is to do nothing.Pipeline
getPipeline()
AppliedPTransform<?,?,?>
getProducingTransformInternal()
Returns theAppliedPTransform
that thisPOutputValueBase
is an output of.void
recordAsOutput(AppliedPTransform<?,?,?> transform)
Records that thisPOutputValueBase
is an output with the given name of the givenAppliedPTransform
.
-
-
-
Constructor Detail
-
POutputValueBase
protected POutputValueBase(Pipeline pipeline)
-
POutputValueBase
protected POutputValueBase()
No-arg constructor for Java serialization only. The resultingPOutputValueBase
is unlikely to be valid.
-
-
Method Detail
-
getPipeline
public Pipeline getPipeline()
Description copied from interface:POutput
- Specified by:
getPipeline
in interfacePOutput
-
getProducingTransformInternal
public AppliedPTransform<?,?,?> getProducingTransformInternal()
-
recordAsOutput
public void recordAsOutput(AppliedPTransform<?,?,?> transform)
Records that thisPOutputValueBase
is an output with the given name of the givenAppliedPTransform
.To be invoked only by
POutput.recordAsOutput(com.google.cloud.dataflow.sdk.transforms.AppliedPTransform<?, ?, ?>)
implementations. Not to be invoked directly by user code.- Specified by:
recordAsOutput
in interfacePOutput
-
finishSpecifyingOutput
public void finishSpecifyingOutput()
Default behavior forfinishSpecifyingOutput()
is to do nothing. Override if yourPValue
requires finalization.- Specified by:
finishSpecifyingOutput
in interfacePOutput
-
-