See: Description
| Interface | Description |
|---|---|
| SparkContextOptions |
A custom
PipelineOptions to work with properties related to JavaSparkContext. |
| SparkPipelineOptions |
Spark runner
PipelineOptions handles Spark execution-related configurations, such as the
master address, batch-interval, and other user-related knobs. |
| TestSparkPipelineOptions |
A
SparkPipelineOptions for tests. |
| Class | Description |
|---|---|
| SparkContextOptions.EmptyListenersList |
Returns an empty list, to avoid handling null.
|
| SparkNativePipelineVisitor |
Pipeline visitor for translating a Beam pipeline into equivalent Spark operations.
|
| SparkPipelineOptions.TmpCheckpointDirFactory |
Returns the default checkpoint directory of /tmp/${job.name}.
|
| SparkPipelineResult |
Represents a Spark pipeline execution result.
|
| SparkRunner |
The SparkRunner translate operations defined on a pipeline to a representation executable by
Spark, and then submitting the job to Spark to be executed.
|
| SparkRunner.Evaluator |
Evaluator on the pipeline.
|
| SparkRunnerDebugger |
Pipeline runner which translates a Beam pipeline into equivalent Spark operations, without
running them.
|
| SparkRunnerDebugger.DebugSparkPipelineResult |
PipelineResult of running a
Pipeline using SparkRunnerDebugger Use SparkRunnerDebugger.DebugSparkPipelineResult.getDebugString() to get a String representation of the Pipeline translated into
Spark native operations. |
| SparkRunnerRegistrar | |
| SparkRunnerRegistrar.Options |
Registers the
SparkPipelineOptions. |
| SparkRunnerRegistrar.Runner |
Registers the
SparkRunner. |
| SparkTransformOverrides |
PTransform overrides for Flink runner. |
| TestSparkPipelineOptions.DefaultStopPipelineWatermarkFactory |
A factory to provide the default watermark to stop a pipeline that reads from an unbounded
source.
|
| TestSparkRunner |
The SparkRunner translate operations defined on a pipeline to a representation executable by
Spark, and then submitting the job to Spark to be executed.
|