InputT
- The type of the sink writer's inputWriterStateT
- The type of the writer's state@PublicEvolving public static interface StatefulSink.StatefulSinkWriter<InputT,WriterStateT> extends StatefulSinkWriter<InputT,WriterStateT>
SinkWriter
whose state needs to be checkpointed.SinkWriter.Context
snapshotState
flush, write, writeWatermark
close
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.