Package 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>, StatefulSinkWriter<InputT,WriterStateT>

Enclosing interface:

StatefulSink<InputT,WriterStateT>

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

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

Methods inherited from interface java.lang.AutoCloseable

close

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

flush, write, writeWatermark

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

snapshotState