java.lang.Object
- org.apache.flink.cdc.debezium.event.SourceRecordEventDeserializer

All Implemented Interfaces:

Serializable, EventDeserializer<org.apache.kafka.connect.source.SourceRecord>

Direct Known Subclasses:

DebeziumEventDeserializationSchema
```
@Internal
public abstract class SourceRecordEventDeserializer
extends Object
implements EventDeserializer<org.apache.kafka.connect.source.SourceRecord>
```
Deserializer to deserialize SourceRecord to Event.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

SourceRecordEventDeserializer()

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`List<? extends Event>`	`deserialize(org.apache.kafka.connect.source.SourceRecord record)`	Deserialize given record to `Event`s.
`protected abstract List<DataChangeEvent>`	`deserializeDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)`	Deserialize given data change record to `DataChangeEvent`.
`protected abstract List<SchemaChangeEvent>`	`deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)`	Deserialize given schema change record to `SchemaChangeEvent`.
`static org.apache.kafka.connect.data.Schema`	`fieldSchema(org.apache.kafka.connect.data.Schema schema, String fieldName)`
`static org.apache.kafka.connect.data.Struct`	`fieldStruct(org.apache.kafka.connect.data.Struct value, String fieldName)`
`protected abstract Map<String,String>`	`getMetadata(org.apache.kafka.connect.source.SourceRecord record)`	Get metadata from data change record.
`protected abstract TableId`	`getTableId(org.apache.kafka.connect.source.SourceRecord record)`	Get `TableId` from data change record.
`protected abstract boolean`	`isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)`	Whether the given record is a data change record.
`protected abstract boolean`	`isSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)`	Whether the given record is a schema change record.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- SourceRecordEventDeserializer
```
public SourceRecordEventDeserializer()
```

Method Detail

deserialize
```
public List<? extends Event> deserialize(org.apache.kafka.connect.source.SourceRecord record)
                                  throws Exception
```
Description copied from interface: EventDeserializer

Deserialize given record to Events.

Specified by:

deserialize in interface EventDeserializer<org.apache.kafka.connect.source.SourceRecord>

Throws:

Exception

isDataChangeRecord

protected abstract boolean isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Whether the given record is a data change record.

isSchemaChangeRecord

protected abstract boolean isSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Whether the given record is a schema change record.

deserializeDataChangeRecord

protected abstract List<DataChangeEvent> deserializeDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)
                                                              throws Exception

Deserialize given data change record to DataChangeEvent.

Throws:: Exception

deserializeSchemaChangeRecord

protected abstract List<SchemaChangeEvent> deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)
                                                                  throws Exception

Deserialize given schema change record to SchemaChangeEvent.

Throws:: Exception

getTableId

protected abstract TableId getTableId(org.apache.kafka.connect.source.SourceRecord record)

Get TableId from data change record.

getMetadata

protected abstract Map<String,String> getMetadata(org.apache.kafka.connect.source.SourceRecord record)

Get metadata from data change record.

fieldSchema

public static org.apache.kafka.connect.data.Schema fieldSchema(org.apache.kafka.connect.data.Schema schema,
                                                               String fieldName)

fieldStruct

public static org.apache.kafka.connect.data.Struct fieldStruct(org.apache.kafka.connect.data.Struct value,
                                                               String fieldName)

Class SourceRecordEventDeserializer

Constructor Summary