org.apache.paimon.flink.sink

Interface Committer.Factory<CommitT,GlobalCommitT>

All Superinterfaces:

Serializable

Enclosing interface:

Committer<CommitT,GlobalCommitT>

public static interface Committer.Factory<CommitT,GlobalCommitT>
extends Serializable

Factory to create Committer.

Method Summary

Modifier and Type	Method and Description
Committer<CommitT,GlobalCommitT>	create(Committer.Context context)

Method Detail

create

Committer<CommitT,GlobalCommitT> create(Committer.Context context)