Package org.apache.beam.runners.spark.structuredstreaming

Internal implementation of the Beam runner for Apache Spark.

See: Description

Interface Summary

Interface	Description
SparkStructuredStreamingPipelineOptions	Spark runner PipelineOptions handles Spark execution-related configurations, such as the master address, and other user-related knobs.

Class Summary

Class	Description
SparkStructuredStreamingPipelineResult	Represents a Spark pipeline execution result.
SparkStructuredStreamingRunner	SparkStructuredStreamingRunner is based on spark structured streaming framework and is no more based on RDD/DStream API.

Package org.apache.beam.runners.spark.structuredstreaming Description

Internal implementation of the Beam runner for Apache Spark.