StatefulSinkWriter (Flink : Core 1.20.1-cp1 API)

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 Subinterfaces:

StatefulSink.StatefulSinkWriter<InputT,WriterStateT>
```
@Public
public interface 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
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  List<WriterStateT> snapshotState(long checkpointId)
  - Methods inherited from interface java.lang.AutoCloseable
    close
  - Methods inherited from interface org.apache.flink.api.connector.sink2.SinkWriter
    flush, write, writeWatermark

- Method Detail
  - snapshotState
```
List<WriterStateT> snapshotState(long checkpointId)
                          throws IOException
```
    Returns:
    
    The writer's state.
    
    Throws:
    
    IOException - if fail to snapshot writer's state.