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

Interface PayloadSerializerProvider

All Superinterfaces:

Providers.Identifyable

All Known Implementing Classes:

AvroPayloadSerializerProvider, JsonPayloadSerializerProvider, ProtoPayloadSerializerProvider, ThriftPayloadSerializerProvider

@Internal
public interface PayloadSerializerProvider
extends Providers.Identifyable

Method Summary

Modifier and Type	Method	Description
PayloadSerializer	getSerializer(Schema schema, Map<String,Object> tableParams)	Get a PayloadSerializer.

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

identifier

Method Details

getSerializer

PayloadSerializer getSerializer(Schema schema,
 Map<String,Object> tableParams)

Get a PayloadSerializer.

Parameters:

schema - the schema of the payload

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