org.apache.beam.runners.direct.portable

Class ReferenceRunner

java.lang.Object

org.apache.beam.runners.direct.portable.ReferenceRunner

public class ReferenceRunner
extends java.lang.Object

The "ReferenceRunner" engine implementation. The ReferenceRunner uses the portability framework to execute a Pipeline on a single machine.

Method Summary

Modifier and Type	Method and Description
void	execute() First starts all the services needed, then configures and starts the ExecutorServiceParallelExecutor.
static ReferenceRunner	forPipeline(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p, org.apache.beam.vendor.grpc.v1p13p1.com.google.protobuf.Struct options, java.lang.String artifactRetrievalToken) Creates a "ReferenceRunner" engine for a single pipeline with a Dockerized SDK harness.

Methods inherited from class java.lang.Object

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

Method Detail

forPipeline

public static ReferenceRunner forPipeline(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p,
                                          org.apache.beam.vendor.grpc.v1p13p1.com.google.protobuf.Struct options,
                                          java.lang.String artifactRetrievalToken)

Creates a "ReferenceRunner" engine for a single pipeline with a Dockerized SDK harness.

Parameters:

p - Pipeline being executed for this job.

options - PipelineOptions for this job.

artifactRetrievalToken - Token to retrieve artifacts that have been staged.

execute

public void execute()
             throws java.lang.Exception

First starts all the services needed, then configures and starts the ExecutorServiceParallelExecutor.

Throws:

java.lang.Exception