edu.snu.coral.compiler.frontend.beam

Class CoralPipelineRunner

java.lang.Object

org.apache.beam.sdk.PipelineRunner<CoralPipelineResult>

edu.snu.coral.compiler.frontend.beam.CoralPipelineRunner

public final class CoralPipelineRunner
extends org.apache.beam.sdk.PipelineRunner<CoralPipelineResult>

Runner class for BEAM programs.

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.sdk.PipelineRunner<CoralPipelineResult>	fromOptions(org.apache.beam.sdk.options.PipelineOptions options) Static initializer for creating PipelineRunner with the given options.
CoralPipelineResult	run(org.apache.beam.sdk.Pipeline pipeline) Method to run the Pipeline.

Methods inherited from class java.lang.Object

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

Method Detail

fromOptions

public static org.apache.beam.sdk.PipelineRunner<CoralPipelineResult> fromOptions(org.apache.beam.sdk.options.PipelineOptions options)

Static initializer for creating PipelineRunner with the given options.

Parameters:

options - given PipelineOptions.

Returns:

The created PipelineRunner.

run

public CoralPipelineResult run(org.apache.beam.sdk.Pipeline pipeline)

Method to run the Pipeline.

Specified by:

run in class org.apache.beam.sdk.PipelineRunner<CoralPipelineResult>

Parameters:

pipeline - the Pipeline to run.

Returns:

The result of the pipeline.