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 2018/09/18 16:48:31 UTC
[13/50] [abbrv] tinkerpop git commit: Make IoStep a bit more
extensible
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/TINKERPOP-1913
Commit: f39128cd300e8683488af96deaa5ed02b49cbaa9
Parents: 7a814e1
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Tue Sep 11 10:59:25 2018 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
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;