Class MultiPartitionCommitterImpl (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class MultiPartitionCommitterImpl implements MultiPartitionCommitter

A MultiPartitionCommitter that lazily adjusts for partition changes when MultiPartitionCommitter#commit(PslSourceOffset) is called.

Inheritance

java.lang.Object > MultiPartitionCommitterImpl

Implements

MultiPartitionCommitter

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

MultiPartitionCommitterImpl(SubscriptionPath subscription, CursorClient client)

public MultiPartitionCommitterImpl(SubscriptionPath subscription, CursorClient client)

Parameters
Name	Description
subscription	com.google.cloud.pubsublite.SubscriptionPath
client	com.google.cloud.pubsublite.internal.CursorClient

Methods

close()

public void close()

commit(PslSourceOffset offset)

public void commit(PslSourceOffset offset)

Parameter
Name	Description
offset	PslSourceOffset