Modifier and Type | Method and Description |
---|---|
default SinkWriter<InputT> |
Sink.createWriter(WriterInitContext context)
Creates a
SinkWriter . |
StatefulSinkWriter<InputT,WriterStateT> |
SupportsWriterState.restoreWriter(WriterInitContext context,
Collection<WriterStateT> recoveredState)
Create a
StatefulSinkWriter from a recovered state. |
default StatefulSink.StatefulSinkWriter<InputT,WriterStateT> |
StatefulSink.restoreWriter(WriterInitContext context,
Collection<WriterStateT> recoveredState)
Deprecated.
Create a
StatefulSinkWriter from a recovered
state. |
Constructor and Description |
---|
InitContextWrapper(WriterInitContext wrapped)
Deprecated.
|
Constructor and Description |
---|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
WriterInitContext context,
AsyncSinkWriterConfiguration configuration,
Collection<BufferedRequestState<RequestEntryT>> states) |
Modifier and Type | Method and Description |
---|---|
FileWriter<IN> |
FileSink.createWriter(WriterInitContext context) |
FileWriter<IN> |
FileSink.restoreWriter(WriterInitContext context,
Collection<FileWriterBucketState> recoveredState) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.api.transformations.SinkV1Adapter.SinkWriterV1Adapter<InputT,CommT,WriterStateT> |
SinkV1Adapter.createWriter(WriterInitContext context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.