org.apache.beam.sdk.coders

Class DefaultCoder.DefaultCoderProviderRegistrar.DefaultCoderProvider

java.lang.Object

org.apache.beam.sdk.coders.CoderProvider

org.apache.beam.sdk.coders.DefaultCoder.DefaultCoderProviderRegistrar.DefaultCoderProvider

Enclosing class:

DefaultCoder.DefaultCoderProviderRegistrar

public static class DefaultCoder.DefaultCoderProviderRegistrar.DefaultCoderProvider
extends CoderProvider

A CoderProvider that uses the @DefaultCoder annotation to provide coder providers that create Coders.

Constructor Summary

Constructors

Constructor and Description
DefaultCoderProvider()

Method Summary

Modifier and Type	Method and Description
<T> Coder<T>	coderFor(TypeDescriptor<T> typeDescriptor, java.util.List<? extends Coder<?>> componentCoders) Returns the Coder returned according to the CoderProvider from any DefaultCoder annotation on the given class.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCoderProvider

public DefaultCoderProvider()

Method Detail

coderFor

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

Returns the Coder returned according to the CoderProvider from any DefaultCoder annotation on the given class.

Specified by:

coderFor in class CoderProvider

Throws:

CannotProvideCoderException