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:

이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.