程序包 org.apache.seatunnel.translation.flink.sink

类 CommitWrapper<CommitT>

  • 类型参数:
    CommitT - The generic type of commit message
    public class CommitWrapper<CommitT>
extends Object
    The commit message wrapper, which is used to wrapper the different commit messages and unify the different implementations of CommitWrapper

    • 构造器详细资料

      • CommitWrapper

        public CommitWrapper​(CommitT commit)

    • 方法详细资料

      • getCommit

        public CommitT getCommit()