public interface ICheckPointConsumer
Modifier and Type | Method and Description |
---|---|
String |
applicationId() |
void |
commit(CheckPoint checkPoint) |
CheckPoint |
lastCommittedCheckPoint()
Use this method to retrieve information of last committed checkpoint
|
CheckPoint |
lastCommittedCheckPoint(String applicationRuntimeIdFieldName,
String applicationCheckPointIntervalFieldName)
Use this method to retrieve information of last committed checkpoint with a custom field name
|
void commit(CheckPoint checkPoint)
checkPoint
- which is initialized by the application who wants to commit at a given dateCheckPoint lastCommittedCheckPoint()
CheckPoint lastCommittedCheckPoint(String applicationRuntimeIdFieldName, String applicationCheckPointIntervalFieldName)
applicationRuntimeIdFieldName
- custom application runtime id field nameapplicationCheckPointIntervalFieldName
- custom application checkpoint interval field nameString applicationId()
Copyright © 2014–2022. All rights reserved.