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

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).