Modifier and Type | Class and Description |
---|---|
class |
SimpleStringSchema
Very simple serialization schema for strings.
|
class |
TypeInformationSerializationSchema<T>
A serialization and deserialization schema that uses Flink's serialization stack to
transform typed from and to byte arrays.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroRowSerializationSchema
Serialization schema that serializes
Row into Avro bytes. |
Modifier and Type | Method and Description |
---|---|
SerializationSchema<Row> |
AvroRowFormatFactory.createSerializationSchema(Map<String,String> properties) |
Modifier and Type | Class and Description |
---|---|
class |
JsonRowSerializationSchema
Serialization schema that serializes an object of Flink types into a JSON bytes.
|
Modifier and Type | Method and Description |
---|---|
SerializationSchema<Row> |
JsonRowFormatFactory.createSerializationSchema(Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeToSocket(String hostName,
int port,
SerializationSchema<T> schema)
Writes the DataStream to a socket as a byte array.
|
Constructor and Description |
---|
SocketClientSink(String hostName,
int port,
SerializationSchema<IN> schema)
Creates a new SocketClientSink.
|
SocketClientSink(String hostName,
int port,
SerializationSchema<IN> schema,
int maxNumRetries)
Creates a new SocketClientSink that retries connections upon failure up to a given number of times.
|
SocketClientSink(String hostName,
int port,
SerializationSchema<IN> schema,
int maxNumRetries,
boolean autoflush)
Creates a new SocketClientSink that retries connections upon failure up to a given number of times.
|
Modifier and Type | Field and Description |
---|---|
protected Optional<SerializationSchema<Row>> |
KafkaTableSink.serializationSchema
Serialization schema for encoding records to Kafka.
|
Modifier and Type | Method and Description |
---|---|
protected SerializationSchema<Row> |
KafkaTableSink.createSerializationSchema(RowTypeInfo rowSchema)
Deprecated.
Use the constructor to pass a serialization schema instead.
|
protected SerializationSchema<Row> |
KafkaJsonTableSink.createSerializationSchema(RowTypeInfo rowSchema)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected SinkFunction<Row> |
Kafka011TableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner) |
protected FlinkKafkaProducerBase<Row> |
Kafka010JsonTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Deprecated.
|
protected FlinkKafkaProducerBase<Row> |
Kafka010TableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner) |
protected FlinkKafkaProducerBase<Row> |
Kafka09JsonTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Deprecated.
|
protected FlinkKafkaProducerBase<Row> |
Kafka09TableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner) |
protected FlinkKafkaProducerBase<Row> |
Kafka08JsonTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Deprecated.
|
protected FlinkKafkaProducerBase<Row> |
Kafka08TableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner) |
protected abstract SinkFunction<Row> |
KafkaTableSink.createKafkaProducer(String topic,
Properties properties,
SerializationSchema<Row> serializationSchema,
Optional<FlinkKafkaPartitioner<Row>> partitioner)
Returns the version-specific Kafka producer.
|
protected KafkaTableSink |
Kafka011TableSourceSinkFactory.createKafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSink |
Kafka010TableSourceSinkFactory.createKafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSink |
Kafka09TableSourceSinkFactory.createKafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected KafkaTableSink |
Kafka08TableSourceSinkFactory.createKafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
protected abstract KafkaTableSink |
KafkaTableSourceSinkFactoryBase.createKafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema)
Constructs the version-specific Kafka table sink.
|
static <T> FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T> |
FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T> inStream,
String topicId,
SerializationSchema<T> serializationSchema,
Properties producerConfig)
|
Constructor and Description |
---|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner customPartitioner)
|
FlinkKafkaProducer(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
|
FlinkKafkaProducer010(String topicId,
SerializationSchema<T> serializationSchema,
Properties producerConfig)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer010(String topicId,
SerializationSchema<T> serializationSchema,
Properties producerConfig,
FlinkKafkaPartitioner<T> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer010(String topicId,
SerializationSchema<T> serializationSchema,
Properties producerConfig,
KafkaPartitioner<T> customPartitioner)
Deprecated.
This is a deprecated since it does not correctly handle partitioning when
producing to multiple topics. Use
FlinkKafkaProducer010.FlinkKafkaProducer010(String, SerializationSchema, Properties, FlinkKafkaPartitioner) instead. |
FlinkKafkaProducer010(String brokerList,
String topicId,
SerializationSchema<T> serializationSchema)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer011(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer011(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
Optional<FlinkKafkaPartitioner<IN>> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer011(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer08(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer08(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
FlinkKafkaPartitioner<IN> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer08(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
Deprecated.
This is a deprecated constructor that does not correctly handle partitioning when
producing to multiple topics. Use
FlinkKafkaProducer08.FlinkKafkaProducer08(String, SerializationSchema, Properties, FlinkKafkaPartitioner) instead. |
FlinkKafkaProducer08(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer09(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer09(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
FlinkKafkaPartitioner<IN> customPartitioner)
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer09(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
KafkaPartitioner<IN> customPartitioner)
Deprecated.
This is a deprecated constructor that does not correctly handle partitioning when
producing to multiple topics. Use
FlinkKafkaProducer09.FlinkKafkaProducer09(String, SerializationSchema, Properties, FlinkKafkaPartitioner) instead. |
FlinkKafkaProducer09(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
Creates a FlinkKafkaProducer for a given topic.
|
Kafka010TableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
Kafka011TableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
Kafka08TableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
Kafka09TableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
KafkaTableSink(org.apache.flink.table.api.TableSchema schema,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<Row>> partitioner,
SerializationSchema<Row> serializationSchema) |
Modifier and Type | Field and Description |
---|---|
protected SerializationSchema<IN> |
RMQSink.schema |
Constructor and Description |
---|
RMQSink(RMQConnectionConfig rmqConnectionConfig,
SerializationSchema<IN> schema,
RMQSinkPublishOptions<IN> publishOptions) |
RMQSink(RMQConnectionConfig rmqConnectionConfig,
SerializationSchema<IN> schema,
RMQSinkPublishOptions<IN> publishOptions,
SerializableReturnListener returnListener) |
RMQSink(RMQConnectionConfig rmqConnectionConfig,
String queueName,
SerializationSchema<IN> schema) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaEventSchema
The serialization schema for the
KafkaEvent type. |
Modifier and Type | Class and Description |
---|---|
class |
EventDeSerializer
A serializer and deserializer for the
Event type. |
Modifier and Type | Method and Description |
---|---|
void |
PythonDataStream.write_to_socket(String host,
Integer port,
SerializationSchema<org.python.core.PyObject> schema)
A thin wrapper layer over
DataStream.writeToSocket(String, int, org.apache.flink.api.common.serialization.SerializationSchema) . |
Modifier and Type | Class and Description |
---|---|
class |
PythonSerializationSchema
A
SerializationSchema for PyObject s. |
Constructor and Description |
---|
PythonSerializationSchema(SerializationSchema<org.python.core.PyObject> schema) |
Modifier and Type | Interface and Description |
---|---|
interface |
SerializationSchema<T>
Deprecated.
Use
SerializationSchema instead. |
Constructor and Description |
---|
KeyedSerializationSchemaWrapper(SerializationSchema<T> serializationSchema) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.