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

Switch to Threaded View
Drill, mail # dev - [11/24] git commit: ispan


Copy link to this message
-
[11/24] git commit: ispan
jacques@... 2014-05-22, 01:14
ispan
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/8621b682
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/8621b682
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/8621b682

Branch: refs/heads/diagnostics2
Commit: 8621b682cae0f8c8f58ff2e5b750544113bf52ee
Parents: 5472140
Author: Jacques Nadeau <[EMAIL PROTECTED]>
Authored: Sun May 4 16:58:41 2014 -0700
Committer: Jacques Nadeau <[EMAIL PROTECTED]>
Committed: Mon May 19 09:12:27 2014 -0700

 exec/java-exec/pom.xml                          |  10 +
 .../exec/cache/AbstractDataSerializable.java    |  33 ++
 .../exec/cache/AbstractStreamSerializable.java  |  34 ++
 .../drill/exec/cache/CachedVectorContainer.java |  77 +++++
 .../drill/exec/cache/DistributedCache.java      |   4 +-
 .../drill/exec/cache/DrillSerializable.java     |  17 +-
 .../cache/HCVectorAccessibleSerializer.java     |  56 ----
 .../org/apache/drill/exec/cache/HazelCache.java | 252 ---------------
 .../exec/cache/JacksonDrillSerializable.java    |  48 +--
 .../org/apache/drill/exec/cache/LocalCache.java | 305 ------------------
 .../cache/LoopedAbstractDrillSerializable.java  |  80 +++++
 .../apache/drill/exec/cache/ProtoBufImpl.java   |  49 ---
 .../apache/drill/exec/cache/ProtoBufWrap.java   |  67 ----
 .../org/apache/drill/exec/cache/ProtoMap.java   |  52 ----
 .../drill/exec/cache/ProtoSerializable.java     |  65 ++++
 .../cache/VectorAccessibleSerializable.java     |  22 +-
 .../hazel/HCVectorAccessibleSerializer.java     |  58 ++++
 .../drill/exec/cache/hazel/HazelCache.java      | 258 ++++++++++++++++
 .../drill/exec/cache/hazel/ProtoBufImpl.java    |  49 +++
 .../drill/exec/cache/hazel/ProtoBufWrap.java    |  67 ++++
 .../apache/drill/exec/cache/hazel/ProtoMap.java |  52 ++++
 .../drill/exec/cache/infinispan/ICache.java     | 266 ++++++++++++++++
 .../infinispan/VAAdvancedExternalizer.java      |  72 +++++
 .../cache/infinispan/ZookeeperCacheStore.java   |  66 ++++
 .../drill/exec/cache/local/LocalCache.java      | 309 +++++++++++++++++++
 .../OrderedPartitionRecordBatch.java            |  20 +-
 .../org/apache/drill/exec/server/Drillbit.java  |   2 +-
 .../drill/exec/server/RemoteServiceSet.java     |  17 +-
 .../java/org/apache/drill/PlanningBase.java     |   2 +-
 .../java/org/apache/drill/exec/cache/ISpan.java |  94 ++++++
 .../drill/exec/cache/TestVectorCache.java       | 136 +++++---
 .../drill/exec/store/TestOrphanSchema.java      |   2 +-
 .../drill/exec/store/ischema/OrphanSchema.java  |   9 +-
 33 files changed, 1750 insertions(+), 900 deletions(-)
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/8621b682/exec/java-exec/pom.xml
diff --git a/exec/java-exec/pom.xml b/exec/java-exec/pom.xml
index d693630..6d11614 100644
+++ b/exec/java-exec/pom.xml
@@ -224,6 +224,16 @@
       <version>3.1.4</version>
     </dependency>
     <dependency>
+      <groupId>org.infinispan</groupId>
+      <artifactId>infinispan-core</artifactId>
+      <version>6.0.1.Final</version>
+    </dependency>
+    <dependency>
+      <groupId>org.infinispan</groupId>
+      <artifactId>infinispan-tree</artifactId>
+      <version>6.0.1.Final</version>
+    </dependency>
+    <dependency>
       <groupId>org.codehaus.janino</groupId>
       <artifactId>janino</artifactId>
       <version>2.6.1</version>

http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/8621b682/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractDataSerializable.java
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractDataSerializable.java b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractDataSerializable.java
new file mode 100644
index 0000000..f7b9eed
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractDataSerializable.java
@@ -0,0 +1,33 @@
+/**
+ * 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.cache;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+
+public abstract class AbstractDataSerializable extends LoopedAbstractDrillSerializable{
+  static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(AbstractDataSerializable.class);
+
+  @Override
+  public abstract void read(DataInput input) throws IOException;
+
+  @Override
+  public abstract void write(DataOutput output) throws IOException;
+
+}

http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/8621b682/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractStreamSerializable.java
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractStreamSerializable.java b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractStreamSerializable.java
new file mode 100644
index 0000000..ef488d6
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/cache/AbstractStreamSerializable.java
@@ -0,0 +1,34 @@
+/**
+ * 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 unde