org.apache.beam.runners.spark

Class SparkRunnerRegistrar

java.lang.Object

org.apache.beam.runners.spark.SparkRunnerRegistrar

public final class SparkRunnerRegistrar
extends java.lang.Object

Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the SparkRunner.

AutoService will register Spark's implementations of the PipelineRunner and PipelineOptions as available pipeline runner services.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkRunnerRegistrar.Options Registers the SparkPipelineOptions.
static class	SparkRunnerRegistrar.Runner Registers the SparkRunner.

Method Summary

Methods inherited from class java.lang.Object

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