Package | Description |
---|---|
org.apache.flink.table.store.connector.sink | |
org.apache.flink.table.store.kafka | |
org.apache.flink.table.store.table.sink |
Modifier and Type | Method and Description |
---|---|
SinkRecord |
StoreSinkWriteImpl.toLogRecord(SinkRecord record) |
SinkRecord |
StoreSinkWriteImpl.write(org.apache.flink.table.data.RowData rowData) |
SinkRecord |
FullChangelogStoreSinkWrite.write(org.apache.flink.table.data.RowData rowData) |
Modifier and Type | Method and Description |
---|---|
SinkRecord |
StoreSinkWriteImpl.toLogRecord(SinkRecord record) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> |
KafkaLogSerializationSchema.serialize(SinkRecord element,
Long timestamp) |
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. |
Modifier and Type | Method and Description |
---|---|
SinkRecord |
SinkRecordConverter.convert(org.apache.flink.table.data.RowData row) |
SinkRecord |
SinkRecordConverter.convertToLogSinkRecord(SinkRecord record) |
SinkRecord |
TableWrite.toLogRecord(SinkRecord record)
Log record need to preserve original pk (which includes partition fields).
|
SinkRecord |
TableWriteImpl.toLogRecord(SinkRecord record) |
SinkRecord |
TableWrite.write(org.apache.flink.table.data.RowData rowData) |
SinkRecord |
TableWriteImpl.write(org.apache.flink.table.data.RowData rowData) |
Modifier and Type | Method and Description |
---|---|
SinkRecord |
SinkRecordConverter.convertToLogSinkRecord(SinkRecord record) |
T |
TableWriteImpl.RecordExtractor.extract(SinkRecord record) |
SinkRecord |
TableWrite.toLogRecord(SinkRecord record)
Log record need to preserve original pk (which includes partition fields).
|
SinkRecord |
TableWriteImpl.toLogRecord(SinkRecord record) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.