NemoPipelineResult (Nemo Project 0.4 API)

java.lang.Object
- org.apache.nemo.client.ClientEndpoint
- - org.apache.nemo.client.beam.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.

Method Summary

All Methods Instance Methods Concrete Methods
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()`
`void`	`setJobDone()`	Signal that the job is finished to the NemoPipelineResult object.
`org.apache.beam.sdk.PipelineResult.State`	`waitUntilFinish()`
`org.apache.beam.sdk.PipelineResult.State`	`waitUntilFinish(org.joda.time.Duration duration)`

Methods inherited from class org.apache.nemo.client.ClientEndpoint
getPlanState, waitUntilJobFinish, waitUntilJobFinish

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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