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

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

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.io	Spark-specific transforms for I/O.
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.

Class	Description
WordCount	Duplicated from beam-examples-java to avoid dependency.
WordCount.CountWords	A PTransform that converts a PCollection containing lines of text into a PCollection of formatted word counts.
WordCount.FormatAsTextFn	A SimpleFunction that converts a Word and Count into a printable string.
WordCount.WordCountOptions	Options supported by WordCount.