Class NemoPipelineResult

  • All Implemented Interfaces:
    org.apache.beam.sdk.PipelineResult

    public final class NemoPipelineResult
    extends ClientEndpoint
    implements org.apache.beam.sdk.PipelineResult
    Beam result.
    • Nested Class Summary

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

        org.apache.beam.sdk.PipelineResult.State
    • Constructor Summary

      Constructors 
      Constructor Description
      NemoPipelineResult()
      Default constructor.
    • Constructor Detail

      • NemoPipelineResult

        public NemoPipelineResult()
        Default constructor.
    • Method Detail

      • setJobDone

        public void setJobDone()
        Signal that the job is finished to the NemoPipelineResult object.
      • getState

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

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

        public org.apache.beam.sdk.PipelineResult.State waitUntilFinish​(org.joda.time.Duration duration)
        Specified by:
        waitUntilFinish 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
      • metrics

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