org.apache.beam.sdk.schemas.io.payloads

Class AvroPayloadSerializerProvider

java.lang.Object

org.apache.beam.sdk.schemas.io.payloads.AvroPayloadSerializerProvider

All Implemented Interfaces:

PayloadSerializerProvider, Providers.Identifyable

@Internal
 @Experimental(value=SCHEMAS)
 @AutoService(value=PayloadSerializerProvider.class)
public class AvroPayloadSerializerProvider
extends java.lang.Object
implements PayloadSerializerProvider

Constructor Summary

Constructors

Constructor and Description
AvroPayloadSerializerProvider()

Method Summary

Modifier and Type	Method and Description
PayloadSerializer	getSerializer(Schema schema, java.util.Map<java.lang.String,java.lang.Object> tableParams) Get a PayloadSerializer.
java.lang.String	identifier() Returns an id that uniquely represents this among others implementing its derived interface.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroPayloadSerializerProvider

public AvroPayloadSerializerProvider()

Method Detail

identifier

public java.lang.String identifier()

Description copied from interface: Providers.Identifyable

Returns an id that uniquely represents this among others implementing its derived interface.

Specified by:

identifier in interface Providers.Identifyable

getSerializer

public PayloadSerializer getSerializer(Schema schema,
                                       java.util.Map<java.lang.String,java.lang.Object> tableParams)

Description copied from interface: PayloadSerializerProvider

Get a PayloadSerializer.

Specified by:

getSerializer in interface PayloadSerializerProvider

Parameters:

schema - the schema of the payload

tableParams - parameters passed at table declaration time for configuring the serializer