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

package org.apache.beam.runners.spark.structuredstreaming.io

Spark-specific transforms for I/O.

Related Packages

Package	Description
org.apache.beam.runners.spark.structuredstreaming	Internal implementation of the Beam runner for Apache Spark.
org.apache.beam.runners.spark.structuredstreaming.examples
org.apache.beam.runners.spark.structuredstreaming.metrics	Provides internal utilities for implementing Beam metrics using Spark accumulators.
org.apache.beam.runners.spark.structuredstreaming.translation	Internal translators for running Beam pipelines on Spark.

Classes

Class	Description
BoundedDatasetFactory