Class CursorClientImpl (1.10.0)

Version 1.10.0

• 1.14.7 (latest)
• 1.14.4
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

public class CursorClientImpl extends ApiResourceAggregation implements CursorClient

Inheritance

java.lang.Object > ApiResourceAggregation > CursorClientImpl

Implements

CursorClient

Inherited Members

ApiResourceAggregation.awaitTermination(long,TimeUnit)

ApiResourceAggregation.close()

ApiResourceAggregation.isShutdown()

ApiResourceAggregation.isTerminated()

ApiResourceAggregation.shutdown()

ApiResourceAggregation.shutdownNow()

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

CursorClientImpl(CloudRegion region, CursorServiceClient serviceClient)

public CursorClientImpl(CloudRegion region, CursorServiceClient serviceClient)

Parameters

Name	Description
region	CloudRegion
serviceClient	CursorServiceClient

Methods

commitCursor(SubscriptionPath path, Partition partition, Offset offset)

public ApiFuture<Void> commitCursor(SubscriptionPath path, Partition partition, Offset offset)

Commit a single cursor.

Parameters

Name	Description
path	SubscriptionPath
partition	Partition
offset	Offset

Returns

Type	Description
ApiFuture<Void>

listPartitionCursors(SubscriptionPath path)

public ApiFuture<Map<Partition,Offset>> listPartitionCursors(SubscriptionPath path)

List the cursors for a given subscription.

Parameter

Name	Description
path	SubscriptionPath

Returns

Type	Description
ApiFuture<Map<Partition,Offset>>

region()

public CloudRegion region()

The Google Cloud region this client operates on.

Returns

Type	Description
CloudRegion