Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010JsonTableSink
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) . |
class |
Kafka010TableSink
Kafka 0.10 table sink for writing data into Kafka.
|
class |
Kafka011TableSink
Kafka 0.11 table sink for writing data into Kafka.
|
class |
Kafka08JsonTableSink
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) . |
class |
Kafka08TableSink
Kafka 0.8 table sink for writing data into Kafka.
|
class |
Kafka09JsonTableSink
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) . |
class |
Kafka09TableSink
Kafka 0.9 table sink for writing data into Kafka.
|
class |
KafkaJsonTableSink
Deprecated.
Use table descriptors instead of implementation-specific classes.
|
class |
KafkaTableSink
Kafka table sink for writing data into Kafka.
|
Modifier and Type | Method and Description |
---|---|
KafkaTableSinkBase |
KafkaTableSinkBase.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
protected KafkaTableSinkBase |
KafkaTableSinkBase.createCopy()
Deprecated.
|
protected KafkaTableSinkBase |
Kafka08TableSourceSinkFactory.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSinkBase |
KafkaTableSourceSinkFactory.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSinkBase |
Kafka011TableSourceSinkFactory.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSinkBase |
Kafka010TableSourceSinkFactory.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSinkBase |
Kafka09TableSourceSinkFactory.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected abstract KafkaTableSinkBase |
KafkaTableSourceSinkFactoryBase.createKafkaTableSink(TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema)
Constructs the version-specific Kafka table sink.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.