Package org.apache.flink.cdc.connectors.oceanbase.sink

Class OceanBaseEventSerializationSchema

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema

All Implemented Interfaces:

com.oceanbase.connector.flink.table.RecordSerializationSchema<Event>, Serializable

public class OceanBaseEventSerializationSchema
extends Object
implements com.oceanbase.connector.flink.table.RecordSerializationSchema<Event>

A serializer for Event to Record.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
java.time.ZoneId	pipelineZoneId	ZoneId from pipeline config to support timestamp with local time zone.

Constructor Summary

Constructors

Constructor	Description
OceanBaseEventSerializationSchema(java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
com.oceanbase.connector.flink.table.Record	serialize(Event event)
Object[]	serializerRecord(RecordData recordData, Schema schema)	serializer RecordData to oceanbase data change record.

Methods inherited from class java.lang.Object

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

Field Detail

pipelineZoneId

public final java.time.ZoneId pipelineZoneId

ZoneId from pipeline config to support timestamp with local time zone.

Constructor Detail

OceanBaseEventSerializationSchema

public OceanBaseEventSerializationSchema(java.time.ZoneId zoneId)

Method Detail

serialize

public com.oceanbase.connector.flink.table.Record serialize(Event event)

Specified by:

serialize in interface com.oceanbase.connector.flink.table.RecordSerializationSchema<Event>

serializerRecord

public Object[] serializerRecord(RecordData recordData,
                                 Schema schema)

serializer RecordData to oceanbase data change record.