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.

Method Summary

Modifier and Type	Method and Description
void	execute()
static ReferenceRunner	forPipeline(org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline p, com.google.protobuf.Struct options, java.io.File artifactsDir)

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,
                                          com.google.protobuf.Struct options,
                                          java.io.File artifactsDir)

execute

public void execute()
             throws java.lang.Exception

Throws:

java.lang.Exception