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

Fixing doc comment shard structure format for HierarchicalShardSyncerTest

Browse source
This commit is contained in:
Ashwin Giridharan 2020-02-11 13:05:26 -08:00
parent b3bcc59697
commit 5c268c2b03
1 changed files with 23 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/HierarchicalShardSyncerTest.java
View file

@ -844,11 +844,11 @@ public class HierarchicalShardSyncerTest {
// /** // /**
// * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position Latest) // * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position Latest)
// * Shard structure (each level depicts a stream segment): // * Shard structure (each level depicts a stream segment):
// * 0 1 2 3 4 5- shards till epoch 102 // * 0 1 2 3 4 5- shards till epoch 102
// * \ / \ / | | // * \ / \ / | |
// * 6 7 4 5- shards from epoch 103 - 205 // * 6 7 4 5- shards from epoch 103 - 205
// * \ / | /\ // * \ / | /\
// * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber) // * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber)
// * Current leases: (3, 4, 5) // * Current leases: (3, 4, 5)
// */ // */
@Test @Test
@ -879,11 +879,11 @@ public class HierarchicalShardSyncerTest {
// /** // /**
// * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position Latest) // * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position Latest)
// * Shard structure (each level depicts a stream segment): // * Shard structure (each level depicts a stream segment):
// * 0 1 2 3 4 5- shards till epoch 102 // * 0 1 2 3 4 5- shards till epoch 102
// * \ / \ / | | // * \ / \ / | |
// * 6 7 4 5- shards from epoch 103 - 205 // * 6 7 4 5- shards from epoch 103 - 205
// * \ / | /\ // * \ / | /\
// * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber) // * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber)
// * Current leases: (4, 5, 7) // * Current leases: (4, 5, 7)
// */ // */
@Test @Test
@ -912,11 +912,11 @@ public class HierarchicalShardSyncerTest {
// /** // /**
// * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position TrimHorizon) // * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position TrimHorizon)
// * Shard structure (each level depicts a stream segment): // * Shard structure (each level depicts a stream segment):
// * 0 1 2 3 4 5- shards till epoch 102 // * 0 1 2 3 4 5- shards till epoch 102
// * \ / \ / | | // * \ / \ / | |
// * 6 7 4 5- shards from epoch 103 - 205 // * 6 7 4 5- shards from epoch 103 - 205
// * \ / | /\ // * \ / | /\
// * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber) // * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber)
// * Current leases: (3, 4, 5) // * Current leases: (3, 4, 5)
// */ // */
@Test @Test
@ -947,11 +947,11 @@ public class HierarchicalShardSyncerTest {
// /** // /**
// * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position TrimHorizon) // * Test CheckIfDescendantAndAddNewLeasesForAncestors (initial position TrimHorizon)
// * Shard structure (each level depicts a stream segment): // * Shard structure (each level depicts a stream segment):
// * 0 1 2 3 4 5- shards till epoch 102 // * 0 1 2 3 4 5- shards till epoch 102
// * \ / \ / | | // * \ / \ / | |
// * 6 7 4 5- shards from epoch 103 - 205 // * 6 7 4 5- shards from epoch 103 - 205
// * \ / | /\ // * \ / | /\
// * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber) // * 8 4 9 10 - shards from epoch 206 (open - no ending sequenceNumber)
// * Current leases: (4, 5, 7) // * Current leases: (4, 5, 7)
// */ // */
@Test @Test
@ -1148,11 +1148,11 @@ public class HierarchicalShardSyncerTest {
// /* // /*
// * Helper method to construct a shard list for graph B. Graph B is defined below. // * Helper method to construct a shard list for graph B. Graph B is defined below.
// * Shard structure (x-axis is epochs): // * Shard structure (x-axis is epochs):
// * 0 3 6 9 // * 0 3 6 9
// * \ / \ / \ / // * \ / \ / \ /
// * 2 5 8 // * 2 5 8
// * / \ / \ / \ // * / \ / \ / \
// * 1 4 7 10 // * 1 4 7 10
// */ // */
private List<Shard> constructShardListForGraphB() { private List<Shard> constructShardListForGraphB() {
final SequenceNumberRange range0 = ShardObjectHelper.newSequenceNumberRange("1000", "1049"); final SequenceNumberRange range0 = ShardObjectHelper.newSequenceNumberRange("1000", "1049");