Package | Description |
---|---|
org.apache.flink.connector.base.sink.writer | |
org.apache.flink.connector.firehose.sink | |
org.apache.flink.connector.kinesis.sink |
Modifier and Type | Method and Description |
---|---|
BufferedRequestState<RequestEntryT> |
AsyncSinkWriterStateSerializer.deserialize(int version,
byte[] serialized) |
static <T extends Serializable> |
BufferedRequestState.emptyState() |
Modifier and Type | Method and Description |
---|---|
List<BufferedRequestState<RequestEntryT>> |
AsyncSinkWriter.snapshotState(long checkpointId)
All in-flight requests that are relevant for the snapshot have been completed, but there may
still be request entries in the internal buffers that are yet to be sent to the endpoint.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
AsyncSinkWriterStateSerializer.serialize(BufferedRequestState<RequestEntryT> obj)
Serializes state in form of
[DATA_IDENTIFIER,NUM_OF_ELEMENTS,SIZE1,REQUEST1,SIZE2,REQUEST2....].
|
Constructor and Description |
---|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes,
Collection<BufferedRequestState<RequestEntryT>> states) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.createWriter(Sink.InitContext context) |
SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.getWriterStateSerializer() |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.createWriter(Sink.InitContext context) |
SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.getWriterStateSerializer() |
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> recoveredState) |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> |
KinesisStreamsSink.restoreWriter(Sink.InitContext context,
Collection<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> recoveredState) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.