You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2015/06/29 17:55:18 UTC
[12/13] incubator-tinkerpop git commit: Add serializer option to
profiler for driver.
Add serializer option to profiler for driver.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/c33468cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/c33468cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/c33468cb
Branch: refs/heads/resultset-refactor
Commit: c33468cb7d51900a0bd1f59050af31bd4242ddda
Parents: 26ba949
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Mon Jun 29 11:53:31 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Mon Jun 29 11:53:31 2015 -0400
----------------------------------------------------------------------
.../tinkerpop/gremlin/driver/util/ProfilingApplication.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/c33468cb/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
----------------------------------------------------------------------
diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
index e1db5c2..0ae00ac 100644
--- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
+++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
@@ -22,6 +22,7 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
import org.apache.tinkerpop.gremlin.driver.Client;
import org.apache.tinkerpop.gremlin.driver.Cluster;
+import org.apache.tinkerpop.gremlin.driver.ser.Serializers;
import org.apache.tinkerpop.gremlin.structure.util.ElementHelper;
import java.io.BufferedWriter;
@@ -127,6 +128,7 @@ public class ProfilingApplication {
final int minInProcessPerConnection = Integer.parseInt(options.getOrDefault("minInProcessPerConnection", "16").toString());
final int workerPoolSize = Integer.parseInt(options.getOrDefault("workerPoolSize", "2").toString());
final int tooSlowThreshold = Integer.parseInt(options.getOrDefault("tooSlowThreshold", "125").toString());
+ final String serializer = options.getOrDefault("serializer", Serializers.GRYO_V1D0.getValue()).toString();
final String script = options.getOrDefault("script", "1+1").toString();
@@ -138,6 +140,7 @@ public class ProfilingApplication {
.minInProcessPerConnection(minInProcessPerConnection)
.maxInProcessPerConnection(maxInProcessPerConnection)
.nioPoolSize(nioPoolSize)
+ .serializer(Serializers.valueOf(serializer))
.workerPoolSize(workerPoolSize).create();
try {