Package | Description |
---|---|
org.apache.flink.connector.kinesis.sink |
Modifier and Type | Method and Description |
---|---|
static <InputT> KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSink.builder()
Create a
KinesisStreamsSinkBuilder to allow the fluent construction of a new KinesisStreamsSink . |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setFailOnError(boolean failOnError) |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setKinesisClientProperties(Properties kinesisClientProperties) |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setPartitionKeyGenerator(PartitionKeyGenerator<InputT> partitionKeyGenerator) |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setSerializationSchema(SerializationSchema<InputT> serializationSchema) |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setStreamName(String streamName)
Sets the name of the KDS stream that the sink will connect to.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.