StepTransformResult (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.runners.inprocess

Class StepTransformResult

  • java.lang.Object
    • com.google.cloud.dataflow.sdk.runners.inprocess.StepTransformResult


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

      • StepTransformResult

        public StepTransformResult()
    • Method Detail

      • getUnprocessedElements

        public abstract Iterable<? extends com.google.cloud.dataflow.sdk.util.WindowedValue<?>> getUnprocessedElements()
        Returns elements that were provided to the TransformEvaluator as input but were not processed.
      • getCounters

        @Nullable
        public abstract com.google.cloud.dataflow.sdk.util.common.CounterSet 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

        @Nullable
        public abstract com.google.cloud.dataflow.sdk.util.state.CopyOnAccessInMemoryStateInternals<?> 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<com.google.cloud.dataflow.sdk.runners.inprocess.CommittedResult.OutputType> 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.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow