Interface PayloadSerializerProvider
-
- All Superinterfaces:
Providers.Identifyable
- All Known Implementing Classes:
AvroPayloadSerializerProvider
,JsonPayloadSerializerProvider
@Internal @Experimental(SCHEMAS) public interface PayloadSerializerProvider extends Providers.Identifyable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 payloadtableParams
- parameters passed at table declaration time for configuring the serializer
-
-