You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2016/01/21 03:26:11 UTC
incubator-tinkerpop git commit: registered CompactBuffer[].class ---
required for CoGroupRDD in SparkServer.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master ce8925b21 -> 1a8e799d3
registered CompactBuffer[].class --- required for CoGroupRDD in SparkServer.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/1a8e799d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/1a8e799d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/1a8e799d
Branch: refs/heads/master
Commit: 1a8e799d3ddba9831cc7404dccd8ee4f07ecfb10
Parents: ce8925b
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Jan 20 19:26:16 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Jan 20 19:26:16 2016 -0700
----------------------------------------------------------------------
.../tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/1a8e799d/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java
----------------------------------------------------------------------
diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java
index 29fde9f..564d9d7 100644
--- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java
+++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/structure/io/gryo/GryoSerializer.java
@@ -31,6 +31,7 @@ import org.apache.spark.scheduler.CompressedMapStatus;
import org.apache.spark.serializer.Serializer;
import org.apache.spark.serializer.SerializerInstance;
import org.apache.spark.util.SerializableConfiguration;
+import org.apache.spark.util.collection.CompactBuffer;
import org.apache.tinkerpop.gremlin.hadoop.structure.io.ObjectWritable;
import org.apache.tinkerpop.gremlin.hadoop.structure.io.VertexWritable;
import org.apache.tinkerpop.gremlin.spark.process.computer.payload.MessagePayload;
@@ -84,6 +85,8 @@ public final class GryoSerializer extends Serializer {
.addCustom(Tuple2[].class, new JavaSerializer())
.addCustom(Tuple3.class, new JavaSerializer())
.addCustom(Tuple3[].class, new JavaSerializer())
+ .addCustom(CompactBuffer.class, new JavaSerializer())
+ .addCustom(CompactBuffer[].class, new JavaSerializer())
.addCustom(CompressedMapStatus.class, new JavaSerializer())
.addCustom(HttpBroadcast.class, new JavaSerializer())
.addCustom(PythonBroadcast.class, new JavaSerializer())