@Internal public static class KinesisDynamicSink.KinesisDynamicTableSinkBuilder extends AsyncDynamicTableSinkBuilder<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry,KinesisDynamicSink.KinesisDynamicTableSinkBuilder>
KinesisDynamicSink
.Constructor and Description |
---|
KinesisDynamicTableSinkBuilder() |
Modifier and Type | Method and Description |
---|---|
KinesisDynamicSink |
build() |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setConsumedDataType(DataType consumedDataType) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setFailOnError(Boolean failOnError) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setKinesisClientProperties(Properties kinesisClientProperties) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setPartitioner(PartitionKeyGenerator<RowData> partitioner) |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
setStream(String stream) |
getMaxBatchSize, getMaxBufferedRequests, getMaxBufferSizeInBytes, getMaxInFlightRequests, getMaxTimeInBufferMS, setMaxBatchSize, setMaxBufferedRequests, setMaxBufferSizeInBytes, setMaxInFlightRequests, setMaxTimeInBufferMS
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setConsumedDataType(DataType consumedDataType)
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setStream(String stream)
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setKinesisClientProperties(Properties kinesisClientProperties)
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat)
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setFailOnError(Boolean failOnError)
public KinesisDynamicSink.KinesisDynamicTableSinkBuilder setPartitioner(PartitionKeyGenerator<RowData> partitioner)
public KinesisDynamicSink build()
build
in class AsyncDynamicTableSinkBuilder<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry,KinesisDynamicSink.KinesisDynamicTableSinkBuilder>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.