Interface MultiPartitionCommitter.CommitterFactory (0.4.5)

public static interface MultiPartitionCommitter.CommitterFactory

Methods

newCommitter(Partition partition)

public abstract Committer newCommitter(Partition partition)
Parameter
NameDescription
partitioncom.google.cloud.pubsublite.Partition
Returns
TypeDescription
com.google.cloud.pubsublite.internal.wire.Committer