Querying a Checkpoint
Initialize a DIS client as instructed in Initializing a DIS SDK Client Instance.
Use the DIS SDK to query the checkpoint.
string streamName = "streamName";
string appName= "appName";
var dic = new DISIngestionClient();
var request = new GetCheckpointRequest
{
//Stream name.
StreamName = streamName,
//Application ID.
AppId = appName,
//Unique identifier of the partition.
ShardId = "shardId-0000000000",
//Type of the checkpoint.
CheckpointType = "LAST_READ",
};
var response = dic.GetCheckpoint(request);
Console.Out.WriteLine(response); Viewing Execution Results
Information similar to the following is displayed on the console:
GetCheckpointResult [sequence_number=1,metadata=]
| Parameter | Type | Description |
|---|---|---|
| sequence_number | String | Sequence number. A sequence number is the unique identifier of each record. |
| metadata | String | Metadata information of the consumer application. |
Last Article: Adding a Checkpoint
Next Article: Changing Partition Quantity
Did this article solve your problem?
Thank you for your score!Your feedback would help us improve the website.