Class JsonPayloadSerializerProvider
- java.lang.Object
-
- org.apache.beam.sdk.schemas.io.payloads.JsonPayloadSerializerProvider
-
- All Implemented Interfaces:
PayloadSerializerProvider
,Providers.Identifyable
@Internal @Experimental(SCHEMAS) @AutoService(PayloadSerializerProvider.class) public class JsonPayloadSerializerProvider extends java.lang.Object implements PayloadSerializerProvider
-
-
Constructor Summary
Constructors Constructor Description JsonPayloadSerializerProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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 interfaceProviders.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 interfacePayloadSerializerProvider
- Parameters:
schema
- the schema of the payloadtableParams
- parameters passed at table declaration time for configuring the serializer
-
-