Class NemoPipelineResult

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

    public final class NemoPipelineResult
    extends ClientEndpoint
    implements org.apache.beam.sdk.PipelineResult
    Beam result.
    • Constructor Detail

      • NemoPipelineResult

        public NemoPipelineResult()
        Default constructor.
    • Method Detail

      • 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 IOException
        Specified by:
        cancel in interface org.apache.beam.sdk.PipelineResult
        Throws:
        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