Uses of Class
org.apache.paimon.table.sink.SinkRecord

Packages that use SinkRecord

Package	Description
org.apache.paimon.flink.kafka
org.apache.paimon.flink.sink
org.apache.paimon.table.sink

Uses of SinkRecord in org.apache.paimon.flink.kafka

Methods in org.apache.paimon.flink.kafka with parameters of type SinkRecord

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	KafkaLogSerializationSchema.serialize(SinkRecord element, Long timestamp)

Constructor parameters in org.apache.paimon.flink.kafka with type arguments of type SinkRecord

Constructor and Description
KafkaSinkFunction(String defaultTopic, org.apache.flink.streaming.connectors.kafka.KafkaSerializationSchema<SinkRecord> serializationSchema, Properties producerConfig, org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.Semantic semantic) Creates a KafkaSinkFunction for a given topic.

Uses of SinkRecord in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return SinkRecord

Modifier and Type	Method and Description
SinkRecord	StoreSinkWrite.toLogRecord(SinkRecord record)
SinkRecord	StoreSinkWriteImpl.toLogRecord(SinkRecord record)
SinkRecord	StoreSinkWrite.write(InternalRow rowData)
SinkRecord	GlobalFullCompactionSinkWrite.write(InternalRow rowData)
SinkRecord	StoreSinkWriteImpl.write(InternalRow rowData)
SinkRecord	StoreSinkWrite.write(InternalRow rowData, int bucket)
SinkRecord	GlobalFullCompactionSinkWrite.write(InternalRow rowData, int bucket)
SinkRecord	StoreSinkWriteImpl.write(InternalRow rowData, int bucket)

Methods in org.apache.paimon.flink.sink with parameters of type SinkRecord

Modifier and Type	Method and Description
SinkRecord	StoreSinkWrite.toLogRecord(SinkRecord record)
SinkRecord	StoreSinkWriteImpl.toLogRecord(SinkRecord record)

Uses of SinkRecord in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink that return SinkRecord

Modifier and Type	Method and Description
SinkRecord	TableWriteImpl.toLogRecord(SinkRecord record)
SinkRecord	TableWriteImpl.writeAndReturn(InternalRow row)
SinkRecord	TableWriteImpl.writeAndReturn(InternalRow row, int bucket)

Methods in org.apache.paimon.table.sink with parameters of type SinkRecord

Modifier and Type	Method and Description
T	TableWriteImpl.RecordExtractor.extract(SinkRecord record, RowKind rowKind)
SinkRecord	TableWriteImpl.toLogRecord(SinkRecord record)