Repository: tinkerpop Updated Branches: refs/heads/master 7a814e196 -> f39128cd3
Make IoStep a bit more extensible Providers will only have to override the read()/write() methods to get a custom OLTP implementation working quickly. CTR Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/f39128cd Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/f39128cd Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/f39128cd Branch: refs/heads/master Commit: f39128cd300e8683488af96deaa5ed02b49cbaa9 Parents: 7a814e1 Author: Stephen Mallette <[email protected]> Authored: Tue Sep 11 10:59:25 2018 -0400 Committer: Stephen Mallette <[email protected]> Committed: Tue Sep 11 11:35:05 2018 -0400 ---------------------------------------------------------------------- .../gremlin/process/traversal/step/sideEffect/IoStep.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/f39128cd/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/IoStep.java ---------------------------------------------------------------------- diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/IoStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/IoStep.java index e5b3a6a..efd4240 100644 --- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/IoStep.java +++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/IoStep.java @@ -115,7 +115,7 @@ public class IoStep<S> extends AbstractStep<S,S> implements ReadWriting { } } - private Traverser.Admin<S> write(final File file) { + protected Traverser.Admin<S> write(final File file) { try (final OutputStream stream = new FileOutputStream(file)) { final Graph graph = (Graph) this.traversal.getGraph().get(); constructWriter().writeGraph(stream, graph); @@ -126,7 +126,7 @@ public class IoStep<S> extends AbstractStep<S,S> implements ReadWriting { } } - private Traverser.Admin<S> read(final File file) { + protected Traverser.Admin<S> read(final File file) { try (final InputStream stream = new FileInputStream(file)) { final Graph graph = (Graph) this.traversal.getGraph().get(); constructReader().readGraph(stream, graph); @@ -217,8 +217,8 @@ public class IoStep<S> extends AbstractStep<S,S> implements ReadWriting { } private List<IoRegistry> detectRegistries() { - final List<Object> k = parameters.get(IO.registry, Collections::emptyList); - return parameters.get(IO.registry, null).stream().map(cn -> { + final List<Object> k = parameters.get(IO.registry, null); + return k.stream().map(cn -> { try { if (cn instanceof IoRegistry) return (IoRegistry) cn;
