From d28d26c6350d121e1919a692e8807324be2ee214 Mon Sep 17 00:00:00 2001 From: Ashwin Giridharan Date: Wed, 6 May 2020 10:41:12 -0700 Subject: [PATCH] Adding java docs --- .../software/amazon/kinesis/leases/ShardInfo.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java index e0da7dec..aff3f6f0 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/ShardInfo.java @@ -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 * @return lease key */ @@ -152,10 +152,16 @@ public class ShardInfo { 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() ? - MultiStreamLease.getLeaseKey(shardInfo.streamIdentifierSerOpt().get(), shardId) : - shardId; + MultiStreamLease.getLeaseKey(shardInfo.streamIdentifierSerOpt().get(), shardIdOverride) : + shardIdOverride; } }