org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class EncoderHelpers

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers

public class EncoderHelpers
extends java.lang.Object

Encoders utility class.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EncoderHelpers.DecodeUsingBeamCoder<T> Catalyst Expression that deserializes elements using Beam Coder.
static class	EncoderHelpers.EncodeUsingBeamCoder<T> Catalyst Expression that serializes elements using Beam Coder.

Constructor Summary

Constructors

Constructor and Description
EncoderHelpers()

Method Summary

Modifier and Type	Method and Description
static <T> org.apache.spark.sql.Encoder<T>	fromBeamCoder(Coder<T> coder) Wrap a Beam coder into a Spark Encoder using Catalyst Expression Encoders (which uses java code generation).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EncoderHelpers

public EncoderHelpers()

Method Detail

fromBeamCoder

public static <T> org.apache.spark.sql.Encoder<T> fromBeamCoder(Coder<T> coder)

Wrap a Beam coder into a Spark Encoder using Catalyst Expression Encoders (which uses java code generation).