org.apache.beam.runners.prism

Class PrismRunner

java.lang.Object

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

org.apache.beam.runners.prism.PrismRunner

public class PrismRunner
extends PipelineRunner<PipelineResult>

A PipelineRunner executed on Prism. Downloads, prepares, and executes the Prism service on behalf of the developer when PipelineRunner.run(org.apache.beam.sdk.Pipeline)ning the pipeline. If users want to submit to an already running Prism service, use the PortableRunner with the PortablePipelineOptions.getJobEndpoint() option instead. Prism is a PortableRunner maintained at sdks/go/cmd/prism. For testing, use TestPrismRunner.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PrismRunner(PrismPipelineOptions prismPipelineOptions)

Method Summary

Modifier and Type	Method and Description
static PrismRunner	fromOptions(PipelineOptions options) Invoked from Pipeline.run() where PrismRunner instantiates using PrismPipelineOptions configuration details.
PipelineResult	run(Pipeline pipeline) Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

Methods inherited from class org.apache.beam.sdk.PipelineRunner

create, run, run

Methods inherited from class java.lang.Object

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

Constructor Detail

PrismRunner

protected PrismRunner(PrismPipelineOptions prismPipelineOptions)

Method Detail

fromOptions

public static PrismRunner fromOptions(PipelineOptions options)

Invoked from Pipeline.run() where PrismRunner instantiates using PrismPipelineOptions configuration details.

run

public PipelineResult run(Pipeline pipeline)

Description copied from class: PipelineRunner

Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

Specified by:

run in class PipelineRunner<PipelineResult>