luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix comment of ICheckpoint.prepareCheckpoint()

Browse source
This commit is contained in:
Walid Baruni 2017-07-12 18:27:52 -07:00
parent 8828ed8b15
commit eb9e7e54a0
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/com/amazonaws/services/kinesis/clientlibrary/interfaces/ICheckpoint.java
View file

@ -60,8 +60,8 @@ public interface ICheckpoint {
/** /**
* Record intent to checkpoint for a shard. Upon failover, the pendingCheckpointValue and pendingCheckpointState * Record intent to checkpoint for a shard. Upon failover, the pendingCheckpointValue will be passed to the new
* will be passed to the new RecordProcessor's init() method. * RecordProcessor's initialize() method.
* *
* @param shardId Checkpoint is specified for this shard. * @param shardId Checkpoint is specified for this shard.
* @param pendingCheckpoint Value of the pending checkpoint (e.g. Kinesis sequence number and subsequence number) * @param pendingCheckpoint Value of the pending checkpoint (e.g. Kinesis sequence number and subsequence number)