fix upstream decoder to line up with flatten data (#48)

ldbc · Oct 16, 2024 · f78e332 · f78e332
1 parent 63d7dec
commit f78e332
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...in/java/org/ldbcouncil/finbench/driver/workloads/transaction/UpdateEventStreamReader.java b/...in/java/org/ldbcouncil/finbench/driver/workloads/transaction/UpdateEventStreamReader.java
@@ -817,12 +817,12 @@ public Operation decodeEvent(ResultSet rs) throws WorkloadException {
                 long dstId = rs.getLong(4);
                 Date currentTime = new Date(scheduledStartTimeAsMilli);
                 long amt = rs.getLong(5);
-                double amountThreshold = rs.getDouble(14);
                 Date startTime = new Date(rs.getLong(10));
                 Date endTime = new Date(rs.getLong(11));
-                float ratioThreshold = rs.getFloat(15);
                 int truncationLimit = rs.getInt(12);
                 TruncationOrder truncationOrder = TruncationOrder.valueOf(rs.getString(13));
+                double amountThreshold = rs.getDouble(14);
+                float ratioThreshold = rs.getFloat(15);
 
                 Operation operation = new ReadWrite2(
                     srcId,
@@ -859,11 +859,11 @@ public Operation decodeEvent(ResultSet rs) throws WorkloadException {
                 long srcId = rs.getLong(3);
                 long dstId = rs.getLong(4);
                 Date currentTime = new Date(scheduledStartTimeAsMilli);
-                double threshold = rs.getDouble(10);
-                Date startTime = new Date(rs.getLong(6));
-                Date endTime = new Date(rs.getLong(7));
-                int truncationLimit = rs.getInt(8);
-                TruncationOrder truncationOrder = TruncationOrder.valueOf(rs.getString(9));
+                Date startTime = new Date(rs.getLong(7));
+                Date endTime = new Date(rs.getLong(8));
+                int truncationLimit = rs.getInt(9);
+                TruncationOrder truncationOrder = TruncationOrder.valueOf(rs.getString(10));
+                double threshold = rs.getDouble(11);
 
                 Operation operation = new ReadWrite3(
                     srcId,