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.