diff --git a/src/main/java/io/airlift/tpch/LineItem.java b/src/main/java/io/airlift/tpch/LineItem.java index 3026e17..52d5c53 100644 --- a/src/main/java/io/airlift/tpch/LineItem.java +++ b/src/main/java/io/airlift/tpch/LineItem.java @@ -102,11 +102,16 @@ public long getLineNumber() return lineNumber; } - public long getQuantity() + public double getQuantity() { return quantity; } + public long getQuantityUnscaled() + { + return quantity * 100; + } + public double getExtendedPrice() { return extendedPrice / 100.0; diff --git a/src/main/java/io/airlift/tpch/LineItemColumn.java b/src/main/java/io/airlift/tpch/LineItemColumn.java index 4bde5bf..7ac242e 100644 --- a/src/main/java/io/airlift/tpch/LineItemColumn.java +++ b/src/main/java/io/airlift/tpch/LineItemColumn.java @@ -58,12 +58,17 @@ public long getLong(LineItem lineItem) } }, - QUANTITY("quantity", BIGINT) + QUANTITY("quantity", DOUBLE) { - public long getLong(LineItem lineItem) + public double getDouble(LineItem lineItem) { return lineItem.getQuantity(); } + + public long getLong(LineItem lineItem) + { + return lineItem.getQuantityUnscaled(); + } }, @SuppressWarnings("SpellCheckingInspection")