DRILL-357: Hive Storage Engine phase 2 - hive record reader

1 files changed, 0 insertions, 93 deletions

diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/util/BatchPrinter.java b/exec/java-exec/src/test/java/org/apache/drill/exec/util/BatchPrinter.java
deleted file mode 100644
index aa68752b7..000000000
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/util/BatchPrinter.java
+++ /dev/null
@@ -1,93 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.drill.exec.util;
-
-import com.beust.jcommander.internal.Lists;
-import org.apache.commons.lang.StringUtils;
-import org.apache.drill.exec.exception.SchemaChangeException;
-import org.apache.drill.exec.record.VectorAccessible;
-import org.apache.drill.exec.record.VectorWrapper;
-import org.apache.drill.exec.record.selection.SelectionVector4;
-import org.apache.drill.exec.rpc.RpcException;
-import org.apache.drill.exec.vector.ValueVector;
-
-import java.util.List;
-
-/**
- * This is a tool for printing the content of record batches to screen. Used for debugging.
- */
-public class BatchPrinter {
-  public static void printHyperBatch(VectorAccessible batch) {
-    List<String> columns = Lists.newArrayList();
-    List<ValueVector> vectors = Lists.newArrayList();
-    int numBatches = 0;
-    for (VectorWrapper vw : batch) {
-      columns.add(vw.getValueVectors()[0].getField().getName());
-      numBatches = vw.getValueVectors().length;
-    }
-    int width = columns.size();
-      for (int i = 0; i < numBatches; i++) {
-        int rows = batch.iterator().next().getValueVectors()[i].getMetadata().getValueCount();
-        for (int j = 0; j < rows; j++) {
-          for (VectorWrapper vw : batch) {
-            Object o = vw.getValueVectors()[i].getAccessor().getObject(j);
-            if (o instanceof byte[]) {
-              String value = new String((byte[]) o);
-              System.out.printf("| %-15s",value.length() <= 15 ? value : value.substring(0, 14));
-            } else {
-              String value = o.toString();
-              System.out.printf("| %-15s",value.length() <= 15 ? value : value.substring(0,14));
-            }
-          }
-          System.out.printf("|\n");
-        }
-      }
-      System.out.printf("|\n");
-  }
-  public static void printBatch(VectorAccessible batch) {
-    List<String> columns = Lists.newArrayList();
-    List<ValueVector> vectors = Lists.newArrayList();
-    for (VectorWrapper vw : batch) {
-      columns.add(vw.getValueVector().getField().getName());
-      vectors.add(vw.getValueVector());
-    }
-    int width = columns.size();
-    int rows = vectors.get(0).getMetadata().getValueCount();
-    for (int row = 0; row < rows; row++) {
-      if (row%50 == 0) {
-        System.out.println(StringUtils.repeat("-", width * 17 + 1));
-        for (String column : columns) {
-          System.out.printf("| %-15s", width <= 15 ? column : column.substring(0, 14));
-        }
-        System.out.printf("|\n");
-        System.out.println(StringUtils.repeat("-", width*17 + 1));
-      }
-      for (ValueVector vv : vectors) {
-        Object o = vv.getAccessor().getObject(row);
-        if (o instanceof byte[]) {
-          String value = new String((byte[]) o);
-          System.out.printf("| %-15s",value.length() <= 15 ? value : value.substring(0, 14));
-        } else {
-          String value = o.toString();
-          System.out.printf("| %-15s",value.length() <= 15 ? value : value.substring(0,14));
-        }
-      }
-      System.out.printf("|\n");
-    }
-  }
-}