org.apache.beam.runners.reference

Class ReferenceRunner

java.lang.Object

org.apache.beam.runners.reference.ReferenceRunner

public class ReferenceRunner
extends java.lang.Object

A PipelineRunner that executes a job via the Beam portability framework.

Constructor Summary

Constructors

Constructor and Description
ReferenceRunner()

Method Summary

Modifier and Type	Method and Description
static void	run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p, com.google.protobuf.Struct options, java.nio.file.Path stagingLocation)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReferenceRunner

public ReferenceRunner()

Method Detail

run

public static void run(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p,
                       com.google.protobuf.Struct options,
                       java.nio.file.Path stagingLocation)
                throws java.lang.Exception

Throws:

java.lang.Exception