Package org.apache.beam.sdk.coders

Class CoderProvider

java.lang.Object

org.apache.beam.sdk.coders.CoderProvider

Direct Known Subclasses:

DefaultCoder.DefaultCoderProviderRegistrar.DefaultCoderProvider

public abstract class CoderProvider
extends Object

A CoderProvider provides Coders.

It may operate on a parameterized type, such as List, in which case the coderFor(org.apache.beam.sdk.values.TypeDescriptor<T>, java.util.List<? extends org.apache.beam.sdk.coders.Coder<?>>) method accepts a list of coders to use for the type parameters.

Constructor Summary

Constructors

Constructor	Description
CoderProvider()

Method Summary

Modifier and Type	Method	Description
abstract <T> Coder<T>	coderFor(TypeDescriptor<T> typeDescriptor, List<? extends Coder<?>> componentCoders)	Returns a Coder<T> to use for values of a particular type, given the Coders for each of the type's generic parameter types.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CoderProvider

public CoderProvider()

Method Details

coderFor

public abstract <T> Coder<T> coderFor(TypeDescriptor<T> typeDescriptor,
 List<? extends Coder<?>> componentCoders)
                               throws CannotProvideCoderException

Returns a Coder<T> to use for values of a particular type, given the Coders for each of the type's generic parameter types.

Throws CannotProvideCoderException if this CoderProvider cannot provide a coder for this type and components.

Throws:

CannotProvideCoderException