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 2015/09/29 19:49:36 UTC
[09/14] incubator-tinkerpop git commit: remvoved uneeded comment
about Spark 1.3 and registering classes. With GryoSerializer,
this is all handled now.
remvoved uneeded comment about Spark 1.3 and registering classes. With GryoSerializer, this is all handled now.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/b4a009c7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/b4a009c7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/b4a009c7
Branch: refs/heads/master
Commit: b4a009c799527386be94c669be9dce9064845f85
Parents: 0ca7363
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Mon Sep 28 16:55:14 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Mon Sep 28 16:55:14 2015 -0600
----------------------------------------------------------------------
.../gremlin/spark/process/computer/SparkGraphComputer.java | 8 --------
1 file changed, 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/b4a009c7/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
----------------------------------------------------------------------
diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
index be5c19e..99a07ba 100644
--- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
+++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
@@ -97,14 +97,6 @@ public final class SparkGraphComputer extends AbstractHadoopGraphComputer {
// wire up a spark context
final SparkConf sparkConfiguration = new SparkConf();
sparkConfiguration.setAppName(Constants.GREMLIN_HADOOP_SPARK_JOB_PREFIX + (null == this.vertexProgram ? "No VertexProgram" : this.vertexProgram) + "[" + this.mapReducers + "]");
- /*final List<Class> classes = new ArrayList<>();
- classes.addAll(IOClasses.getGryoClasses(GryoMapper.build().create()));
- classes.addAll(IOClasses.getSharedHadoopClasses());
- classes.add(ViewPayload.class);
- classes.add(MessagePayload.class);
- classes.add(ViewIncomingPayload.class);
- classes.add(ViewOutgoingPayload.class);
- sparkConfiguration.registerKryoClasses(classes.toArray(new Class[classes.size()]));*/ // TODO: fix for user submitted jars in Spark 1.3.0
// create the spark configuration from the graph computer configuration
hadoopConfiguration.forEach(entry -> sparkConfiguration.set(entry.getKey(), entry.getValue()));