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

Interface PayloadSerializerProvider

All Superinterfaces:

Providers.Identifyable

All Known Implementing Classes:

AvroPayloadSerializerProvider, JsonPayloadSerializerProvider, ProtoPayloadSerializerProvider, ThriftPayloadSerializerProvider

@Internal
 @Experimental(value=SCHEMAS)
public interface PayloadSerializerProvider
extends Providers.Identifyable

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.

Methods inherited from interface org.apache.beam.sdk.schemas.io.Providers.Identifyable

identifier

Method Detail

getSerializer

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

Get a PayloadSerializer.

Parameters:

schema - the schema of the payload

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