T
- Type of the KafkaTableSourceBase produced by the builder.B
- Type of the KafkaTableSourceBase.Builder subclass.Kafka
descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor)
.@Deprecated protected abstract static class KafkaTableSourceBase.Builder<T extends KafkaTableSourceBase,B extends KafkaTableSourceBase.Builder> extends Object
KafkaTableSourceBase
to be extended by builders of subclasses of
KafkaTableSourceBase.Modifier | Constructor and Description |
---|---|
protected |
Builder()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected abstract KafkaTableSourceBase |
build()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected abstract B |
builder()
Deprecated.
Use the
Kafka descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor) . |
protected void |
configureTableSource(T tableSource)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
forTopic(String topic)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
fromEarliest()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
fromGroupOffsets()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
fromLatest()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
fromSpecificOffsets(Map<KafkaTopicPartition,Long> specificStartupOffsets)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected Properties |
getKafkaProps()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected TableSchema |
getTableSchema()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected String |
getTopic()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
protected abstract boolean |
supportsKafkaTimestamps()
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withKafkaProperties(Properties props)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withKafkaTimestampAsRowtimeAttribute(String rowtimeAttribute,
org.apache.flink.table.sources.wmstrategies.WatermarkStrategy watermarkStrategy)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withProctimeAttribute(String proctimeAttribute)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withRowtimeAttribute(String rowtimeAttribute,
org.apache.flink.table.sources.tsextractors.TimestampExtractor timestampExtractor,
org.apache.flink.table.sources.wmstrategies.WatermarkStrategy watermarkStrategy)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
B |
withSchema(TableSchema schema)
Deprecated.
Use table descriptors instead of implementation-specific builders.
|
@Deprecated public B forTopic(String topic)
topic
- The topic from which the table is read.@Deprecated public B withKafkaProperties(Properties props)
props
- The configuration properties for the Kafka consumer.@Deprecated public B withSchema(TableSchema schema)
schema
- The schema of the produced table.@Deprecated public B withProctimeAttribute(String proctimeAttribute)
Types.SQL_TIMESTAMP()
.proctimeAttribute
- The name of the processing time attribute in the table schema.@Deprecated public B withRowtimeAttribute(String rowtimeAttribute, org.apache.flink.table.sources.tsextractors.TimestampExtractor timestampExtractor, org.apache.flink.table.sources.wmstrategies.WatermarkStrategy watermarkStrategy)
Types.SQL_TIMESTAMP()
.rowtimeAttribute
- The name of the rowtime attribute in the table schema.timestampExtractor
- The TimestampExtractor
to extract the rowtime attribute from the physical type.watermarkStrategy
- The WatermarkStrategy
to generate watermarks for the rowtime attribute.@Deprecated public B withKafkaTimestampAsRowtimeAttribute(String rowtimeAttribute, org.apache.flink.table.sources.wmstrategies.WatermarkStrategy watermarkStrategy)
Note: Kafka supports message timestamps only since version 0.10.
rowtimeAttribute
- The name of the rowtime attribute in the table schema.watermarkStrategy
- The WatermarkStrategy
to generate watermarks for the rowtime attribute.@Deprecated public B fromEarliest()
@Deprecated public B fromLatest()
@Deprecated public B fromGroupOffsets()
@Deprecated public B fromSpecificOffsets(Map<KafkaTopicPartition,Long> specificStartupOffsets)
specificStartupOffsets
- the specified offsets for partitionsFlinkKafkaConsumerBase.setStartFromSpecificOffsets(Map)
@Deprecated protected String getTopic()
@Deprecated protected Properties getKafkaProps()
@Deprecated protected TableSchema getTableSchema()
@Deprecated protected abstract boolean supportsKafkaTimestamps()
@Deprecated protected void configureTableSource(T tableSource)
tableSource
- The TableSource to configure.@Deprecated protected abstract B builder()
Kafka
descriptor together
with descriptors for schema and format instead. Descriptors allow for
implementation-agnostic definition of tables. See also
TableEnvironment.connect(ConnectorDescriptor)
.@Deprecated protected abstract KafkaTableSourceBase build()
KafkaTableSourceBase
.KafkaTableSourceBase
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.