程序包 org.apache.flink.streaming.runtime.operators.sink

类概要

类	说明
CommitterOperatorFactory<CommT,GlobalCommT>	A StreamOperatorFactory for CommitterOperator.
GlobalStreamingCommitterHandler<CommT,GlobalCommT>	CommitterHandler for executing GlobalCommitter in the streaming execution mode.
SinkOperatorFactory<InputT,CommT,WriterStateT>	A StreamOperatorFactory for SinkOperator.