| Package | Description |
|---|---|
| org.apache.paimon.flink.kafka | |
| org.apache.paimon.flink.log |
| Modifier and Type | Method and Description |
|---|---|
LogStoreRegister |
KafkaLogStoreFactory.createRegister(LogStoreTableFactory.RegisterContext context) |
| Constructor and Description |
|---|
KafkaLogStoreRegister(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. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.