Package 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 Coder
s.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription<T> Coder
<T> coderFor
(TypeDescriptor<T> typeDescriptor, List<? extends Coder<?>> componentCoders) Returns theCoder
returned according to theCoderProvider
from anyDefaultCoder
annotation on the given class.
-
Constructor Details
-
DefaultCoderProvider
public DefaultCoderProvider()
-
-
Method Details
-
coderFor
public <T> Coder<T> coderFor(TypeDescriptor<T> typeDescriptor, List<? extends Coder<?>> componentCoders) throws CannotProvideCoderException Returns theCoder
returned according to theCoderProvider
from anyDefaultCoder
annotation on the given class.- Specified by:
coderFor
in classCoderProvider
- Throws:
CannotProvideCoderException
-