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

Interface EncoderProvider.Factory<T>

All Superinterfaces:

java.util.function.Function<Coder<T>,org.apache.spark.sql.Encoder<T>>

Enclosing interface:

EncoderProvider

public static interface EncoderProvider.Factory<T>
extends java.util.function.Function<Coder<T>,org.apache.spark.sql.Encoder<T>>

Field Summary

Fields

Modifier and Type	Field and Description
static EncoderProvider.Factory<?>	INSTANCE

Method Summary

Methods inherited from interface java.util.function.Function

andThen, apply, compose, identity

Field Detail

INSTANCE

static final EncoderProvider.Factory<?> INSTANCE