org.apache.flink.api.connector.sink2

Interface StatefulSink.StatefulSinkWriter<InputT,WriterStateT>

Type Parameters:

InputT - The type of the sink writer's input

WriterStateT - The type of the writer's state

All Superinterfaces:

AutoCloseable, SinkWriter<InputT>

All Known Implementing Classes:

AsyncSinkWriter, FileWriter

Enclosing interface:

StatefulSink<InputT,WriterStateT>

@PublicEvolving
public static interface StatefulSink.StatefulSinkWriter<InputT,WriterStateT>
extends SinkWriter<InputT>

A SinkWriter whose state needs to be checkpointed.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

SinkWriter.Context

Method Summary

Modifier and Type	Method and Description
List<WriterStateT>	snapshotState(long checkpointId)

Methods inherited from interface org.apache.flink.api.connector.sink2.SinkWriter

flush, write, writeWatermark

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

snapshotState

List<WriterStateT> snapshotState(long checkpointId)
                          throws IOException

Returns:

The writer's state.

Throws:

IOException - if fail to snapshot writer's state.