Interface | Description |
---|---|
Committer<CommT> | Deprecated
Please use
Committer . |
GlobalCommitter<CommT,GlobalCommT> | Deprecated
Please use
WithPostCommitTopology with StandardSinkTopologies#addGlobalCommitter . |
Sink<InputT,CommT,WriterStateT,GlobalCommT> | Deprecated
Please use
Sink or a derivative. |
Sink.InitContext | Deprecated
Please migrate to
Sink and use
Sink.InitContext . |
Sink.ProcessingTimeService | Deprecated
Please migrate to
Sink and use
ProcessingTimeService . |
Sink.ProcessingTimeService.ProcessingTimeCallback | Deprecated
Please migrate to
Sink and use
ProcessingTimeService.ProcessingTimeCallback . |
SinkWriter<InputT,CommT,WriterStateT> | Deprecated
Please use
SinkWriter or a derivative. |
SinkWriter.Context | Deprecated
Please migrate to
SinkWriter and use
SinkWriter.Context . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.