StepTransformResult (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class StepTransformResult

  • java.lang.Object

  • public abstract class StepTransformResult
    extends Object
    An immutable InProcessTransformResult.
    • Constructor Detail

      • StepTransformResult

        public StepTransformResult()
    • Method Detail

      • getUnprocessedElements

        public abstract Iterable<? extends<?>> getUnprocessedElements()
        Returns elements that were provided to the TransformEvaluator as input but were not processed.
      • getCounters

        public abstract getCounters()
        Returns the CounterSet used by this PTransform, or null if this transform did not use a CounterSet.
      • getWatermarkHold

        public abstract Instant getWatermarkHold()
        Returns the Watermark Hold for the transform at the time this result was produced.

        If the transform does not set any watermark hold, returns BoundedWindow.TIMESTAMP_MAX_VALUE.

      • getState

        public abstract<?> getState()
        Returns the State used by the transform.

        If this evaluation did not access state, this may return null.

      • getTimerUpdate

        public abstract InMemoryWatermarkManager.TimerUpdate getTimerUpdate()
        Returns a TimerUpdateBuilder that was produced as a result of this evaluation. If the evaluation was triggered due to the delivery of one or more timers, those timers must be added to the builder before it is complete.

        If this evaluation did not add or remove any timers, returns an empty TimerUpdate.

      • getOutputTypes

        public abstract Set<> getOutputTypes()
        Returns the types of output produced by this PTransform. This may not include CommittedResult.OutputType.BUNDLE, as empty bundles may be dropped when the transform is committed.