org.apache.beam.runners.spark.structuredstreaming

Class SparkStructuredStreamingRunnerRegistrar

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.SparkStructuredStreamingRunnerRegistrar

public final class SparkStructuredStreamingRunnerRegistrar
extends java.lang.Object

Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the SparkStructuredStreamingRunner.

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	SparkStructuredStreamingRunnerRegistrar.Options Registers the SparkStructuredStreamingPipelineOptions.
static class	SparkStructuredStreamingRunnerRegistrar.Runner Registers the SparkStructuredStreamingRunner.

Method Summary

Methods inherited from class java.lang.Object

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