TypedPValue (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1


Class TypedPValue<T>

  • Type Parameters:
    T - the type of the values stored in this TypedPValue
    All Implemented Interfaces:
    PInput, POutput, PValue
    Direct Known Subclasses:

    public abstract class TypedPValue<T>
    extends PValueBase
    implements PValue
    A TypedPValue<T> is the abstract base class of things that store some number of values of type T.

    Because we know the type T, this is the layer of the inheritance hierarchy where we store a coder for objects of type T.

    • Constructor Detail

      • TypedPValue

        protected TypedPValue(Pipeline p)
    • Method Detail

      • finishSpecifying

        public void finishSpecifying()
        After building, finalizes this PValue to make it ready for running. Automatically invoked whenever the PValue is "used" (e.g., when apply() is called on it) and when the Pipeline is run (useful if this is a PValue with no consumers).
        Specified by:
        finishSpecifying in interface PInput
        finishSpecifying in class PValueBase
      • getTypeDescriptor

        public TypeDescriptor<T> getTypeDescriptor()
        Returns a TypeDescriptor<T> with some reflective information about T, if possible. May return null if no information is available. Subclasses may override this to enable better Coder inference.