Modifier and Type | Method and Description |
---|---|
static DeliveryGuarantee |
DeliveryGuarantee.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static DeliveryGuarantee[] |
DeliveryGuarantee.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
KafkaSinkBuilder<IN> |
KafkaSinkBuilder.setDeliverGuarantee(DeliveryGuarantee deliveryGuarantee)
Deprecated.
Will be removed in future versions. Use
KafkaSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee) instead. |
KafkaSinkBuilder<IN> |
KafkaSinkBuilder.setDeliveryGuarantee(DeliveryGuarantee deliveryGuarantee)
Sets the wanted the
DeliveryGuarantee . |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<DeliveryGuarantee> |
PulsarSinkOptions.PULSAR_WRITE_DELIVERY_GUARANTEE |
Modifier and Type | Method and Description |
---|---|
PulsarSinkBuilder<IN> |
PulsarSinkBuilder.setDeliveryGuarantee(DeliveryGuarantee deliveryGuarantee)
Sets the wanted the
DeliveryGuarantee . |
Modifier and Type | Method and Description |
---|---|
DeliveryGuarantee |
SinkConfiguration.getDeliveryGuarantee()
The delivery guarantee changes the behavior of
PulsarWriter . |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<DeliveryGuarantee> |
KafkaConnectorOptions.DELIVERY_GUARANTEE |
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) |
Constructor and Description |
---|
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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.