public class KafkaLogSourceProvider extends Object implements LogSourceProvider
LogSourceProvider
.Constructor and Description |
---|
KafkaLogSourceProvider(String topic,
Properties properties,
org.apache.flink.table.types.DataType physicalType,
int[] primaryKey,
org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> primaryKeyDeserializer,
org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> valueDeserializer,
int[][] projectFields,
CoreOptions.LogConsistency consistency,
CoreOptions.StartupMode scanMode,
Long timestampMills) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.connector.kafka.source.KafkaSource<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. |
public KafkaLogSourceProvider(String topic, Properties properties, org.apache.flink.table.types.DataType physicalType, int[] primaryKey, @Nullable org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> primaryKeyDeserializer, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> valueDeserializer, @Nullable int[][] projectFields, CoreOptions.LogConsistency consistency, CoreOptions.StartupMode scanMode, @Nullable Long timestampMills)
public void preCreateSource()
LogSourceProvider
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.preCreateSource
in interface LogSourceProvider
public org.apache.flink.connector.kafka.source.KafkaSource<org.apache.flink.table.data.RowData> createSource(@Nullable Map<Integer,Long> bucketOffsets)
LogSourceProvider
Source
instance.createSource
in interface LogSourceProvider
bucketOffsets
- optional, configure if you need to specify the startup offset.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.