DirectPipelineRunner.ValueWithMetadata (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class DirectPipelineRunner.ValueWithMetadata<V>

  • java.lang.Object
  • Enclosing class:

    public static class DirectPipelineRunner.ValueWithMetadata<V>
    extends Object
    An immutable (value, timestamp) pair, along with other metadata necessary for the implementation of DirectPipelineRunner.
    • Method Detail

      • of

        public static <V> DirectPipelineRunner.ValueWithMetadata<V> of(<V> windowedValue)
        Returns a new ValueWithMetadata with the WindowedValue. Key is null.
      • withKey

        public DirectPipelineRunner.ValueWithMetadata<V> withKey(Object key)
        Returns a new ValueWithMetadata with the implicit key associated with this value set. The key is the last key grouped by in the chain of productions that produced this element. These keys are used internally by DirectPipelineRunner for keeping persisted state separate across keys.
      • getWindowedValue

        public<V> getWindowedValue()
        Returns the WindowedValue associated with this element.
      • getValue

        public V getValue()
        Returns the value associated with this element.
        See Also:
      • getTimestamp

        public Instant getTimestamp()
        Returns the timestamp associated with this element.
      • getWindows

        public Collection<? extends BoundedWindow> getWindows()
        Returns the collection of windows this element has been placed into. May be null if the PCollection this element is in has not yet been windowed.
        See Also:
      • getKey

        public Object getKey()
        Returns the key associated with this element. May be null if the PCollection this element is in is not keyed.
        See Also: