InputT- The type of the sink writer's input
WriterStateT- The type of the writer's state
@PublicEvolving public static interface StatefulSink.StatefulSinkWriter<InputT,WriterStateT> extends SinkWriter<InputT>
SinkWriterwhose state needs to be checkpointed.
|Modifier and Type||Method and Description|
flush, write, writeWatermark
List<WriterStateT> snapshotState(long checkpointId) throws IOException
IOException- if fail to snapshot writer's state.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.