diff --git a/src/main/java/io/airlift/tpch/CustomerColumn.java b/src/main/java/io/airlift/tpch/CustomerColumn.java
index b17708d..3e81294 100644
--- a/src/main/java/io/airlift/tpch/CustomerColumn.java
+++ b/src/main/java/io/airlift/tpch/CustomerColumn.java
@@ -14,7 +14,7 @@
 package io.airlift.tpch;
 
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
 public enum CustomerColumn
@@ -60,7 +60,7 @@ public String getString(Customer customer)
                 }
             },
 
-    ACCOUNT_BALANCE("c_acctbal", DOUBLE)
+    ACCOUNT_BALANCE("c_acctbal", DECIMAL)
             {
                 public double getDouble(Customer customer)
                 {
diff --git a/src/main/java/io/airlift/tpch/LineItemColumn.java b/src/main/java/io/airlift/tpch/LineItemColumn.java
index b2480b0..8d90795 100644
--- a/src/main/java/io/airlift/tpch/LineItemColumn.java
+++ b/src/main/java/io/airlift/tpch/LineItemColumn.java
@@ -16,7 +16,7 @@
 import static io.airlift.tpch.GenerateUtils.formatDate;
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
 import static io.airlift.tpch.TpchColumnTypes.DATE;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.INTEGER;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
@@ -59,7 +59,7 @@ public int getInteger(LineItem lineItem)
                 }
             },
 
-    QUANTITY("l_quantity", DOUBLE)
+    QUANTITY("l_quantity", DECIMAL)
             {
                 public double getDouble(LineItem lineItem)
                 {
@@ -73,7 +73,7 @@ public long getIdentifier(LineItem lineItem)
             },
 
     @SuppressWarnings("SpellCheckingInspection")
-    EXTENDED_PRICE("l_extendedprice", DOUBLE)
+    EXTENDED_PRICE("l_extendedprice", DECIMAL)
             {
                 public double getDouble(LineItem lineItem)
                 {
@@ -86,7 +86,7 @@ public long getIdentifier(LineItem lineItem)
                 }
             },
 
-    DISCOUNT("l_discount", DOUBLE)
+    DISCOUNT("l_discount", DECIMAL)
             {
                 public double getDouble(LineItem lineItem)
                 {
@@ -99,7 +99,7 @@ public long getIdentifier(LineItem lineItem)
                 }
             },
 
-    TAX("l_tax", DOUBLE)
+    TAX("l_tax", DECIMAL)
             {
                 public double getDouble(LineItem lineItem)
                 {
diff --git a/src/main/java/io/airlift/tpch/OrderColumn.java b/src/main/java/io/airlift/tpch/OrderColumn.java
index 936b64e..529994a 100644
--- a/src/main/java/io/airlift/tpch/OrderColumn.java
+++ b/src/main/java/io/airlift/tpch/OrderColumn.java
@@ -16,7 +16,7 @@
 import static io.airlift.tpch.GenerateUtils.formatDate;
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
 import static io.airlift.tpch.TpchColumnTypes.DATE;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.INTEGER;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
@@ -51,7 +51,7 @@ public String getString(Order order)
             },
 
     @SuppressWarnings("SpellCheckingInspection")
-    TOTAL_PRICE("o_totalprice", DOUBLE)
+    TOTAL_PRICE("o_totalprice", DECIMAL)
             {
                 public double getDouble(Order order)
                 {
diff --git a/src/main/java/io/airlift/tpch/PartColumn.java b/src/main/java/io/airlift/tpch/PartColumn.java
index 646f810..4ff8438 100644
--- a/src/main/java/io/airlift/tpch/PartColumn.java
+++ b/src/main/java/io/airlift/tpch/PartColumn.java
@@ -14,7 +14,7 @@
 package io.airlift.tpch;
 
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.INTEGER;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
@@ -79,7 +79,7 @@ public String getString(Part part)
             },
 
     @SuppressWarnings("SpellCheckingInspection")
-    RETAIL_PRICE("p_retailprice", DOUBLE)
+    RETAIL_PRICE("p_retailprice", DECIMAL)
             {
                 public double getDouble(Part part)
                 {
diff --git a/src/main/java/io/airlift/tpch/PartSupplierColumn.java b/src/main/java/io/airlift/tpch/PartSupplierColumn.java
index 0befc6c..7cf8e47 100644
--- a/src/main/java/io/airlift/tpch/PartSupplierColumn.java
+++ b/src/main/java/io/airlift/tpch/PartSupplierColumn.java
@@ -14,7 +14,7 @@
 package io.airlift.tpch;
 
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.INTEGER;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
@@ -49,7 +49,7 @@ public int getInteger(PartSupplier partSupplier)
             },
 
     @SuppressWarnings("SpellCheckingInspection")
-    SUPPLY_COST("ps_supplycost", DOUBLE)
+    SUPPLY_COST("ps_supplycost", DECIMAL)
             {
                 public double getDouble(PartSupplier partSupplier)
                 {
diff --git a/src/main/java/io/airlift/tpch/SupplierColumn.java b/src/main/java/io/airlift/tpch/SupplierColumn.java
index 0999746..59cfcea 100644
--- a/src/main/java/io/airlift/tpch/SupplierColumn.java
+++ b/src/main/java/io/airlift/tpch/SupplierColumn.java
@@ -14,7 +14,7 @@
 package io.airlift.tpch;
 
 import static io.airlift.tpch.TpchColumnTypes.IDENTIFIER;
-import static io.airlift.tpch.TpchColumnTypes.DOUBLE;
+import static io.airlift.tpch.TpchColumnTypes.DECIMAL;
 import static io.airlift.tpch.TpchColumnTypes.varchar;
 
 public enum SupplierColumn
@@ -63,7 +63,7 @@ public String getString(Supplier supplier)
             },
 
     @SuppressWarnings("SpellCheckingInspection")
-    ACCOUNT_BALANCE("s_acctbal", DOUBLE)
+    ACCOUNT_BALANCE("s_acctbal", DECIMAL)
             {
                 public double getDouble(Supplier supplier)
                 {
diff --git a/src/main/java/io/airlift/tpch/TpchColumnType.java b/src/main/java/io/airlift/tpch/TpchColumnType.java
index e9fe1a3..21d60a5 100644
--- a/src/main/java/io/airlift/tpch/TpchColumnType.java
+++ b/src/main/java/io/airlift/tpch/TpchColumnType.java
@@ -23,7 +23,7 @@ public enum Base {
         INTEGER,
         IDENTIFIER,
         DATE,
-        DOUBLE,
+        DECIMAL,
         VARCHAR
     }
 
diff --git a/src/main/java/io/airlift/tpch/TpchColumnTypes.java b/src/main/java/io/airlift/tpch/TpchColumnTypes.java
index 22b8da6..96fcf2c 100644
--- a/src/main/java/io/airlift/tpch/TpchColumnTypes.java
+++ b/src/main/java/io/airlift/tpch/TpchColumnTypes.java
@@ -20,7 +20,7 @@ private TpchColumnTypes() {}
     public static final TpchColumnType INTEGER = new TpchColumnType(TpchColumnType.Base.INTEGER);
     public static final TpchColumnType IDENTIFIER = new TpchColumnType(TpchColumnType.Base.IDENTIFIER);
     public static final TpchColumnType DATE = new TpchColumnType(TpchColumnType.Base.DATE);
-    public static final TpchColumnType DOUBLE = new TpchColumnType(TpchColumnType.Base.DOUBLE);
+    public static final TpchColumnType DECIMAL = new TpchColumnType(TpchColumnType.Base.DECIMAL);
 
     public static TpchColumnType varchar(long precision) {
         return new TpchColumnType(TpchColumnType.Base.VARCHAR, precision);