DRILL-694: Implement parquet writer.

Enable "CREATE TABLE AS" with parquet as the output format.

Add decimal metadata support to parquet reader and writer.

2 files changed, 13 insertions, 2 deletions

diff --git a/common/src/main/java/org/apache/drill/common/types/Types.java b/common/src/main/java/org/apache/drill/common/types/Types.java
index c6ac82e68..a6ec29b57 100644
--- a/common/src/main/java/org/apache/drill/common/types/Types.java
+++ b/common/src/main/java/org/apache/drill/common/types/Types.java
@@ -271,6 +271,10 @@ public class Types {
     return MajorType.newBuilder().setMode(mode).setMinorType(type).build();
   }
 
+  public static MajorType withScaleAndPrecision(MinorType type, DataMode mode, int scale, int precision) {
+    return MajorType.newBuilder().setMinorType(type).setMode(mode).setScale(scale).setPrecision(precision).build();
+  }
+  
   public static MajorType required(MinorType type){
     return MajorType.newBuilder().setMode(DataMode.REQUIRED).setMinorType(type).build();
   }
diff --git a/common/src/main/java/org/apache/drill/common/util/DecimalUtility.java b/common/src/main/java/org/apache/drill/common/util/DecimalUtility.java
index dbfd6ac96..0cacc59d3 100644
--- a/common/src/main/java/org/apache/drill/common/util/DecimalUtility.java
+++ b/common/src/main/java/org/apache/drill/common/util/DecimalUtility.java
@@ -17,8 +17,7 @@
  */
 package org.apache.drill.common.util;
 
-import java.math.BigDecimal;
-import java.math.BigInteger;
+import java.math.*;
 
 
 import io.netty.buffer.Unpooled;
@@ -26,6 +25,7 @@ import io.netty.buffer.ByteBuf;
 
 import java.math.BigDecimal;
 import java.math.BigInteger;
+import java.util.Arrays;
 
 public class DecimalUtility {
 
@@ -486,5 +486,12 @@ public class DecimalUtility {
       return 0;
     }
 
+
+    public static BigDecimal getBigDecimalFromByteArray(byte[] bytes, int start, int length, int scale) {
+      byte[] value = Arrays.copyOfRange(bytes, start, start + length);
+      BigInteger unscaledValue = new BigInteger(value);
+      return new BigDecimal(unscaledValue, scale);
+    }
+
 }