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

Adding java docs

Browse source
This commit is contained in:
Ashwin Giridharan 2020-05-06 10:41:12 -07:00
parent e86b1d1f01
commit d28d26c635
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java
View file

@ -144,7 +144,7 @@ public class ShardInfo {
} }
/** /**
* Utility method to derive lease key from ShardInfo * Utility method to derive lease key from ShardInfo.
* @param shardInfo * @param shardInfo
* @return lease key * @return lease key
*/ */
@ -152,10 +152,16 @@ public class ShardInfo {
return getLeaseKey(shardInfo, shardInfo.shardId()); return getLeaseKey(shardInfo, shardInfo.shardId());
} }
public static String getLeaseKey(ShardInfo shardInfo, String shardId) { /**
* Utility method to derive lease key from ShardInfo and shardId to override.
* @param shardInfo
* @param shardIdOverride
* @return lease key
*/
public static String getLeaseKey(ShardInfo shardInfo, String shardIdOverride) {
return shardInfo.streamIdentifierSerOpt().isPresent() ? return shardInfo.streamIdentifierSerOpt().isPresent() ?
MultiStreamLease.getLeaseKey(shardInfo.streamIdentifierSerOpt().get(), shardId) : MultiStreamLease.getLeaseKey(shardInfo.streamIdentifierSerOpt().get(), shardIdOverride) :
shardId; shardIdOverride;
} }
} }