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

Interface EncoderProvider.Factory<T>

All Superinterfaces:

Function<org.apache.beam.sdk.coders.Coder<T>,org.apache.spark.sql.Encoder<T>>

Enclosing interface:

EncoderProvider

public static interface EncoderProvider.Factory<T>
extends Function<org.apache.beam.sdk.coders.Coder<T>,org.apache.spark.sql.Encoder<T>>

Field Summary

Fields

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

Method Summary

Methods inherited from interface java.util.function.Function

andThen, apply, compose

Field Details

INSTANCE

static final EncoderProvider.Factory<?> INSTANCE