ZqliteWatermarkService.getOrCreateWatermark() method

Retrieves an existing watermark for the given shard ID and resume token, or creates a new one if it does not exist.

Signature:

getOrCreateWatermark(shardId: string, resumeToken: string): Promise<string>;

Parameters

Parameter

Type

Description

shardId

string

The identifier for the shard.

resumeToken

string

The token used to resume from a specific point.

Returns:

Promise<string>

A promise that resolves to the watermark string.

How was this page?

ZqliteWatermarkService. nextWatermark() method

ZqliteWatermarkService.getResumeToken() method