Package org.apache.beam.runners.spark

Class SparkPipelineResult

java.lang.Object
org.apache.beam.runners.spark.SparkPipelineResult
All Implemented Interfaces:
org.apache.beam.sdk.PipelineResult
Direct Known Subclasses:
SparkRunnerDebugger.DebugSparkPipelineResult
public abstract class SparkPipelineResult extends Object implements org.apache.beam.sdk.PipelineResult
Represents a Spark pipeline execution result.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.beam.sdk.PipelineResult

    org.apache.beam.sdk.PipelineResult.State

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract org.apache.beam.sdk.PipelineResult.State
    awaitTermination(org.joda.time.Duration duration)
     
    org.apache.beam.sdk.PipelineResult.State
    cancel()
     
    org.apache.beam.sdk.PipelineResult.State
    getState()
     
    org.apache.beam.sdk.metrics.MetricResults
    metrics()
     
    protected abstract void
    stop()
     
    org.apache.beam.sdk.PipelineResult.State
    waitUntilFinish()
     
    org.apache.beam.sdk.PipelineResult.State
    waitUntilFinish(org.joda.time.Duration duration)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • stop

      protected abstract void stop()

    • awaitTermination

      protected abstract org.apache.beam.sdk.PipelineResult.State awaitTermination(org.joda.time.Duration duration) throws TimeoutException, ExecutionException, InterruptedException
      Throws:
      TimeoutException
      ExecutionException
      InterruptedException

    • getState

      public org.apache.beam.sdk.PipelineResult.State getState()
      Specified by:
      getState in interface org.apache.beam.sdk.PipelineResult

    • waitUntilFinish

      public org.apache.beam.sdk.PipelineResult.State waitUntilFinish()
      Specified by:
      waitUntilFinish in interface org.apache.beam.sdk.PipelineResult

    • waitUntilFinish

      public org.apache.beam.sdk.PipelineResult.State waitUntilFinish(org.joda.time.Duration duration)
      Specified by:
      waitUntilFinish in interface org.apache.beam.sdk.PipelineResult

    • metrics

      public org.apache.beam.sdk.metrics.MetricResults metrics()
      Specified by:
      metrics in interface org.apache.beam.sdk.PipelineResult

    • cancel

      public org.apache.beam.sdk.PipelineResult.State cancel() throws IOException
      Specified by:
      cancel in interface org.apache.beam.sdk.PipelineResult
      Throws:
      IOException