Package org.apache.beam.runners.spark.coders

package org.apache.beam.runners.spark.coders

Beam coders and coder-related utilities for running on Apache Spark.

Related Packages

Package	Description
org.apache.beam.runners.spark	Internal implementation of the Beam runner for Apache Spark.

Classes

Class	Description
CoderHelpers	Serialization utility class.
CoderHelpers.FromByteFunction<K,V>	A function for converting a byte array pair to a key-value pair.
SparkRunnerKryoRegistrator	Custom KryoRegistrators for Beam's Spark runner needs and registering used class in spark translation for better serialization performance.