org.apache.paimon.flink.kafka

Class KafkaLogSerializationSchema

java.lang.Object

org.apache.paimon.flink.kafka.KafkaLogSerializationSchema

All Implemented Interfaces:

Serializable, org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>

public class KafkaLogSerializationSchema
extends Object
implements org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>

A KafkaRecordSerializationSchema for the table in log store.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaLogSerializationSchema(String topic, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer, CoreOptions.LogChangelogMode changelogMode)

Method Summary

Modifier and Type	Method and Description
void	open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	serialize(SinkRecord element, Long timestamp)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaLogSerializationSchema

public KafkaLogSerializationSchema(String topic,
                                   @Nullable
                                   org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> primaryKeySerializer,
                                   org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> valueSerializer,
                                   CoreOptions.LogChangelogMode changelogMode)

Method Detail

open

public void open(org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context)
          throws Exception

Specified by:

open in interface org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>

Throws:

Exception

serialize

public org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> serialize(SinkRecord element,
                                                                                 @Nullable
                                                                                 Long timestamp)

Specified by:

serialize in interface org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord>