You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by dk...@apache.org on 2015/06/03 02:12:49 UTC
[44/50] [abbrv] incubator-tinkerpop git commit: Finalize classes in
GraphSON.
Finalize classes in GraphSON.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/67ad95ec
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/67ad95ec
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/67ad95ec
Branch: refs/heads/preprocessor
Commit: 67ad95ec8d06160bfed00e4b1163edf74cc8d007
Parents: 1dd487c
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Mon Jun 1 14:40:24 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Mon Jun 1 14:40:24 2015 -0400
----------------------------------------------------------------------
.../structure/io/graphson/GraphSONIo.java | 6 +-
.../structure/io/graphson/GraphSONModule.java | 2 +-
.../structure/io/graphson/GraphSONReader.java | 9 ++-
.../io/graphson/GraphSONSerializers.java | 14 ++--
.../structure/io/graphson/GraphSONVersion.java | 2 +-
.../structure/io/graphson/GraphSONWriter.java | 2 +-
.../io/graphson/LegacyGraphSONReader.java | 73 ++++++++++----------
7 files changed, 55 insertions(+), 53 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONIo.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONIo.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONIo.java
index 57cfc62..29d14cf 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONIo.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONIo.java
@@ -34,11 +34,11 @@ import java.io.OutputStream;
*
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public class GraphSONIo implements Io<GraphSONReader.Builder, GraphSONWriter.Builder, GraphSONMapper.Builder> {
+public final class GraphSONIo implements Io<GraphSONReader.Builder, GraphSONWriter.Builder, GraphSONMapper.Builder> {
private final IoRegistry registry;
private final Graph graph;
- public GraphSONIo(final IoRegistry registry, final Graph graph) {
+ private GraphSONIo(final IoRegistry registry, final Graph graph) {
this.registry = registry;
this.graph = graph;
}
@@ -91,7 +91,7 @@ public class GraphSONIo implements Io<GraphSONReader.Builder, GraphSONWriter.Bui
return new Builder();
}
- public static class Builder implements Io.Builder<GraphSONIo> {
+ public final static class Builder implements Io.Builder<GraphSONIo> {
private IoRegistry registry = null;
private Graph graph;
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONModule.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONModule.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONModule.java
index 4161faf..b53427b 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONModule.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONModule.java
@@ -51,7 +51,7 @@ abstract class GraphSONModule extends SimpleModule {
/**
* Constructs a new object.
*/
- GraphSONModuleV1d0(final boolean normalize) {
+ protected GraphSONModuleV1d0(final boolean normalize) {
super("graphson-1.0");
addSerializer(Edge.class, new GraphSONSerializers.EdgeJacksonSerializer(normalize));
addSerializer(Vertex.class, new GraphSONSerializers.VertexJacksonSerializer(normalize));
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONReader.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONReader.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONReader.java
index 76594ab..311463f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONReader.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONReader.java
@@ -63,14 +63,14 @@ import java.util.function.Function;
*
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public class GraphSONReader implements GraphReader {
+public final class GraphSONReader implements GraphReader {
private final ObjectMapper mapper;
private final long batchSize;
final TypeReference<Map<String, Object>> mapTypeReference = new TypeReference<Map<String, Object>>() {
};
- public GraphSONReader(final GraphSONMapper mapper, final long batchSize) {
+ private GraphSONReader(final GraphSONMapper mapper, final long batchSize) {
this.mapper = mapper.createMapper();
this.batchSize = batchSize;
}
@@ -248,13 +248,12 @@ public class GraphSONReader implements GraphReader {
return new Builder();
}
- public static class Builder implements ReaderBuilder<GraphSONReader> {
+ public final static class Builder implements ReaderBuilder<GraphSONReader> {
private long batchSize = 10000;
private GraphSONMapper mapper = GraphSONMapper.build().create();
- private Builder() {
- }
+ private Builder() {}
/**
* Number of mutations to perform before a commit is executed when using
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONSerializers.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONSerializers.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONSerializers.java
index 9d637b2..bd43417 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONSerializers.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONSerializers.java
@@ -56,7 +56,7 @@ final class GraphSONSerializers {
private GraphSONSerializers() {}
- static class VertexPropertyJacksonSerializer extends StdSerializer<VertexProperty> {
+ final static class VertexPropertyJacksonSerializer extends StdSerializer<VertexProperty> {
private final boolean normalize;
@@ -78,7 +78,7 @@ final class GraphSONSerializers {
}
}
- static class PropertyJacksonSerializer extends StdSerializer<Property> {
+ final static class PropertyJacksonSerializer extends StdSerializer<Property> {
public PropertyJacksonSerializer() {
super(Property.class);
@@ -105,7 +105,7 @@ final class GraphSONSerializers {
}
}
- static class EdgeJacksonSerializer extends StdSerializer<Edge> {
+ final static class EdgeJacksonSerializer extends StdSerializer<Edge> {
private final boolean normalize;
@@ -160,7 +160,7 @@ final class GraphSONSerializers {
}
- static class VertexJacksonSerializer extends StdSerializer<Vertex> {
+ final static class VertexJacksonSerializer extends StdSerializer<Vertex> {
private final boolean normalize;
@@ -226,7 +226,7 @@ final class GraphSONSerializers {
}
- static class PathJacksonSerializer extends StdSerializer<Path> {
+ final static class PathJacksonSerializer extends StdSerializer<Path> {
public PathJacksonSerializer() {
super(Path.class);
@@ -257,7 +257,7 @@ final class GraphSONSerializers {
/**
* Maps in the JVM can have {@link Object} as a key, but in JSON they must be a {@link String}.
*/
- static class GraphSONKeySerializer extends StdKeySerializer {
+ final static class GraphSONKeySerializer extends StdKeySerializer {
@Override
public void serialize(final Object o, final JsonGenerator jsonGenerator, final SerializerProvider serializerProvider) throws IOException {
@@ -278,7 +278,7 @@ final class GraphSONSerializers {
}
}
- static class TraversalMetricsJacksonSerializer extends StdSerializer<TraversalMetrics> {
+ final static class TraversalMetricsJacksonSerializer extends StdSerializer<TraversalMetrics> {
public TraversalMetricsJacksonSerializer() {
super(TraversalMetrics.class);
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONVersion.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONVersion.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONVersion.java
index fef6df6..628ea22 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONVersion.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONVersion.java
@@ -29,7 +29,7 @@ public enum GraphSONVersion {
private final GraphSONModule.GraphSONModuleBuilder builder;
private final String versionNumber;
- private GraphSONVersion(final GraphSONModule.GraphSONModuleBuilder builder, final String versionNumber) {
+ GraphSONVersion(final GraphSONModule.GraphSONModuleBuilder builder, final String versionNumber) {
this.builder = builder;
this.versionNumber = versionNumber;
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONWriter.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONWriter.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONWriter.java
index bbbfb3b..a531012 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONWriter.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONWriter.java
@@ -42,7 +42,7 @@ import java.util.Iterator;
*
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public class GraphSONWriter implements GraphWriter {
+public final class GraphSONWriter implements GraphWriter {
private final ObjectMapper mapper;
private GraphSONWriter(final GraphSONMapper mapper) {
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/67ad95ec/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/LegacyGraphSONReader.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/LegacyGraphSONReader.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/LegacyGraphSONReader.java
index a8d1929..ba8255a 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/LegacyGraphSONReader.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/LegacyGraphSONReader.java
@@ -53,11 +53,11 @@ import java.util.function.Function;
*
* @author Stephen Mallette (http://stephen.genoprime.com)
*/
-public class LegacyGraphSONReader implements GraphReader {
+public final class LegacyGraphSONReader implements GraphReader {
private final ObjectMapper mapper;
private final long batchSize;
- public LegacyGraphSONReader(final ObjectMapper mapper, final long batchSize) {
+ private LegacyGraphSONReader(final ObjectMapper mapper, final long batchSize) {
this.mapper = mapper;
this.batchSize = batchSize;
}
@@ -80,13 +80,13 @@ public class LegacyGraphSONReader implements GraphReader {
while (parser.nextToken() != JsonToken.END_OBJECT) {
final String fieldName = parser.getCurrentName() == null ? "" : parser.getCurrentName();
switch (fieldName) {
- case GraphSONTokens.MODE:
+ case GraphSONTokensTP2.MODE:
parser.nextToken();
final String mode = parser.getText();
if (!mode.equals("EXTENDED"))
throw new IllegalStateException("The legacy GraphSON must be generated with GraphSONMode.EXTENDED");
break;
- case GraphSONTokens.VERTICES:
+ case GraphSONTokensTP2.VERTICES:
parser.nextToken();
while (parser.nextToken() != JsonToken.END_ARRAY) {
final JsonNode node = parser.readValueAsTree();
@@ -96,12 +96,12 @@ public class LegacyGraphSONReader implements GraphReader {
graphToWriteTo.tx().commit();
}
break;
- case GraphSONTokens.EDGES:
+ case GraphSONTokensTP2.EDGES:
parser.nextToken();
while (parser.nextToken() != JsonToken.END_ARRAY) {
final JsonNode node = parser.readValueAsTree();
- final Vertex inV = cache.get(LegacyGraphSONUtility.getTypedValueFromJsonNode(node.get(GraphSONTokens._IN_V)));
- final Vertex outV = cache.get(LegacyGraphSONUtility.getTypedValueFromJsonNode(node.get(GraphSONTokens._OUT_V)));
+ final Vertex inV = cache.get(LegacyGraphSONUtility.getTypedValueFromJsonNode(node.get(GraphSONTokensTP2._IN_V)));
+ final Vertex outV = cache.get(LegacyGraphSONUtility.getTypedValueFromJsonNode(node.get(GraphSONTokensTP2._OUT_V)));
graphson.edgeFromJson(node, outV, inV);
if (supportsTx && counter.incrementAndGet() % batchSize == 0)
@@ -201,7 +201,7 @@ public class LegacyGraphSONReader implements GraphReader {
return new Builder();
}
- public static class Builder {
+ public final static class Builder {
private boolean loadCustomModules = false;
private List<SimpleModule> customModules = new ArrayList<>();
private long batchSize = 10000;
@@ -263,7 +263,7 @@ public class LegacyGraphSONReader implements GraphReader {
public Vertex vertexFromJson(final JsonNode json) throws IOException {
final Map<String, Object> props = readProperties(json);
- final Object vertexId = getTypedValueFromJsonNode(json.get(GraphSONTokens._ID));
+ final Object vertexId = getTypedValueFromJsonNode(json.get(GraphSONTokensTP2._ID));
final Vertex v = vertexFeatures.willAllowId(vertexId) ? g.addVertex(T.id, vertexId) : g.addVertex();
cache.put(vertexId, v);
@@ -277,8 +277,8 @@ public class LegacyGraphSONReader implements GraphReader {
public Edge edgeFromJson(final JsonNode json, final Vertex out, final Vertex in) throws IOException {
final Map<String, Object> props = LegacyGraphSONUtility.readProperties(json);
- final Object edgeId = getTypedValueFromJsonNode(json.get(GraphSONTokens._ID));
- final JsonNode nodeLabel = json.get(GraphSONTokens._LABEL);
+ final Object edgeId = getTypedValueFromJsonNode(json.get(GraphSONTokensTP2._ID));
+ final JsonNode nodeLabel = json.get(GraphSONTokensTP2._LABEL);
final String label = nodeLabel == null ? EMPTY_STRING : nodeLabel.textValue();
final Edge e = edgeFeatures.willAllowId(edgeId) ? out.addEdge(label, in, T.id, edgeId) : out.addEdge(label, in) ;
@@ -310,35 +310,35 @@ public class LegacyGraphSONReader implements GraphReader {
}
private static boolean isReservedKey(final String key) {
- return key.equals(GraphSONTokens._ID) || key.equals(GraphSONTokens._TYPE) || key.equals(GraphSONTokens._LABEL)
- || key.equals(GraphSONTokens._OUT_V) || key.equals(GraphSONTokens._IN_V);
+ return key.equals(GraphSONTokensTP2._ID) || key.equals(GraphSONTokensTP2._TYPE) || key.equals(GraphSONTokensTP2._LABEL)
+ || key.equals(GraphSONTokensTP2._OUT_V) || key.equals(GraphSONTokensTP2._IN_V);
}
private static Object readProperty(final JsonNode node) {
final Object propertyValue;
- if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_UNKNOWN)) {
+ if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_UNKNOWN)) {
propertyValue = null;
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_BOOLEAN)) {
- propertyValue = node.get(GraphSONTokens.VALUE).booleanValue();
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_FLOAT)) {
- propertyValue = Float.parseFloat(node.get(GraphSONTokens.VALUE).asText());
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_BYTE)) {
- propertyValue = Byte.parseByte(node.get(GraphSONTokens.VALUE).asText());
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_SHORT)) {
- propertyValue = Short.parseShort(node.get(GraphSONTokens.VALUE).asText());
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_DOUBLE)) {
- propertyValue = node.get(GraphSONTokens.VALUE).doubleValue();
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_INTEGER)) {
- propertyValue = node.get(GraphSONTokens.VALUE).intValue();
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_LONG)) {
- propertyValue = node.get(GraphSONTokens.VALUE).longValue();
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_STRING)) {
- propertyValue = node.get(GraphSONTokens.VALUE).textValue();
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_LIST)) {
- propertyValue = readProperties(node.get(GraphSONTokens.VALUE).elements());
- } else if (node.get(GraphSONTokens.TYPE).textValue().equals(GraphSONTokens.TYPE_MAP)) {
- propertyValue = readProperties(node.get(GraphSONTokens.VALUE));
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_BOOLEAN)) {
+ propertyValue = node.get(GraphSONTokensTP2.VALUE).booleanValue();
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_FLOAT)) {
+ propertyValue = Float.parseFloat(node.get(GraphSONTokensTP2.VALUE).asText());
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_BYTE)) {
+ propertyValue = Byte.parseByte(node.get(GraphSONTokensTP2.VALUE).asText());
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_SHORT)) {
+ propertyValue = Short.parseShort(node.get(GraphSONTokensTP2.VALUE).asText());
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_DOUBLE)) {
+ propertyValue = node.get(GraphSONTokensTP2.VALUE).doubleValue();
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_INTEGER)) {
+ propertyValue = node.get(GraphSONTokensTP2.VALUE).intValue();
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_LONG)) {
+ propertyValue = node.get(GraphSONTokensTP2.VALUE).longValue();
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_STRING)) {
+ propertyValue = node.get(GraphSONTokensTP2.VALUE).textValue();
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_LIST)) {
+ propertyValue = readProperties(node.get(GraphSONTokensTP2.VALUE).elements());
+ } else if (node.get(GraphSONTokensTP2.TYPE).textValue().equals(GraphSONTokensTP2.TYPE_MAP)) {
+ propertyValue = readProperties(node.get(GraphSONTokensTP2.VALUE));
} else {
propertyValue = node.textValue();
}
@@ -389,7 +389,10 @@ public class LegacyGraphSONReader implements GraphReader {
}
}
- public static class GraphSONTokens {
+ public final static class GraphSONTokensTP2 {
+
+ private GraphSONTokensTP2() {}
+
public static final String _ID = "_id";
public static final String _LABEL = "_label";
public static final String _TYPE = "_type";