org.apache.paimon.flink.kafka

Class KafkaLogStoreFactory

java.lang.Object

org.apache.paimon.flink.kafka.KafkaLogStoreFactory

All Implemented Interfaces:

Factory, LogStoreTableFactory

public class KafkaLogStoreFactory
extends Object
implements LogStoreTableFactory

The Kafka LogStoreTableFactory implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.flink.log.LogStoreTableFactory

LogStoreTableFactory.RegisterContext

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER
static String	KAFKA_PREFIX

Constructor Summary

Constructors

Constructor and Description
KafkaLogStoreFactory()

Method Summary

Modifier and Type	Method and Description
LogStoreRegister	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.
KafkaLogSinkProvider	createSinkProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.sink.DynamicTableSink.Context sinkContext) Creates a LogSinkProvider instance from a CatalogTable and additional context information.
KafkaLogSourceProvider	createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext, int[][] projectFields) Creates a LogSourceProvider instance from a CatalogTable and additional context information.
String	identifier() Returns a unique identifier among same factory interfaces.
static Properties	toKafkaProperties(Options options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.flink.log.LogStoreTableFactory

discoverLogStoreFactory, getKeyDecodingFormat, getKeyEncodingFormat, getValueDecodingFormat, getValueEncodingFormat, logFormat, logKeyFormat, validateKeyFormat, validateValueFormat

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

KAFKA_PREFIX

public static final String KAFKA_PREFIX

See Also:

Constant Field Values

Constructor Detail

KafkaLogStoreFactory

public KafkaLogStoreFactory()

Method Detail

identifier

public String identifier()

Description copied from interface: Factory

Returns a unique identifier among same factory interfaces.

For consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended using "-" (e.g. elasticsearch-7).

Specified by:

identifier in interface Factory

createSourceProvider

public KafkaLogSourceProvider createSourceProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                   org.apache.flink.table.connector.source.DynamicTableSource.Context sourceContext,
                                                   @Nullable
                                                   int[][] projectFields)

Description copied from interface: LogStoreTableFactory

Creates a LogSourceProvider instance from a CatalogTable and additional context information.

Specified by:

createSourceProvider in interface LogStoreTableFactory

createSinkProvider

public KafkaLogSinkProvider createSinkProvider(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                               org.apache.flink.table.connector.sink.DynamicTableSink.Context sinkContext)

Description copied from interface: LogStoreTableFactory

Creates a LogSinkProvider instance from a CatalogTable and additional context information.

Specified by:

createSinkProvider in interface LogStoreTableFactory

createRegister

public LogStoreRegister createRegister(LogStoreTableFactory.RegisterContext context)

Description copied from interface: LogStoreTableFactory

Creates a LogStoreRegister instance for table ddl, it will register table to log store when a table is created or dropped.

Specified by:

createRegister in interface LogStoreTableFactory

toKafkaProperties

public static Properties toKafkaProperties(Options options)