Package | Description |
---|---|
org.apache.flink.connector.firehose.sink |
Modifier and Type | Method and Description |
---|---|
static <InputT> KinesisFirehoseSinkBuilder<InputT> |
KinesisFirehoseSink.builder()
Create a
KinesisFirehoseSinkBuilder to allow the fluent construction of a new KinesisFirehoseSink . |
KinesisFirehoseSinkBuilder<InputT> |
KinesisFirehoseSinkBuilder.setDeliveryStreamName(String deliveryStreamName)
Sets the name of the KDF delivery stream that the sink will connect to.
|
KinesisFirehoseSinkBuilder<InputT> |
KinesisFirehoseSinkBuilder.setFailOnError(boolean failOnError)
If writing to Kinesis Data Firehose results in a partial or full failure being returned, the
job will fail immediately with a
KinesisFirehoseException if failOnError is set. |
KinesisFirehoseSinkBuilder<InputT> |
KinesisFirehoseSinkBuilder.setFirehoseClientProperties(Properties firehoseClientProperties)
A set of properties used by the sink to create the firehose client.
|
KinesisFirehoseSinkBuilder<InputT> |
KinesisFirehoseSinkBuilder.setSerializationSchema(SerializationSchema<InputT> serializationSchema)
Allows the user to specify a serialization schema to serialize each record to persist to
Firehose.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.