org.apache.paimon.flink.log

Interface LogStoreRegister

All Known Implementing Classes:

KafkaLogStoreRegister

public interface LogStoreRegister

LogStoreRegister will register and unregister topic for a Paimon table, you can implement it for customized log system management.

Method Summary

Modifier and Type	Method and Description
static LogStoreRegister	getLogStoreRegister(Identifier identifier, ClassLoader classLoader, Options tableOptions, String logStore)
static void	registerLogSystem(Catalog catalog, Identifier identifier, Map<String,String> options, ClassLoader classLoader)
Map<String,String>	registerTopic() Register topic in log system for the table.
static void	unRegisterLogSystem(Identifier identifier, Map<String,String> options, ClassLoader classLoader)
void	unRegisterTopic() Unregister topic in log system for the table.

Method Detail

registerTopic

Map<String,String> registerTopic()

Register topic in log system for the table.

unRegisterTopic

void unRegisterTopic()

Unregister topic in log system for the table.

registerLogSystem

static void registerLogSystem(Catalog catalog,
                              Identifier identifier,
                              Map<String,String> options,
                              ClassLoader classLoader)

unRegisterLogSystem

static void unRegisterLogSystem(Identifier identifier,
                                Map<String,String> options,
                                ClassLoader classLoader)

getLogStoreRegister

static LogStoreRegister getLogStoreRegister(Identifier identifier,
                                            ClassLoader classLoader,
                                            Options tableOptions,
                                            String logStore)