InputT
- Type of the elements handled by this sink@PublicEvolving public class KinesisFirehoseSink<InputT> extends AsyncSinkBase<InputT,software.amazon.awssdk.services.firehose.model.Record>
AsyncSinkBase
.
The sink internally uses a FirehoseAsyncClient
to communicate with the AWS
endpoint.
Please see the writer implementation in KinesisFirehoseSinkWriter
StatefulSink.StatefulSinkWriter<InputT,WriterStateT>, StatefulSink.WithCompatibleState
Sink.InitContext
Modifier and Type | Method and Description |
---|---|
static <InputT> KinesisFirehoseSinkBuilder<InputT> |
builder()
Create a
KinesisFirehoseSinkBuilder to allow the fluent construction of a new KinesisFirehoseSink . |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
createWriter(Sink.InitContext context)
Create a
StatefulSink.StatefulSinkWriter . |
SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
getWriterStateSerializer()
Any stateful sink needs to provide this state serializer and implement
StatefulSink.StatefulSinkWriter.snapshotState(long) properly. |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState)
Create a
StatefulSink.StatefulSinkWriter from a recovered state. |
getElementConverter, getMaxBatchSize, getMaxBatchSizeInBytes, getMaxBufferedRequests, getMaxInFlightRequests, getMaxRecordSizeInBytes, getMaxTimeInBufferMS
public static <InputT> KinesisFirehoseSinkBuilder<InputT> builder()
KinesisFirehoseSinkBuilder
to allow the fluent construction of a new KinesisFirehoseSink
.InputT
- type of incoming recordsKinesisFirehoseSinkBuilder
public StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> createWriter(Sink.InitContext context) throws IOException
StatefulSink
StatefulSink.StatefulSinkWriter
.context
- the runtime context.IOException
- for any failure during creation.public StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> restoreWriter(Sink.InitContext context, Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState) throws IOException
StatefulSink
StatefulSink.StatefulSinkWriter
from a recovered state.context
- the runtime context.IOException
- for any failure during creation.public SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> getWriterStateSerializer()
StatefulSink
StatefulSink.StatefulSinkWriter.snapshotState(long)
properly. The respective state is used in #restoreWriter(InitContext, Collection)
on recovery.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.