org.apache.paimon.flink.log

Interface LogSourceProvider

All Superinterfaces:

Serializable

All Known Implementing Classes:

KafkaLogSourceProvider

public interface LogSourceProvider
extends Serializable

A Serializable source provider for log store.

This class is serializable, it can be wrapped as the HybridSource.SourceFactory.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?>	createSource(Map<Integer,Long> bucketOffsets) Creates a Source instance.
void	preCreateSource() Do pre-operations before log Source creation if you need, like system properties setting before job submitting, for the log Source inside of HybridSource will be created during job running.

Method Detail

createSource

org.apache.flink.api.connector.source.Source<org.apache.flink.table.data.RowData,?,?> createSource(@Nullable
                                                                                                   Map<Integer,Long> bucketOffsets)

Creates a Source instance.

Parameters:

bucketOffsets - optional, configure if you need to specify the startup offset.

preCreateSource

void preCreateSource()

Do pre-operations before log Source creation if you need, like system properties setting before job submitting, for the log Source inside of HybridSource will be created during job running.