Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,WriterStateT> |
StatefulSink.createWriter(Sink.InitContext context)
Create a
StatefulSink.StatefulSinkWriter . |
StatefulSink.StatefulSinkWriter<InputT,WriterStateT> |
StatefulSink.restoreWriter(Sink.InitContext context,
Collection<WriterStateT> recoveredState)
Create a
StatefulSink.StatefulSinkWriter from a recovered state. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSinkWriter<InputT,RequestEntryT extends Serializable>
A generic sink writer that handles the general behaviour of a sink such as batching and flushing,
and allows extenders to implement the logic for persisting individual request elements, with
allowance for retries.
|
Modifier and Type | Class and Description |
---|---|
class |
FileWriter<IN>
A
SinkWriter implementation for FileSink . |
Modifier and Type | Method and Description |
---|---|
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> |
KinesisFirehoseSink.createWriter(Sink.InitContext context) |
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) |
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.