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 | Method and Description |
---|---|
<T extends IN> |
KafkaRecordSerializationSchemaBuilder.setKeySerializationSchema(SerializationSchema<? super T> keySerializationSchema)
Sets a
SerializationSchema which is used to serialize the incoming element to the key
of the ProducerRecord . |
<T extends IN> |
KafkaRecordSerializationSchemaBuilder.setValueSerializationSchema(SerializationSchema<T> valueSerializationSchema)
Sets a
SerializationSchema which is used to serialize the incoming element to the
value of the ProducerRecord . |
Modifier and Type | Class and Description |
---|---|
class |
AvroRowDataSerializationSchema
Serialization schema that serializes
RowData into Avro bytes. |
class |
AvroRowSerializationSchema
Serialization schema that serializes
Row into Avro bytes. |
class |
AvroSerializationSchema<T>
Serialization schema that serializes to Avro binary format.
|
class |
RegistryAvroSerializationSchema<T>
Serialization schema that serializes to Avro binary format.
|
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Constructor and Description |
---|
AvroRowDataSerializationSchema(RowType rowType,
SerializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema,
RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter)
Creates an Avro serialization schema with the given record row type, nested schema and
runtime converters.
|
Modifier and Type | Class and Description |
---|---|
class |
GlueSchemaRegistryAvroSerializationSchema<T>
AWS Glue Schema Registry Serialization schema to serialize to Avro binary format for Flink
Producer user.
|
Modifier and Type | Class and Description |
---|---|
class |
ConfluentRegistryAvroSerializationSchema<T>
Serialization schema that serializes to Avro binary format that uses Confluent Schema Registry.
|
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
RegistryAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumAvroSerializationSchema
Serialization schema from Flink Table/SQL internal data structure
RowData to Debezium
Avro. |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
DebeziumAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
CsvRowDataSerializationSchema
Serialization schema that serializes an object of Flink Table & SQL internal data structure into
a CSV bytes.
|
class |
CsvRowSerializationSchema
Serialization schema that serializes an object of Flink types into a CSV bytes.
|
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
JsonRowDataSerializationSchema
Serialization schema that serializes an object of Flink internal data structure into a JSON
bytes.
|
class |
JsonRowSerializationSchema
Serialization schema that serializes an object of Flink types into a JSON bytes.
|
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonSerializationSchema
Serialization schema that serializes an object of Flink Table/SQL internal data structure
RowData into a Canal JSON bytes. |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonSerializationSchema
Serialization schema from Flink Table/SQL internal data structure
RowData to Debezium
JSON. |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellJsonSerializationSchema
Serialization schema from Flink Table/SQL internal data structure
RowData to
maxwell-Json. |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
MaxwellJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
RawFormatSerializationSchema
Serialization schema that serializes an
RowData object into raw (byte based) value. |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
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 | Method and Description |
---|---|
<IN> PubSubSink.ProjectNameBuilder<IN> |
PubSubSink.SerializationSchemaBuilder.withSerializationSchema(SerializationSchema<IN> deserializationSchema)
Set the SerializationSchema used to Serialize objects to be added as payloads of
PubSubMessages.
|
Constructor and Description |
---|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig)
Deprecated.
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
FlinkKafkaPartitioner<IN> customPartitioner,
FlinkKafkaProducer.Semantic semantic,
int kafkaProducersPoolSize)
Deprecated.
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer(String topicId,
SerializationSchema<IN> serializationSchema,
Properties producerConfig,
Optional<FlinkKafkaPartitioner<IN>> customPartitioner)
Deprecated.
Creates a FlinkKafkaProducer for a given topic.
|
FlinkKafkaProducer(String brokerList,
String topicId,
SerializationSchema<IN> serializationSchema)
Deprecated.
Creates a FlinkKafkaProducer for a given topic.
|
Modifier and Type | Method and Description |
---|---|
SerializationSchema<T> |
KeyedSerializationSchemaWrapper.getSerializationSchema() |
Constructor and Description |
---|
KafkaSerializationSchemaWrapper(String topic,
FlinkKafkaPartitioner<T> partitioner,
boolean writeTimestamp,
SerializationSchema<T> serializationSchema) |
KeyedSerializationSchemaWrapper(SerializationSchema<T> serializationSchema) |
Modifier and Type | Field and Description |
---|---|
protected EncodingFormat<SerializationSchema<RowData>> |
KafkaDynamicSink.keyEncodingFormat
Optional format for encoding keys to Kafka.
|
protected EncodingFormat<SerializationSchema<RowData>> |
KafkaDynamicSink.valueEncodingFormat
Format for encoding values to Kafka.
|
Modifier and Type | Method and Description |
---|---|
SerializationSchema<RowData> |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType) |
Modifier and Type | Method and Description |
---|---|
protected KafkaDynamicSink |
KafkaDynamicTableFactory.createKafkaTableSink(DataType physicalDataType,
EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat,
EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat,
int[] keyProjection,
int[] valueProjection,
String keyPrefix,
String topic,
Properties properties,
FlinkKafkaPartitioner<RowData> partitioner,
DeliveryGuarantee deliveryGuarantee,
Integer parallelism,
String transactionalIdPrefix) |
protected KafkaDynamicSink |
KafkaDynamicTableFactory.createKafkaTableSink(DataType physicalDataType,
EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat,
EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat,
int[] keyProjection,
int[] valueProjection,
String keyPrefix,
String topic,
Properties properties,
FlinkKafkaPartitioner<RowData> partitioner,
DeliveryGuarantee deliveryGuarantee,
Integer parallelism,
String transactionalIdPrefix) |
Constructor and Description |
---|
EncodingFormatWrapper(EncodingFormat<SerializationSchema<RowData>> innerEncodingFormat) |
KafkaDynamicSink(DataType consumedDataType,
DataType physicalDataType,
EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat,
EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat,
int[] keyProjection,
int[] valueProjection,
String keyPrefix,
String topic,
Properties properties,
FlinkKafkaPartitioner<RowData> partitioner,
DeliveryGuarantee deliveryGuarantee,
boolean upsertMode,
SinkBufferFlushMode flushMode,
Integer parallelism,
String transactionalIdPrefix) |
KafkaDynamicSink(DataType consumedDataType,
DataType physicalDataType,
EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat,
EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat,
int[] keyProjection,
int[] valueProjection,
String keyPrefix,
String topic,
Properties properties,
FlinkKafkaPartitioner<RowData> partitioner,
DeliveryGuarantee deliveryGuarantee,
boolean upsertMode,
SinkBufferFlushMode flushMode,
Integer parallelism,
String transactionalIdPrefix) |
Constructor and Description |
---|
FlinkKinesisProducer(SerializationSchema<OUT> schema,
Properties configProps)
Create a new FlinkKinesisProducer.
|
Constructor and Description |
---|
KinesisDynamicSink(DataType consumedDataType,
String stream,
Properties producerProperties,
EncodingFormat<SerializationSchema<RowData>> encodingFormat,
KinesisPartitioner<RowData> partitioner) |
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 |
EventDeSerializationSchema
A serializer and deserializer for the
Event type. |
Modifier and Type | Class and Description |
---|---|
class |
KafkaEventSchema
The serialization schema for the
KafkaEvent type. |
Modifier and Type | Interface and Description |
---|---|
interface |
SerializationSchema<T>
Deprecated.
Use
SerializationSchema instead. |
Modifier and Type | Method and Description |
---|---|
SerializationSchema<T> |
SerializationSchemaFactory.createSerializationSchema(Map<String,String> properties)
Creates and configures a [[SerializationSchema]] using the given properties.
|
Constructor and Description |
---|
SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.