Package 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
    Description
    static interface 
    EncoderProvider.Factory<T>
     

  • Method Summary

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

  • Method Details

    • encoderOf

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

    • encoderOf

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

    • kvEncoderOf

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

    • keyEncoderOf

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

    • valueEncoderOf

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

    • encoderFactory

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