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