Package org.apache.beam.runners.spark.structuredstreaming

Class SparkStructuredStreamingPipelineResult

java.lang.Object
org.apache.beam.runners.spark.structuredstreaming.SparkStructuredStreamingPipelineResult
All Implemented Interfaces:
org.apache.beam.sdk.PipelineResult
public class SparkStructuredStreamingPipelineResult extends Object implements org.apache.beam.sdk.PipelineResult

  • 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
    org.apache.beam.sdk.PipelineResult.State
    cancel()
     
    org.apache.beam.sdk.PipelineResult.State
    getState()
     
    org.apache.beam.sdk.metrics.MetricResults
    metrics()
     
    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

    • 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