程序包org.apache.seatunnel.translation.flink.sink的分层结构

程序包分层结构:

• 所有程序包

类分层结构

• java.lang.Object
  • org.apache.seatunnel.translation.flink.sink.CommitWrapper<CommitT>
  • org.apache.seatunnel.translation.flink.sink.FlinkCommitter<CommT> (implements org.apache.flink.api.connector.sink.Committer<CommT>)
  • org.apache.seatunnel.translation.flink.sink.FlinkGlobalCommitter<CommT,GlobalCommT> (implements org.apache.flink.api.connector.sink.GlobalCommitter<CommT,GlobalCommT>)
  • org.apache.seatunnel.translation.flink.sink.FlinkSink<InputT,CommT,WriterStateT,GlobalCommT> (implements org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,GlobalCommT>)
  • org.apache.seatunnel.translation.flink.sink.FlinkSinkWriter<InputT,CommT,WriterStateT> (implements org.apache.flink.api.connector.sink.SinkWriter<InputT,CommT,WriterStateT>)
  • org.apache.seatunnel.translation.flink.sink.FlinkSinkWriterContext (implements org.apache.seatunnel.api.sink.SinkWriter.Context)
  • org.apache.seatunnel.translation.flink.sink.FlinkWriterState<StateT> (implements java.io.Serializable)