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

Interface EncoderProvider

All Known Subinterfaces:

PipelineTranslator.TranslationState

All Known Implementing Classes:

TransformTranslator.Context

@Internal
public interface EncoderProvider

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	EncoderProvider.Factory<T>

Method Summary

Modifier and Type	Method and Description
default <T> EncoderProvider.Factory<T>	encoderFactory()
default <T> org.apache.spark.sql.Encoder<T>	encoderOf(Coder<T> coder)
<T> org.apache.spark.sql.Encoder<T>	encoderOf(Coder<T> coder, EncoderProvider.Factory<T> factory)
default <K,V> org.apache.spark.sql.Encoder<K>	keyEncoderOf(KvCoder<K,V> coder)
default <K,V> org.apache.spark.sql.Encoder<KV<K,V>>	kvEncoderOf(KvCoder<K,V> coder)
default <K,V> org.apache.spark.sql.Encoder<V>	valueEncoderOf(KvCoder<K,V> coder)

Method Detail

encoderOf

<T> org.apache.spark.sql.Encoder<T> encoderOf(Coder<T> coder,
                                              EncoderProvider.Factory<T> factory)

encoderOf

default <T> org.apache.spark.sql.Encoder<T> encoderOf(Coder<T> coder)

kvEncoderOf

default <K,V> org.apache.spark.sql.Encoder<KV<K,V>> kvEncoderOf(KvCoder<K,V> coder)

keyEncoderOf

default <K,V> org.apache.spark.sql.Encoder<K> keyEncoderOf(KvCoder<K,V> coder)

valueEncoderOf

default <K,V> org.apache.spark.sql.Encoder<V> valueEncoderOf(KvCoder<K,V> coder)

encoderFactory

default <T> EncoderProvider.Factory<T> encoderFactory()