Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Drill >> mail # dev >> [09/24] git commit: status changes


Copy link to this message
-
[09/24] git commit: status changes
status changes
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/5472140a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/5472140a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/5472140a

Branch: refs/heads/diagnostics2
Commit: 5472140ab228376ed6e205e60edec473771b9dba
Parents: 73d3bd0
Author: Jacques Nadeau <[EMAIL PROTECTED]>
Authored: Mon May 19 07:57:25 2014 -0700
Committer: Jacques Nadeau <[EMAIL PROTECTED]>
Committed: Mon May 19 09:12:09 2014 -0700

 .../org/apache/drill/common/types/Types.java    |    5 +-
 exec/java-exec/pom.xml                          |   58 +-
 .../apache/drill/exec/client/DrillClient.java   |    2 +-
 .../drill/exec/client/QuerySubmitter.java       |   10 +-
 .../apache/drill/exec/ops/FragmentStats.java    |   37 +-
 .../org/apache/drill/exec/ops/MetricDef.java    |    6 +
 .../org/apache/drill/exec/ops/OpProfileDef.java |   20 +
 .../apache/drill/exec/ops/OperatorContext.java  |   25 +
 .../apache/drill/exec/ops/OperatorStats.java    |  117 +-
 .../exec/physical/base/AbstractExchange.java    |   12 +-
 .../exec/physical/base/AbstractGroupScan.java   |    4 +
 .../exec/physical/base/PhysicalOperator.java    |    3 +
 .../exec/physical/config/BroadcastSender.java   |    9 +
 .../exec/physical/config/ExternalSort.java      |   19 +-
 .../drill/exec/physical/config/Filter.java      |   13 +-
 .../exec/physical/config/HashAggregate.java     |   30 +-
 .../drill/exec/physical/config/HashJoinPOP.java |    8 +-
 .../physical/config/HashPartitionSender.java    |    9 +-
 .../exec/physical/config/IteratorValidator.java |    7 +-
 .../drill/exec/physical/config/Limit.java       |    5 +
 .../exec/physical/config/MergeJoinPOP.java      |    6 +
 .../physical/config/MergingReceiverPOP.java     |    5 +
 .../physical/config/OrderedPartitionSender.java |    9 +-
 .../drill/exec/physical/config/Project.java     |   12 +-
 .../exec/physical/config/RandomReceiver.java    |   14 +-
 .../drill/exec/physical/config/RangeSender.java |   10 +-
 .../drill/exec/physical/config/Screen.java      |    7 +-
 .../physical/config/SelectionVectorRemover.java |    8 +-
 .../exec/physical/config/SingleSender.java      |   13 +-
 .../apache/drill/exec/physical/config/Sort.java |   20 +-
 .../physical/config/StreamingAggregate.java     |   13 +-
 .../apache/drill/exec/physical/config/TopN.java |   18 +-
 .../drill/exec/physical/config/Trace.java       |    6 +
 .../drill/exec/physical/config/Union.java       |    6 +
 .../exec/physical/impl/WriterRecordBatch.java   |  153 +-
 .../physical/impl/aggregate/HashAggBatch.java   |  126 +-
 .../impl/aggregate/StreamingAggBatch.java       |  141 +-
 .../exec/physical/impl/join/HashJoinBatch.java  |   46 +-
 .../exec/physical/impl/join/JoinStatus.java     |   19 +-
 .../exec/physical/impl/join/MergeJoinBatch.java |   81 +-
 .../impl/mergereceiver/MergingRecordBatch.java  |   50 +-
 .../OrderedPartitionRecordBatch.java            |  173 +-
 .../drill/exec/record/AbstractRecordBatch.java  |   27 +-
 .../exec/record/AbstractSingleRecordBatch.java  |   68 +-
 .../org/apache/drill/exec/server/Drillbit.java  |   20 +-
 .../exec/store/dfs/easy/EasyFormatPlugin.java   |   16 +-
 .../drill/exec/store/dfs/easy/EasySubScan.java  |   17 +-
 .../drill/exec/store/dfs/easy/EasyWriter.java   |    5 +
 .../drill/exec/store/direct/DirectSubScan.java  |    7 +
 .../exec/store/easy/json/JSONFormatPlugin.java  |   14 +
 .../exec/store/easy/text/TextFormatPlugin.java  |   15 +-
 .../drill/exec/store/hive/HiveSubScan.java      |    7 +
 .../exec/store/ischema/InfoSchemaSubScan.java   |   13 +-
 .../drill/exec/store/mock/MockStorePOP.java     |    8 +-
 .../drill/exec/store/mock/MockSubScanPOP.java   |    8 +-
 .../exec/store/parquet/ParquetRowGroupScan.java |    6 +
 .../drill/exec/store/parquet/ParquetWriter.java |    8 +
 .../apache/drill/exec/work/foreman/Foreman.java |    4 +-
 .../drill/exec/work/foreman/FragmentData.java   |   43 +
 .../drill/exec/work/foreman/QueryManager.java   |  106 +-
 .../drill/exec/work/foreman/QueryStatus.java    |   33 +
 .../exec/physical/impl/PerformanceTests.java    |   31 -
 .../physical/impl/TestBroadcastExchange.java    |   19 +-
 .../impl/TestExecutionAbstractions.java         |  225 -
 .../drill/exec/server/DrillClientFactory.java   |   21 +
 .../apache/drill/exec/server/HelloResource.java |   22 +
 .../apache/drill/exec/server/TestJersey.java    |   48 +
 .../drill/exec/server/rest/RootResource.java    |    9 +
 exec/java-exec/src/test/resources/logback.xml   |    2 +-
 .../org/apache/drill/jdbc/DrillResultSet.java   |   26 +-
 .../apache/drill/common/types/TypeProtos.java   |  117 +-
 .../org/apache/drill/exec/proto/BitControl.java |  245 +-
 .../apache/drill/exec/proto/UserBitShared.java  | 6290 +++++++++++++++++-
 .../org/apache/drill/exec/proto/UserProtos.java |  184 +-
 protocol/src/main/protobuf/BitControl.proto     |    1 +
 protocol/src/main/protobuf/User.proto           |    8 +-
 protocol/src/main/protobuf/UserBitShared.proto  |   88 +
 77 files changed, 7963 insertions(+), 1133 deletions(-)
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/5472140a/common/src/main/java/org/apache/drill/common/types/Types.java
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 5d0812f..8a826b1 100644
+++ b/common/src/main/java/org/apache/drill/common/types/Types.java
@@ -113,8 +113,6 @@ public class Types {
     case INTERVALYEAR:
     case INTERVALDAY:
     case LATE:
-    case REPEATMAP:
-      return java.sql.Types.OTHER;
     case SMALLINT:
       return java.sql.Types.SMALLINT;
     case TIME:
@@ -226,7 +224,6 @@ public class Types {
     case LATE:
       return Comparability.UNKNOWN;
     case MAP:
-    case REPEATMAP:
       return Comparability.NONE;
     case BIT:
       return Comparability.EQUAL;
@@