diff options
| author |   Enrique Saurez <esaurez@gatech.edu> | 2019-01-26 22:51:56 -0500 |
|---|---|---|
| committer |   Enrique Saurez <enrique.saurez@gmail.com> | 2019-01-29 14:20:49 -0500 |
| commit | 2a4f867f4e6b8c896124958885119475eee1cbb0 (patch) | |
| tree | 278c7be22759c8b37be2b2f6bb52d38475e67a51 /mdbc-server/src/test | |
| parent | b357ddb0869c2cc44eb0bd5800ed66914f49c468 (diff) | |
Keyspace creation, and handling of mdbc_cuid
Issue-ID: MUSIC-281
Signed-off-by: Enrique Saurez<enrique.saurez@gmail.com>
Change-Id: I3bc685e30e064c1c93386301385115632b179449
Diffstat (limited to 'mdbc-server/src/test')
| -rw-r--r-- | mdbc-server/src/test/java/org/onap/music/mdbc/ownership/DagTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/mdbc-server/src/test/java/org/onap/music/mdbc/ownership/DagTest.java b/mdbc-server/src/test/java/org/onap/music/mdbc/ownership/DagTest.java index 85e31cd..da64595 100644 --- a/mdbc-server/src/test/java/org/onap/music/mdbc/ownership/DagTest.java +++ b/mdbc-server/src/test/java/org/onap/music/mdbc/ownership/DagTest.java @@ -34,6 +34,7 @@ import org.onap.music.exceptions.MDBCServiceException; import org.onap.music.mdbc.DatabasePartition; import org.onap.music.mdbc.MDBCUtils; import org.onap.music.mdbc.Range; +import org.onap.music.mdbc.tables.MriReference; import org.onap.music.mdbc.tables.MusicRangeInformationRow; import org.onap.music.mdbc.tables.MusicTxDigestId; @@ -191,7 +192,7 @@ public class DagTest { @Test public void nextToApply2() throws InterruptedException, MDBCServiceException { - Map<Range, Pair<MusicRangeInformationRow, Integer>> alreadyApplied = new HashMap<>(); + Map<Range, Pair<MriReference, Integer>> alreadyApplied = new HashMap<>(); List<MusicRangeInformationRow> rows = new ArrayList<>(); List<Range> ranges = new ArrayList<>( Arrays.asList( new Range("range1") @@ -206,7 +207,7 @@ public class DagTest { new MusicTxDigestId(MDBCUtils.generateUniqueKey(),1) )); MusicRangeInformationRow newRow = createNewRow(new ArrayList<>(ranges), "", false, redo2); - alreadyApplied.put(new Range("range1"),Pair.of(newRow, 0)); + alreadyApplied.put(new Range("range1"),Pair.of(new MriReference(newRow.getPartitionIndex()), 0)); rows.add(newRow); MILLISECONDS.sleep(10); List<MusicTxDigestId> redo3 = new ArrayList<>(Arrays.asList( |