org.apache.flink.connector.firehose.table

Class KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder

java.lang.Object

org.apache.flink.connector.base.table.sink.AsyncDynamicTableSinkBuilder<software.amazon.awssdk.services.firehose.model.Record,KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder>

org.apache.flink.connector.firehose.table.KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder

Enclosing class:

KinesisFirehoseDynamicSink

@Internal
public static class KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder
extends AsyncDynamicTableSinkBuilder<software.amazon.awssdk.services.firehose.model.Record,KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder>

Builder class for KinesisFirehoseDynamicSink.

Constructor Summary

Constructors

Constructor and Description
KinesisFirehoseDynamicSinkBuilder()

Method Summary

Modifier and Type	Method and Description
KinesisFirehoseDynamicSink	build()
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	setConsumedDataType(DataType consumedDataType)
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	setDeliveryStream(String deliveryStream)
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat)
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	setFailOnError(Boolean failOnError)
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	setFirehoseClientProperties(Properties firehoseClientProperties)

Methods inherited from class org.apache.flink.connector.base.table.sink.AsyncDynamicTableSinkBuilder

getMaxBatchSize, getMaxBufferedRequests, getMaxBufferSizeInBytes, getMaxInFlightRequests, getMaxTimeInBufferMS, setMaxBatchSize, setMaxBufferedRequests, setMaxBufferSizeInBytes, setMaxInFlightRequests, setMaxTimeInBufferMS

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisFirehoseDynamicSinkBuilder

public KinesisFirehoseDynamicSinkBuilder()

Method Detail

setConsumedDataType

public KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder setConsumedDataType(DataType consumedDataType)

setDeliveryStream

public KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder setDeliveryStream(String deliveryStream)

setFirehoseClientProperties

public KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder setFirehoseClientProperties(Properties firehoseClientProperties)

setEncodingFormat

public KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat)

setFailOnError

public KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder setFailOnError(Boolean failOnError)

build

public KinesisFirehoseDynamicSink build()

Specified by:

build in class AsyncDynamicTableSinkBuilder<software.amazon.awssdk.services.firehose.model.Record,KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder>