程序包 org.apache.flink.cdc.connectors.oceanbase.sink

类 OceanBaseEventSerializationSchema

java.lang.Object

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

所有已实现的接口:

com.oceanbase.connector.flink.table.RecordSerializationSchema<org.apache.flink.cdc.common.event.Event>, Serializable

public class OceanBaseEventSerializationSchema
extends Object
implements com.oceanbase.connector.flink.table.RecordSerializationSchema<org.apache.flink.cdc.common.event.Event>

A serializer for Event to Record.

另请参阅:

序列化表格

字段概要

字段

修饰符和类型	字段	说明
java.time.ZoneId	pipelineZoneId	ZoneId from pipeline config to support timestamp with local time zone.

构造器概要

构造器

构造器	说明
OceanBaseEventSerializationSchema(java.time.ZoneId zoneId)

方法概要

修饰符和类型	方法	说明
com.oceanbase.connector.flink.table.Record	serialize(org.apache.flink.cdc.common.event.Event event)
Object[]	serializerRecord(org.apache.flink.cdc.common.data.RecordData recordData, org.apache.flink.cdc.common.schema.Schema schema)	serializer RecordData to oceanbase data change record.

从类继承的方法 java.lang.Object

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

字段详细资料

pipelineZoneId

public final java.time.ZoneId pipelineZoneId

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

构造器详细资料

OceanBaseEventSerializationSchema

public OceanBaseEventSerializationSchema(java.time.ZoneId zoneId)

方法详细资料

serialize

public com.oceanbase.connector.flink.table.Record serialize(org.apache.flink.cdc.common.event.Event event)

指定者:

serialize 在接口中 com.oceanbase.connector.flink.table.RecordSerializationSchema<org.apache.flink.cdc.common.event.Event>

serializerRecord

public Object[] serializerRecord(org.apache.flink.cdc.common.data.RecordData recordData,
                                 org.apache.flink.cdc.common.schema.Schema schema)

serializer RecordData to oceanbase data change record.