Package | Description |
---|---|
org.apache.paimon.flink.kafka | |
org.apache.paimon.flink.log |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLogStoreRegister
KafkaLogStoreRegister is used to register/unregister topics in Kafka for paimon table.
|
Modifier and Type | Method and Description |
---|---|
LogStoreRegister |
KafkaLogStoreFactory.createRegister(LogStoreTableFactory.RegisterContext context) |
Modifier and Type | Method and Description |
---|---|
LogStoreRegister |
LogStoreTableFactory.createRegister(LogStoreTableFactory.RegisterContext context)
Creates a
LogStoreRegister instance for table ddl, it will register table to log
store when a table is created or dropped. |
static LogStoreRegister |
LogStoreRegister.getLogStoreRegister(Identifier identifier,
ClassLoader classLoader,
Options tableOptions,
String logStore) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.