in src/main/java/com/amazonaws/services/dynamodbv2/streamsadapter/AmazonDynamoDBStreamsAdapterClient.java [302:315]
private void markLeafShardsAsActive(List<Shard> shards) {
List<String> parentShardIds = new ArrayList<String>();
for (Shard shard : shards) {
if (shard.getParentShardId() != null) {
parentShardIds.add(shard.getParentShardId());
}
}
for (Shard shard : shards) {
// Feign shard activity by modifying leaf shards
if (!parentShardIds.contains(shard.getShardId())) {
shard.getSequenceNumberRange().setEndingSequenceNumber(null);
}
}
}