Package org.apache.beam.sdk.io.gcp.pubsub

Class PubsubCoderProviderRegistrar

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubCoderProviderRegistrar

All Implemented Interfaces:

CoderProviderRegistrar

@AutoService(CoderProviderRegistrar.class)
public class PubsubCoderProviderRegistrar
extends Object
implements CoderProviderRegistrar

A CoderProviderRegistrar for standard types used with PubsubIO.

Constructor Summary

Constructors

Constructor	Description
PubsubCoderProviderRegistrar()

Method Summary

Modifier and Type	Method	Description
List<CoderProvider>	getCoderProviders()	Returns a list of coder providers which will be registered by default within each coder registry instance.

Methods inherited from class java.lang.Object

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

Constructor Details

PubsubCoderProviderRegistrar

public PubsubCoderProviderRegistrar()

Method Details

getCoderProviders

public List<CoderProvider> getCoderProviders()

Description copied from interface: CoderProviderRegistrar

Returns a list of coder providers which will be registered by default within each coder registry instance.

See CoderProviders for convenience methods to construct a CoderProvider.

Specified by:

getCoderProviders in interface CoderProviderRegistrar