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/04/20 14:30:47 UTC
incubator-tinkerpop git commit: Centralized creation of Io.Builder
instances in IoTest.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/refactor-io 6ffd5b4ce -> 4d8c43843
Centralized creation of Io.Builder instances in IoTest.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/4d8c4384
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/4d8c4384
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/4d8c4384
Branch: refs/heads/refactor-io
Commit: 4d8c4384300289588ce61b9b8094205d052f25f3
Parents: 6ffd5b4
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Mon Apr 20 08:00:41 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Mon Apr 20 08:00:41 2015 -0400
----------------------------------------------------------------------
.../tinkerpop/gremlin/structure/IoTest.java | 217 ++++++++++---------
1 file changed, 115 insertions(+), 102 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/4d8c4384/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/structure/IoTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/structure/IoTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/structure/IoTest.java
index 0b9765a..0efc264 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/structure/IoTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/structure/IoTest.java
@@ -39,6 +39,7 @@ import org.apache.tinkerpop.gremlin.structure.Graph.Features.VertexPropertyFeatu
import org.apache.tinkerpop.gremlin.structure.io.GraphMigrator;
import org.apache.tinkerpop.gremlin.structure.io.GraphReader;
import org.apache.tinkerpop.gremlin.structure.io.GraphWriter;
+import org.apache.tinkerpop.gremlin.structure.io.Io;
import org.apache.tinkerpop.gremlin.structure.io.graphml.GraphMLIo;
import org.apache.tinkerpop.gremlin.structure.io.graphml.GraphMLReader;
import org.apache.tinkerpop.gremlin.structure.io.graphml.GraphMLWriter;
@@ -57,6 +58,7 @@ import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedFactory;
import org.apache.tinkerpop.gremlin.structure.util.detached.DetachedVertex;
import org.apache.tinkerpop.gremlin.util.StreamFactory;
import org.apache.tinkerpop.gremlin.util.iterator.IteratorUtils;
+import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
@@ -104,6 +106,10 @@ public class IoTest extends AbstractGremlinTest {
private static String tempPath;
+ private Io.Builder<GraphMLIo> graphml;
+ private Io.Builder<GraphSONIo> graphson;
+ private Io.Builder<GryoIo> gryo;
+
static {
tempPath = TestHelper.makeTestDataPath(IoTest.class, "iotest").getPath() + File.separator;
}
@@ -115,6 +121,13 @@ public class IoTest extends AbstractGremlinTest {
if (!tempDir.mkdirs()) throw new IOException(String.format("Could not create %s", tempDir));
}
+ @Before
+ public void setupBeforeEachTest() {
+ graphml = GraphMLIo.build();
+ graphson = GraphSONIo.build();
+ gryo = GryoIo.build();
+ }
+
@Test
@FeatureRequirement(featureClass = Graph.Features.EdgeFeatures.class, feature = Graph.Features.EdgeFeatures.FEATURE_ADD_EDGES)
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
@@ -161,11 +174,11 @@ public class IoTest extends AbstractGremlinTest {
public void shouldReadWriteClassicToGraphMLToFileWithHelpers() throws Exception {
final File f = TestHelper.generateTempFile(this.getClass(), name.getMethodName(), ".xml");
try {
- graph.io(GraphMLIo.build()).write(f.getAbsolutePath());
+ graph.io(graphml).write(f.getAbsolutePath());
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.CLASSIC);
final Graph g1 = graphProvider.openTestGraph(configuration);
- g1.io(GraphMLIo.build()).read(f.getAbsolutePath());
+ g1.io(graphml).read(f.getAbsolutePath());
assertClassicGraph(graph, false, true);
@@ -213,8 +226,8 @@ public class IoTest extends AbstractGremlinTest {
@LoadGraphWith(LoadGraphWith.GraphData.CLASSIC)
public void shouldWriteNormalizedGraphSON() throws Exception {
try (ByteArrayOutputStream bos = new ByteArrayOutputStream()) {
- final GraphSONMapper mapper = graph.io(GraphSONIo.build()).mapper().normalize(true).create();
- final GraphSONWriter w = graph.io(GraphSONIo.build()).writer().mapper(mapper).create();
+ final GraphSONMapper mapper = graph.io(graphson).mapper().normalize(true).create();
+ final GraphSONWriter w = graph.io(graphson).writer().mapper(mapper).create();
w.writeGraph(bos, graph);
final String expected = streamToString(IoTest.class.getResourceAsStream(GRAPHSON_RESOURCE_PATH_PREFIX + "tinkerpop-classic-normalized.json"));
@@ -277,8 +290,8 @@ public class IoTest extends AbstractGremlinTest {
final SimpleModule module = new SimpleModule();
module.addSerializer(CustomId.class, new CustomId.CustomIdJacksonSerializer());
- final GraphWriter writer = graph.io(GraphSONIo.build()).writer().mapper(
- graph.io(GraphSONIo.build()).mapper().addCustomModule(module).embedTypes(true).create()).create();
+ final GraphWriter writer = graph.io(graphson).writer().mapper(
+ graph.io(graphson).mapper().addCustomModule(module).embedTypes(true).create()).create();
try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
writer.writeGraph(baos, graph);
@@ -297,8 +310,8 @@ public class IoTest extends AbstractGremlinTest {
final Graph g2 = graphProvider.openTestGraph(configuration);
try (final InputStream is = new ByteArrayInputStream(baos.toByteArray())) {
- final GraphReader reader = graph.io(GraphSONIo.build()).reader()
- .mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).addCustomModule(module).create()).create();
+ final GraphReader reader = graph.io(graphson).reader()
+ .mapper(graph.io(graphson).mapper().embedTypes(true).addCustomModule(module).create()).create();
reader.readGraph(is, g2);
}
@@ -347,8 +360,8 @@ public class IoTest extends AbstractGremlinTest {
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
GraphMigrator.migrateGraph(graph, g1, reader, writer);
@@ -367,8 +380,8 @@ public class IoTest extends AbstractGremlinTest {
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
GraphMigrator.migrateGraph(graph, g1, reader, writer);
@@ -387,13 +400,13 @@ public class IoTest extends AbstractGremlinTest {
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void shouldReadWriteModernToGryo() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.MODERN);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
}
@@ -415,11 +428,11 @@ public class IoTest extends AbstractGremlinTest {
public void shouldReadWriteModernToGryoToFileWithHelpers() throws Exception {
final File f = TestHelper.generateTempFile(this.getClass(), name.getMethodName(), ".kryo");
try {
- graph.io(GryoIo.build()).write(f.getAbsolutePath());
+ graph.io(gryo).write(f.getAbsolutePath());
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.MODERN);
final Graph g1 = graphProvider.openTestGraph(configuration);
- g1.io(GryoIo.build()).read(f.getAbsolutePath());
+ g1.io(gryo).read(f.getAbsolutePath());
// by making this lossy for float it will assert floats for doubles
assertModernGraph(g1, true, false);
@@ -441,14 +454,14 @@ public class IoTest extends AbstractGremlinTest {
public void shouldReadWriteCrewToGryo() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.CREW);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
final GryoReader reader = GryoReader.build()
- .mapper(graph.io(GryoIo.build()).mapper().create())
+ .mapper(graph.io(gryo).mapper().create())
.workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
@@ -471,13 +484,13 @@ public class IoTest extends AbstractGremlinTest {
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void shouldReadWriteClassicToGryo() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.CLASSIC);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
}
@@ -495,13 +508,13 @@ public class IoTest extends AbstractGremlinTest {
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void shouldReadWriteClassicToGraphSON() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.CLASSIC);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
}
@@ -519,13 +532,13 @@ public class IoTest extends AbstractGremlinTest {
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void shouldReadWriteModernToGraphSON() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.MODERN);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
}
@@ -544,12 +557,12 @@ public class IoTest extends AbstractGremlinTest {
public void shouldReadWriteModernToGraphSONWithHelpers() throws Exception {
final File f = TestHelper.generateTempFile(this.getClass(), name.getMethodName(), ".json");
try {
- graph.io(GraphSONIo.build()).write(f.getAbsolutePath());
+ graph.io(graphson).write(f.getAbsolutePath());
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.MODERN);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- g1.io(GraphSONIo.build()).read(f.getAbsolutePath());
+ g1.io(graphson).read(f.getAbsolutePath());
assertModernGraph(g1, true, false);
@@ -569,13 +582,13 @@ public class IoTest extends AbstractGremlinTest {
@FeatureRequirement(featureClass = Graph.Features.VertexFeatures.class, feature = Graph.Features.VertexFeatures.FEATURE_ADD_VERTICES)
public void shouldReadWriteCrewToGraphSON() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeGraph(os, graph);
final Configuration configuration = graphProvider.newGraphConfiguration("readGraph", this.getClass(), name.getMethodName(), LoadGraphWith.GraphData.CREW);
graphProvider.clear(configuration);
final Graph g1 = graphProvider.openTestGraph(configuration);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readGraph(bais, g1);
}
@@ -597,11 +610,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "weight", 0.5f, "acl", "rw");
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -633,11 +646,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "weight", 0.5d, "acl", "rw");
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -667,11 +680,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = DetachedFactory.detach(v1.addEdge("friend", v2, "weight", 0.5d, "acl", "rw"), false);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -701,11 +714,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = DetachedFactory.detach(v1.addEdge("friend", v2, "weight", 0.5d, "acl", "rw"), true);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -736,11 +749,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "weight", 0.5f, "acl", "rw");
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), graph.edges(detachedEdge.id().toString()).next().id());
@@ -771,11 +784,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = DetachedFactory.detach(v1.addEdge("friend", v2, "weight", 0.5f, "acl", "rw"), false);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), graph.edges(detachedEdge.id().toString()).next().id());
@@ -805,11 +818,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = DetachedFactory.detach(v1.addEdge("friend", v2, "weight", 0.5f, "acl", "rw"), true);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), graph.edges(detachedEdge.id().toString()).next().id());
@@ -841,11 +854,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "weight", 0.5f, "acl", "rw");
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONWriter writer = graph.io(graphson).writer().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONReader reader = graph.io(graphson).reader().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -877,11 +890,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "uuid", id);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONWriter writer = graph.io(graphson).writer().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONReader reader = graph.io(graphson).reader().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
// a quick reminder here that the purpose of these id assertions is to ensure that those with
@@ -917,11 +930,11 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friend", v2, "uuid", id);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeEdge(os, e);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readEdge(bais, detachedEdge -> {
assertEquals(e.id(), detachedEdge.id());
@@ -955,11 +968,11 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -986,11 +999,11 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1017,12 +1030,12 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
final DetachedVertex dv = DetachedFactory.detach(v1, true);
writer.writeVertex(os, dv);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1049,12 +1062,12 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
final DetachedVertex dv = DetachedFactory.detach(v1, false);
writer.writeVertex(os, dv);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1082,11 +1095,11 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1);
final AtomicBoolean called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1117,11 +1130,11 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1150,12 +1163,12 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
final DetachedVertex dv = DetachedFactory.detach(v1, true);
writer.writeVertex(os, dv);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1184,12 +1197,12 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
final DetachedVertex dv = DetachedFactory.detach(v1, false);
writer.writeVertex(os, dv);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1219,11 +1232,11 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1);
final AtomicBoolean called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1246,11 +1259,11 @@ public class IoTest extends AbstractGremlinTest {
@LoadGraphWith(LoadGraphWith.GraphData.CLASSIC)
public void shouldReadWriteVerticesNoEdgesToGryoManual() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertices(os, g.V().has("age", Compare.gt, 30));
final AtomicInteger called = new AtomicInteger(0);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final VertexByteArrayInputStream vbais = new VertexByteArrayInputStream(new ByteArrayInputStream(os.toByteArray()))) {
reader.readVertex(new ByteArrayInputStream(vbais.readVertexBytes().toByteArray()),
@@ -1274,11 +1287,11 @@ public class IoTest extends AbstractGremlinTest {
@LoadGraphWith(LoadGraphWith.GraphData.MODERN)
public void shouldReadWriteVerticesNoEdgesToGryo() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertices(os, g.V().has("age", Compare.gt, 30));
final AtomicInteger called = new AtomicInteger(0);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
final Iterator<Vertex> itty = reader.readVertices(bais, null,
@@ -1300,11 +1313,11 @@ public class IoTest extends AbstractGremlinTest {
@LoadGraphWith(LoadGraphWith.GraphData.CLASSIC)
public void shouldReadWriteVerticesNoEdgesToGraphSONManual() throws Exception {
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertices(os, g.V().has("age", Compare.gt, 30));
final AtomicInteger called = new AtomicInteger(0);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
final BufferedReader br = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(os.toByteArray())));
String line = br.readLine();
reader.readVertex(new ByteArrayInputStream(line.getBytes()),
@@ -1337,12 +1350,12 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.OUT);
final AtomicBoolean calledVertex = new AtomicBoolean(false);
final AtomicBoolean calledEdge = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.OUT, detachedVertex -> {
@@ -1386,12 +1399,12 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v1.addEdge("friends", v2, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1, Direction.OUT);
final AtomicBoolean calledVertex = new AtomicBoolean(false);
final AtomicBoolean calledEdge = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.OUT, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1433,13 +1446,13 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v2.addEdge("friends", v1, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.IN);
final AtomicBoolean calledVertex = new AtomicBoolean(false);
final AtomicBoolean calledEdge = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.IN, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1482,13 +1495,13 @@ public class IoTest extends AbstractGremlinTest {
final Edge e = v2.addEdge("friends", v1, "weight", 0.5f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1, Direction.IN);
os.close();
final AtomicBoolean calledVertex = new AtomicBoolean(false);
final AtomicBoolean calledEdge = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.IN, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1531,14 +1544,14 @@ public class IoTest extends AbstractGremlinTest {
final Edge e2 = v1.addEdge("friends", v2, "weight", 1.0d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean calledVertex = new AtomicBoolean(false);
final AtomicBoolean calledEdge1 = new AtomicBoolean(false);
final AtomicBoolean calledEdge2 = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.BOTH, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1595,14 +1608,14 @@ public class IoTest extends AbstractGremlinTest {
final Edge e2 = v1.addEdge("friends", v2, "weight", 1.0f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edge1Called = new AtomicBoolean(false);
final AtomicBoolean edge2Called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.BOTH, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1660,14 +1673,14 @@ public class IoTest extends AbstractGremlinTest {
final Edge e2 = v1.addEdge("friends", v2, "weight", 1.0f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONWriter writer = graph.io(graphson).writer().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edge1Called = new AtomicBoolean(false);
final AtomicBoolean edge2Called = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().mapper(graph.io(GraphSONIo.build()).mapper().embedTypes(true).create()).create();
+ final GraphSONReader reader = graph.io(graphson).reader().mapper(graph.io(graphson).mapper().embedTypes(true).create()).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.BOTH, detachedVertex -> {
// a quick reminder here that the purpose of these id assertions is to ensure that those with
@@ -1728,13 +1741,13 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 1.0d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edge1Called = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.IN, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1781,13 +1794,13 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 1.0f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edgeCalled = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.IN, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1834,13 +1847,13 @@ public class IoTest extends AbstractGremlinTest {
final Edge e2 = v1.addEdge("friends", v2, "weight", 1.0d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edgeCalled = new AtomicBoolean(false);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.OUT, detachedVertex -> {
assertEquals(v1.id(), detachedVertex.id());
@@ -1888,13 +1901,13 @@ public class IoTest extends AbstractGremlinTest {
final Edge e2 = v1.addEdge("friends", v2, "weight", 1.0f);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GraphSONWriter writer = graph.io(GraphSONIo.build()).writer().create();
+ final GraphSONWriter writer = graph.io(graphson).writer().create();
writer.writeVertex(os, v1, Direction.BOTH);
final AtomicBoolean vertexCalled = new AtomicBoolean(false);
final AtomicBoolean edgeCalled = new AtomicBoolean(false);
- final GraphSONReader reader = graph.io(GraphSONIo.build()).reader().create();
+ final GraphSONReader reader = graph.io(graphson).reader().create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais, Direction.OUT, detachedVertex -> {
assertEquals(v1.id(), graph.vertices(detachedVertex.id().toString()).next().id());
@@ -1938,10 +1951,10 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.OUT);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais,
Direction.BOTH,
@@ -1962,10 +1975,10 @@ public class IoTest extends AbstractGremlinTest {
v2.addEdge("friends", v1, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.IN);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais,
Direction.BOTH,
@@ -1986,10 +1999,10 @@ public class IoTest extends AbstractGremlinTest {
v2.addEdge("friends", v1, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.IN);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais,
Direction.OUT,
@@ -2010,10 +2023,10 @@ public class IoTest extends AbstractGremlinTest {
v1.addEdge("friends", v2, "weight", 0.5d);
try (final ByteArrayOutputStream os = new ByteArrayOutputStream()) {
- final GryoWriter writer = graph.io(GryoIo.build()).writer().create();
+ final GryoWriter writer = graph.io(gryo).writer().create();
writer.writeVertex(os, v1, Direction.IN);
- final GryoReader reader = graph.io(GryoIo.build()).reader().workingDirectory(tempPath).create();
+ final GryoReader reader = graph.io(gryo).reader().workingDirectory(tempPath).create();
try (final ByteArrayInputStream bais = new ByteArrayInputStream(os.toByteArray())) {
reader.readVertex(bais,
Direction.OUT,