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 java.lang.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 and Description
CoderProvider()

Method Summary

Modifier and Type	Method and Description
abstract <T> Coder<T>	coderFor(TypeDescriptor<T> typeDescriptor, java.util.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 Detail

CoderProvider

public CoderProvider()

Method Detail

coderFor

public abstract <T> Coder<T> coderFor(TypeDescriptor<T> typeDescriptor,
                                      java.util.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