Class MultiPartitionCommitterImpl (0.4.5)

Version 0.4.5

• 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