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 2016/12/22 18:40:12 UTC
[13/21] tinkerpop git commit: TINKERPOP-1130 Structured the IO
compatibility tests
TINKERPOP-1130 Structured the IO compatibility tests
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/5f5848b1
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/5f5848b1
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/5f5848b1
Branch: refs/heads/TINKERPOP-1130
Commit: 5f5848b1a661bc9c0e0b351d9b08297486880797
Parents: b010268
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Dec 14 11:50:38 2016 -0500
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Thu Dec 22 13:33:36 2016 -0500
----------------------------------------------------------------------
gremlin-tools/gremlin-io-test/pom.xml | 378 +++++++++
.../gremlin/structure/io/Compatibility.java | 28 +
.../tinkerpop/gremlin/structure/io/Model.java | 390 +++++++++
.../io/graphson/GraphSONCompatibility.java | 59 ++
.../structure/io/gryo/GryoCompatibility.java | 55 ++
.../structure/io/AbstractCompatibilityTest.java | 36 +
.../io/AbstractTypedCompatibilityTest.java | 84 ++
.../io/AbstractUntypedCompatibilityTest.java | 63 ++
.../GraphSONTypedCompatibilityTest.java | 70 ++
.../GraphSONUntypedCompatibilityTest.java | 82 ++
.../io/gryo/GryoCompatibilityTest.java | 75 ++
.../src/test/resources/log4j-silent.properties | 23 +
.../src/test/resources/log4j-test.properties | 21 +
.../_3_2_3/authenticationchallenge-v1d0.json | 12 +
.../authenticationchallenge-v2d0-no-types.json | 12 +
.../authenticationchallenge-v2d0-partial.json | 12 +
.../_3_2_3/authenticationresponse-v1d0.json | 9 +
.../authenticationresponse-v2d0-no-types.json | 9 +
.../authenticationresponse-v2d0-partial.json | 12 +
.../graphson/_3_2_3/barrier-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/barrier-v2d0-partial.json | 4 +
.../_3_2_3/bigdecimal-v2d0-no-types.json | 1 +
.../_3_2_3/bigdecimal-v2d0-partial.json | 4 +
.../_3_2_3/biginteger-v2d0-no-types.json | 1 +
.../_3_2_3/biginteger-v2d0-partial.json | 4 +
.../graphson/_3_2_3/binding-v2d0-no-types.json | 4 +
.../graphson/_3_2_3/binding-v2d0-partial.json | 10 +
.../io/graphson/_3_2_3/byte-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/byte-v2d0-partial.json | 4 +
.../_3_2_3/bytebuffer-v2d0-no-types.json | 1 +
.../_3_2_3/bytebuffer-v2d0-partial.json | 4 +
.../graphson/_3_2_3/bytecode-v2d0-no-types.json | 6 +
.../graphson/_3_2_3/bytecode-v2d0-partial.json | 15 +
.../_3_2_3/cardinality-v2d0-no-types.json | 1 +
.../_3_2_3/cardinality-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/char-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/char-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/class-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/class-v2d0-partial.json | 4 +
.../graphson/_3_2_3/column-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/column-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/date-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/date-v2d0-partial.json | 4 +
.../_3_2_3/direction-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/direction-v2d0-partial.json | 4 +
.../graphson/_3_2_3/double-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/double-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/duration-v1d0.json | 1 +
.../graphson/_3_2_3/duration-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/duration-v2d0-partial.json | 4 +
.../structure/io/graphson/_3_2_3/edge-v1d0.json | 12 +
.../io/graphson/_3_2_3/edge-v2d0-no-types.json | 14 +
.../io/graphson/_3_2_3/edge-v2d0-partial.json | 32 +
.../io/graphson/_3_2_3/float-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/float-v2d0-partial.json | 4 +
.../_3_2_3/inetaddress-v2d0-no-types.json | 1 +
.../_3_2_3/inetaddress-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/instant-v1d0.json | 1 +
.../graphson/_3_2_3/instant-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/instant-v2d0-partial.json | 4 +
.../graphson/_3_2_3/integer-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/integer-v2d0-partial.json | 4 +
.../graphson/_3_2_3/lambda-v2d0-no-types.json | 5 +
.../io/graphson/_3_2_3/lambda-v2d0-partial.json | 8 +
.../io/graphson/_3_2_3/localdate-v1d0.json | 1 +
.../_3_2_3/localdate-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/localdate-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/localdatetime-v1d0.json | 1 +
.../_3_2_3/localdatetime-v2d0-no-types.json | 1 +
.../_3_2_3/localdatetime-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/localtime-v1d0.json | 1 +
.../_3_2_3/localtime-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/localtime-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/long-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/long-v2d0-partial.json | 4 +
.../_3_2_3/manual-graphson-generator.groovy | 288 +++++++
.../graphson/_3_2_3/metrics-v2d0-no-types.json | 24 +
.../graphson/_3_2_3/metrics-v2d0-partial.json | 54 ++
.../io/graphson/_3_2_3/monthday-v1d0.json | 1 +
.../graphson/_3_2_3/monthday-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/monthday-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/offsetdatetime-v1d0.json | 1 +
.../_3_2_3/offsetdatetime-v2d0-no-types.json | 1 +
.../_3_2_3/offsetdatetime-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/offsettime-v1d0.json | 1 +
.../_3_2_3/offsettime-v2d0-no-types.json | 1 +
.../_3_2_3/offsettime-v2d0-partial.json | 4 +
.../graphson/_3_2_3/operator-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/operator-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/order-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/order-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/p-v2d0-no-types.json | 4 +
.../io/graphson/_3_2_3/p-v2d0-partial.json | 10 +
.../io/graphson/_3_2_3/pand-v2d0-no-types.json | 10 +
.../io/graphson/_3_2_3/pand-v2d0-partial.json | 25 +
.../structure/io/graphson/_3_2_3/path-v1d0.json | 62 ++
.../io/graphson/_3_2_3/path-v2d0-no-types.json | 66 ++
.../io/graphson/_3_2_3/path-v2d0-partial.json | 150 ++++
.../io/graphson/_3_2_3/period-v1d0.json | 1 +
.../graphson/_3_2_3/period-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/period-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/pop-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/pop-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/por-v2d0-no-types.json | 10 +
.../io/graphson/_3_2_3/por-v2d0-partial.json | 31 +
.../io/graphson/_3_2_3/property-v1d0.json | 4 +
.../graphson/_3_2_3/property-v2d0-no-types.json | 4 +
.../graphson/_3_2_3/property-v2d0-partial.json | 10 +
.../io/graphson/_3_2_3/scope-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/scope-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/sessionclose-v1d0.json | 8 +
.../_3_2_3/sessionclose-v2d0-no-types.json | 8 +
.../_3_2_3/sessionclose-v2d0-partial.json | 14 +
.../io/graphson/_3_2_3/sessioneval-v1d0.json | 16 +
.../_3_2_3/sessioneval-v2d0-no-types.json | 16 +
.../_3_2_3/sessioneval-v2d0-partial.json | 25 +
.../graphson/_3_2_3/sessionlesseval-v1d0.json | 15 +
.../_3_2_3/sessionlesseval-v2d0-no-types.json | 15 +
.../_3_2_3/sessionlesseval-v2d0-partial.json | 21 +
.../io/graphson/_3_2_3/short-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/short-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/standardresult-v1d0.json | 50 ++
.../_3_2_3/standardresult-v2d0-no-types.json | 54 ++
.../_3_2_3/standardresult-v2d0-partial.json | 111 +++
.../io/graphson/_3_2_3/stargraph-v1d0.json | 66 ++
.../_3_2_3/stargraph-v2d0-no-types.json | 66 ++
.../graphson/_3_2_3/stargraph-v2d0-partial.json | 141 ++++
.../io/graphson/_3_2_3/t-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/t-v2d0-partial.json | 4 +
.../_3_2_3/timestamp-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/timestamp-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/tinkergraph-v1d0.json | 313 +++++++
.../_3_2_3/tinkergraph-v2d0-no-types.json | 352 ++++++++
.../_3_2_3/tinkergraph-v2d0-partial.json | 829 ++++++++++++++++++
.../_3_2_3/traversalmetrics-v2d0-no-types.json | 48 ++
.../_3_2_3/traversalmetrics-v2d0-partial.json | 114 +++
.../_3_2_3/traverser-v2d0-no-types.json | 46 +
.../graphson/_3_2_3/traverser-v2d0-partial.json | 109 +++
.../structure/io/graphson/_3_2_3/tree-v1d0.json | 276 ++++++
.../io/graphson/_3_2_3/tree-v2d0-no-types.json | 269 ++++++
.../io/graphson/_3_2_3/tree-v2d0-partial.json | 608 ++++++++++++++
.../io/graphson/_3_2_3/uuid-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/uuid-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/vertex-v1d0.json | 39 +
.../graphson/_3_2_3/vertex-v2d0-no-types.json | 43 +
.../io/graphson/_3_2_3/vertex-v2d0-partial.json | 100 +++
.../io/graphson/_3_2_3/vertexproperty-v1d0.json | 5 +
.../_3_2_3/vertexproperty-v2d0-no-types.json | 5 +
.../_3_2_3/vertexproperty-v2d0-partial.json | 11 +
.../structure/io/graphson/_3_2_3/year-v1d0.json | 1 +
.../io/graphson/_3_2_3/year-v2d0-no-types.json | 1 +
.../io/graphson/_3_2_3/year-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/yearmonth-v1d0.json | 1 +
.../_3_2_3/yearmonth-v2d0-no-types.json | 1 +
.../graphson/_3_2_3/yearmonth-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/zoneddatetime-v1d0.json | 1 +
.../_3_2_3/zoneddatetime-v2d0-no-types.json | 1 +
.../_3_2_3/zoneddatetime-v2d0-partial.json | 4 +
.../io/graphson/_3_2_3/zoneoffset-v1d0.json | 1 +
.../_3_2_3/zoneoffset-v2d0-no-types.json | 1 +
.../_3_2_3/zoneoffset-v2d0-partial.json | 4 +
.../_3_3_0/authenticationchallenge-v1d0.json | 12 +
.../authenticationchallenge-v2d0-no-types.json | 12 +
.../authenticationchallenge-v2d0-partial.json | 12 +
.../_3_3_0/authenticationresponse-v1d0.json | 9 +
.../authenticationresponse-v2d0-no-types.json | 9 +
.../authenticationresponse-v2d0-partial.json | 12 +
.../_3_3_0/bigdecimal-v2d0-no-types.json | 1 +
.../_3_3_0/bigdecimal-v2d0-partial.json | 4 +
.../_3_3_0/biginteger-v2d0-no-types.json | 1 +
.../_3_3_0/biginteger-v2d0-partial.json | 4 +
.../graphson/_3_3_0/binding-v2d0-no-types.json | 4 +
.../graphson/_3_3_0/binding-v2d0-partial.json | 10 +
.../io/graphson/_3_3_0/byte-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/byte-v2d0-partial.json | 4 +
.../_3_3_0/bytebuffer-v2d0-no-types.json | 1 +
.../_3_3_0/bytebuffer-v2d0-partial.json | 4 +
.../graphson/_3_3_0/bytecode-v2d0-no-types.json | 3 +
.../graphson/_3_3_0/bytecode-v2d0-partial.json | 6 +
.../_3_3_0/cardinality-v2d0-no-types.json | 1 +
.../_3_3_0/cardinality-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/char-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/char-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/class-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/class-v2d0-partial.json | 4 +
.../graphson/_3_3_0/column-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/column-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/date-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/date-v2d0-partial.json | 4 +
.../_3_3_0/direction-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/direction-v2d0-partial.json | 4 +
.../graphson/_3_3_0/double-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/double-v2d0-partial.json | 4 +
.../graphson/_3_3_0/duration-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/duration-v2d0-partial.json | 4 +
.../structure/io/graphson/_3_3_0/edge-v1d0.json | 12 +
.../io/graphson/_3_3_0/edge-v2d0-no-types.json | 11 +
.../io/graphson/_3_3_0/edge-v2d0-partial.json | 26 +
.../io/graphson/_3_3_0/float-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/float-v2d0-partial.json | 4 +
.../_3_3_0/inetaddress-v2d0-no-types.json | 1 +
.../_3_3_0/inetaddress-v2d0-partial.json | 4 +
.../graphson/_3_3_0/instant-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/instant-v2d0-partial.json | 4 +
.../graphson/_3_3_0/integer-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/integer-v2d0-partial.json | 4 +
.../graphson/_3_3_0/lambda-v2d0-no-types.json | 5 +
.../io/graphson/_3_3_0/lambda-v2d0-partial.json | 8 +
.../_3_3_0/localdate-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/localdate-v2d0-partial.json | 4 +
.../_3_3_0/localdatetime-v2d0-no-types.json | 1 +
.../_3_3_0/localdatetime-v2d0-partial.json | 4 +
.../_3_3_0/localtime-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/localtime-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/long-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/long-v2d0-partial.json | 4 +
.../graphson/_3_3_0/metrics-v2d0-no-types.json | 24 +
.../graphson/_3_3_0/metrics-v2d0-partial.json | 54 ++
.../graphson/_3_3_0/monthday-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/monthday-v2d0-partial.json | 4 +
.../_3_3_0/offsetdatetime-v2d0-no-types.json | 1 +
.../_3_3_0/offsetdatetime-v2d0-partial.json | 4 +
.../_3_3_0/offsettime-v2d0-no-types.json | 1 +
.../_3_3_0/offsettime-v2d0-partial.json | 4 +
.../graphson/_3_3_0/operator-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/operator-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/order-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/order-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/p-v2d0-no-types.json | 4 +
.../io/graphson/_3_3_0/p-v2d0-partial.json | 10 +
.../io/graphson/_3_3_0/pand-v2d0-no-types.json | 10 +
.../io/graphson/_3_3_0/pand-v2d0-partial.json | 25 +
.../structure/io/graphson/_3_3_0/path-v1d0.json | 62 ++
.../io/graphson/_3_3_0/path-v2d0-no-types.json | 73 ++
.../io/graphson/_3_3_0/path-v2d0-partial.json | 178 ++++
.../graphson/_3_3_0/period-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/period-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/pick-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/pick-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/pop-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/pop-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/por-v2d0-no-types.json | 10 +
.../io/graphson/_3_3_0/por-v2d0-partial.json | 31 +
.../io/graphson/_3_3_0/property-v1d0.json | 4 +
.../graphson/_3_3_0/property-v2d0-no-types.json | 13 +
.../graphson/_3_3_0/property-v2d0-partial.json | 28 +
.../io/graphson/_3_3_0/scope-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/scope-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/sessionclose-v1d0.json | 8 +
.../_3_3_0/sessionclose-v2d0-no-types.json | 8 +
.../_3_3_0/sessionclose-v2d0-partial.json | 14 +
.../io/graphson/_3_3_0/sessioneval-v1d0.json | 16 +
.../_3_3_0/sessioneval-v2d0-no-types.json | 16 +
.../_3_3_0/sessioneval-v2d0-partial.json | 25 +
.../graphson/_3_3_0/sessionlesseval-v1d0.json | 15 +
.../_3_3_0/sessionlesseval-v2d0-no-types.json | 15 +
.../_3_3_0/sessionlesseval-v2d0-partial.json | 21 +
.../io/graphson/_3_3_0/short-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/short-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/standardresult-v1d0.json | 50 ++
.../_3_3_0/standardresult-v2d0-no-types.json | 59 ++
.../_3_3_0/standardresult-v2d0-partial.json | 131 +++
.../io/graphson/_3_3_0/stargraph-v1d0.json | 41 +
.../_3_3_0/stargraph-v2d0-no-types.json | 50 ++
.../graphson/_3_3_0/stargraph-v2d0-partial.json | 122 +++
.../io/graphson/_3_3_0/t-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/t-v2d0-partial.json | 4 +
.../_3_3_0/timestamp-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/timestamp-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/tinkergraph-v1d0.json | 313 +++++++
.../_3_3_0/tinkergraph-v2d0-no-types.json | 333 ++++++++
.../_3_3_0/tinkergraph-v2d0-partial.json | 831 +++++++++++++++++++
.../_3_3_0/traversalmetrics-v2d0-no-types.json | 48 ++
.../_3_3_0/traversalmetrics-v2d0-partial.json | 114 +++
.../_3_3_0/traverser-v2d0-no-types.json | 51 ++
.../graphson/_3_3_0/traverser-v2d0-partial.json | 129 +++
.../structure/io/graphson/_3_3_0/tree-v1d0.json | 276 ++++++
.../io/graphson/_3_3_0/tree-v2d0-no-types.json | 295 +++++++
.../io/graphson/_3_3_0/tree-v2d0-partial.json | 712 ++++++++++++++++
.../io/graphson/_3_3_0/uuid-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/uuid-v2d0-partial.json | 4 +
.../io/graphson/_3_3_0/vertex-v1d0.json | 39 +
.../graphson/_3_3_0/vertex-v2d0-no-types.json | 48 ++
.../io/graphson/_3_3_0/vertex-v2d0-partial.json | 120 +++
.../io/graphson/_3_3_0/vertexproperty-v1d0.json | 5 +
.../_3_3_0/vertexproperty-v2d0-no-types.json | 6 +
.../_3_3_0/vertexproperty-v2d0-partial.json | 15 +
.../io/graphson/_3_3_0/year-v2d0-no-types.json | 1 +
.../io/graphson/_3_3_0/year-v2d0-partial.json | 4 +
.../_3_3_0/yearmonth-v2d0-no-types.json | 1 +
.../graphson/_3_3_0/yearmonth-v2d0-partial.json | 4 +
.../_3_3_0/zoneddatetime-v2d0-no-types.json | 1 +
.../_3_3_0/zoneddatetime-v2d0-partial.json | 4 +
.../_3_3_0/zoneoffset-v2d0-no-types.json | 1 +
.../_3_3_0/zoneoffset-v2d0-partial.json | 4 +
.../structure/io/gryo/_3_2_3/barrier-v1d0.kryo | 1 +
.../io/gryo/_3_2_3/bigdecimal-v1d0.kryo | Bin 0 -> 18 bytes
.../io/gryo/_3_2_3/biginteger-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/binding-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/byte-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/bytecode-v1d0.kryo | Bin 0 -> 46 bytes
.../io/gryo/_3_2_3/cardinality-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/char-v1d0.kryo | Bin 0 -> 2 bytes
.../structure/io/gryo/_3_2_3/column-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/date-v1d0.kryo | 1 +
.../io/gryo/_3_2_3/direction-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/double-v1d0.kryo | Bin 0 -> 8 bytes
.../structure/io/gryo/_3_2_3/duration-v1d0.kryo | Bin 0 -> 9 bytes
.../structure/io/gryo/_3_2_3/edge-v1d0.kryo | Bin 0 -> 57 bytes
.../structure/io/gryo/_3_2_3/float-v1d0.kryo | Bin 0 -> 4 bytes
.../structure/io/gryo/_3_2_3/instant-v1d0.kryo | Bin 0 -> 13 bytes
.../structure/io/gryo/_3_2_3/integer-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/lambda-v1d0.kryo | Bin 0 -> 31 bytes
.../io/gryo/_3_2_3/localdate-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_2_3/localdatetime-v1d0.kryo | Bin 0 -> 29 bytes
.../io/gryo/_3_2_3/localtime-v1d0.kryo | Bin 0 -> 9 bytes
.../structure/io/gryo/_3_2_3/long-v1d0.kryo | 1 +
.../io/gryo/_3_2_3/manual-gryo-generator.groovy | 155 ++++
.../structure/io/gryo/_3_2_3/metrics-v1d0.kryo | Bin 0 -> 185 bytes
.../structure/io/gryo/_3_2_3/monthday-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_2_3/offsetdatetime-v1d0.kryo | Bin 0 -> 37 bytes
.../io/gryo/_3_2_3/offsettime-v1d0.kryo | Bin 0 -> 17 bytes
.../structure/io/gryo/_3_2_3/operator-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/order-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/p-v1d0.kryo | Bin 0 -> 6 bytes
.../structure/io/gryo/_3_2_3/pand-v1d0.kryo | Bin 0 -> 17 bytes
.../structure/io/gryo/_3_2_3/path-v1d0.kryo | Bin 0 -> 50 bytes
.../structure/io/gryo/_3_2_3/period-v1d0.kryo | Bin 0 -> 13 bytes
.../structure/io/gryo/_3_2_3/pop-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/por-v1d0.kryo | Bin 0 -> 30 bytes
.../structure/io/gryo/_3_2_3/property-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/scope-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/short-v1d0.kryo | Bin 0 -> 2 bytes
.../io/gryo/_3_2_3/stargraph-v1d0.kryo | Bin 0 -> 247 bytes
.../structure/io/gryo/_3_2_3/t-v1d0.kryo | 1 +
.../io/gryo/_3_2_3/tinkergraph-v1d0.kryo | Bin 0 -> 1117 bytes
.../io/gryo/_3_2_3/traversalmetrics-v1d0.kryo | Bin 0 -> 429 bytes
.../io/gryo/_3_2_3/traverser-v1d0.kryo | Bin 0 -> 211 bytes
.../structure/io/gryo/_3_2_3/tree-v1d0.kryo | Bin 0 -> 762 bytes
.../structure/io/gryo/_3_2_3/uuid-v1d0.kryo | 1 +
.../structure/io/gryo/_3_2_3/vertex-v1d0.kryo | Bin 0 -> 202 bytes
.../io/gryo/_3_2_3/vertexproperty-v1d0.kryo | Bin 0 -> 18 bytes
.../structure/io/gryo/_3_2_3/year-v1d0.kryo | Bin 0 -> 5 bytes
.../io/gryo/_3_2_3/yearmonth-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_2_3/zoneddatetime-v1d0.kryo | Bin 0 -> 45 bytes
.../io/gryo/_3_2_3/zoneoffset-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/barrier-v1d0.kryo | 1 +
.../io/gryo/_3_3_0/bigdecimal-v1d0.kryo | Bin 0 -> 18 bytes
.../io/gryo/_3_3_0/biginteger-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/binding-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/byte-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/bytecode-v1d0.kryo | Bin 0 -> 43 bytes
.../io/gryo/_3_3_0/cardinality-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/char-v1d0.kryo | Bin 0 -> 2 bytes
.../structure/io/gryo/_3_3_0/column-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/date-v1d0.kryo | 1 +
.../io/gryo/_3_3_0/direction-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/double-v1d0.kryo | Bin 0 -> 8 bytes
.../structure/io/gryo/_3_3_0/duration-v1d0.kryo | Bin 0 -> 9 bytes
.../structure/io/gryo/_3_3_0/edge-v1d0.kryo | Bin 0 -> 57 bytes
.../structure/io/gryo/_3_3_0/float-v1d0.kryo | Bin 0 -> 4 bytes
.../structure/io/gryo/_3_3_0/instant-v1d0.kryo | Bin 0 -> 13 bytes
.../structure/io/gryo/_3_3_0/integer-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/lambda-v1d0.kryo | Bin 0 -> 31 bytes
.../io/gryo/_3_3_0/localdate-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_3_0/localdatetime-v1d0.kryo | Bin 0 -> 29 bytes
.../io/gryo/_3_3_0/localtime-v1d0.kryo | Bin 0 -> 9 bytes
.../structure/io/gryo/_3_3_0/long-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/metrics-v1d0.kryo | Bin 0 -> 185 bytes
.../structure/io/gryo/_3_3_0/monthday-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_3_0/offsetdatetime-v1d0.kryo | Bin 0 -> 37 bytes
.../io/gryo/_3_3_0/offsettime-v1d0.kryo | Bin 0 -> 17 bytes
.../structure/io/gryo/_3_3_0/operator-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/order-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/p-v1d0.kryo | Bin 0 -> 6 bytes
.../structure/io/gryo/_3_3_0/pand-v1d0.kryo | Bin 0 -> 17 bytes
.../structure/io/gryo/_3_3_0/path-v1d0.kryo | Bin 0 -> 50 bytes
.../structure/io/gryo/_3_3_0/period-v1d0.kryo | Bin 0 -> 13 bytes
.../structure/io/gryo/_3_3_0/pick-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/pop-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/por-v1d0.kryo | Bin 0 -> 30 bytes
.../structure/io/gryo/_3_3_0/property-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/scope-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/short-v1d0.kryo | Bin 0 -> 2 bytes
.../io/gryo/_3_3_0/stargraph-v1d0.kryo | Bin 0 -> 247 bytes
.../structure/io/gryo/_3_3_0/t-v1d0.kryo | 1 +
.../io/gryo/_3_3_0/tinkergraph-v1d0.kryo | Bin 0 -> 1117 bytes
.../io/gryo/_3_3_0/traversalmetrics-v1d0.kryo | Bin 0 -> 429 bytes
.../io/gryo/_3_3_0/traverser-v1d0.kryo | Bin 0 -> 211 bytes
.../structure/io/gryo/_3_3_0/tree-v1d0.kryo | Bin 0 -> 762 bytes
.../structure/io/gryo/_3_3_0/uuid-v1d0.kryo | 1 +
.../structure/io/gryo/_3_3_0/vertex-v1d0.kryo | Bin 0 -> 202 bytes
.../io/gryo/_3_3_0/vertexproperty-v1d0.kryo | Bin 0 -> 18 bytes
.../structure/io/gryo/_3_3_0/year-v1d0.kryo | Bin 0 -> 5 bytes
.../io/gryo/_3_3_0/yearmonth-v1d0.kryo | Bin 0 -> 9 bytes
.../io/gryo/_3_3_0/zoneddatetime-v1d0.kryo | Bin 0 -> 45 bytes
.../io/gryo/_3_3_0/zoneoffset-v1d0.kryo | 1 +
gremlin-tools/pom.xml | 1 +
398 files changed, 11260 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/pom.xml
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/pom.xml b/gremlin-tools/gremlin-io-test/pom.xml
new file mode 100644
index 0000000..0ba73d3
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/pom.xml
@@ -0,0 +1,378 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <artifactId>gremlin-tools</artifactId>
+ <groupId>org.apache.tinkerpop</groupId>
+ <version>3.3.0-SNAPSHOT</version>
+ </parent>
+ <artifactId>gremlin-io-test</artifactId>
+ <name>Apache TinkerPop :: Gremlin IO Test</name>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.tinkerpop</groupId>
+ <artifactId>gremlin-driver</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tinkerpop</groupId>
+ <artifactId>tinkergraph-gremlin</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tinkerpop</groupId>
+ <artifactId>gremlin-test</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <optional>true</optional>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+
+ <profiles>
+ <profile>
+ <id>io</id>
+ <activation>
+ <activeByDefault>false</activeByDefault>
+ <property>
+ <name>io</name>
+ </property>
+ </activation>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <skipTests>true</skipTests>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.codehaus.gmavenplus</groupId>
+ <artifactId>gmavenplus-plugin</artifactId>
+ <dependencies>
+ <dependency>
+ <groupId>org.codehaus.groovy</groupId>
+ <artifactId>groovy-all</artifactId>
+ <version>${groovy.version}</version>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>log4j</groupId>
+ <artifactId>log4j</artifactId>
+ <version>1.2.17</version>
+ <scope>runtime</scope>
+ </dependency>
+ </dependencies>
+ <executions>
+ <execution>
+ <id>generate-io-files-graphson</id>
+ <phase>generate-test-resources</phase>
+ <goals>
+ <goal>execute</goal>
+ </goals>
+ <configuration>
+ <scripts>
+ <script>
+ <![CDATA[
+import java.time.*
+import java.nio.files.*
+import org.apache.tinkerpop.gremlin.driver.ser.*
+import org.apache.tinkerpop.gremlin.process.traversal.*
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.*
+import org.apache.tinkerpop.gremlin.structure.*
+import org.apache.tinkerpop.gremlin.structure.io.graphson.*
+import org.apache.tinkerpop.gremlin.driver.message.*
+import org.apache.tinkerpop.gremlin.process.traversal.step.*
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalOptionParent.Pick
+import org.apache.tinkerpop.gremlin.structure.io.Model
+
+new File("${project.build.directory}/dev-docs/").mkdirs()
+new File("${project.build.directory}/test-case-data/io/graphson/").mkdirs()
+new File("${project.build.directory}/test-case-data/io/gryo/").mkdirs()
+
+graph = TinkerFactory.createTheCrew()
+g = graph.traversal()
+
+model = Model.instance()
+
+toJsonV1d0NoTypes = { o, type, mapper, comment = "" ->
+ toJson(o, type, mapper, comment, "v1d0")
+}
+
+toJson = { o, type, mapper, comment = "", suffix = "" ->
+ def jsonSample = mapper.writerWithDefaultPrettyPrinter().writeValueAsString(o)
+
+ def fileToWriteTo = new File("${project.build.directory}/test-case-data/io/graphson/" + type.toLowerCase().replace(" ","") + "-" + suffix + ".json")
+ if (fileToWriteTo.exists()) fileToWriteTo.delete()
+ fileToWriteTo.withWriter{ it.write(jsonSample) }
+
+ return type + "\n" +
+ "^".multiply(type.length()) + "\n\n" +
+ (comment.isEmpty() ? "" : comment + "\n\n") +
+ "[source,json]\n" +
+ "----\n" +
+ jsonSample + "\n" +
+ "----\n" +
+ "\n"
+}
+
+writeSupportedV1Objects = { writer, mapper ->
+ writer.write("Graph Structure\n")
+ writer.write("~~~~~~~~~~~~~~~\n\n")
+ model.entries("Graph Structure").findAll{it.isCompatibleWith(GraphSONCompatibility.V1D0_3_3_0)}.each {
+ writer.write(toJsonV1d0NoTypes(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("RequestMessage\n")
+ writer.write("~~~~~~~~~~~~~~\n\n")
+ model.entries("RequestMessage").findAll{it.isCompatibleWith(GraphSONCompatibility.V1D0_3_3_0)}.each {
+ writer.write(toJsonV1d0NoTypes(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("ResponseMessage\n")
+ writer.write("~~~~~~~~~~~~~~~\n\n")
+ model.entries("ResponseMessage").findAll{it.isCompatibleWith(GraphSONCompatibility.V1D0_3_3_0)}.each {
+ writer.write(toJsonV1d0NoTypes(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("Time\n")
+ writer.write("~~~~\n\n")
+ model.entries("RequestMessage").findAll{it.isCompatibleWith(GraphSONCompatibility.V1D0_3_3_0)}.each {
+ writer.write(toJsonV1d0NoTypes(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+}
+
+mapper = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistry.instance()).
+ addCustomModule(new AbstractGraphSONMessageSerializerV1d0.GremlinServerModule()).
+ version(GraphSONVersion.V1_0).create().createMapper()
+
+v1GraphSONFile = new File("${project.build.directory}/dev-docs/out-graphson-1d0.txt")
+if (v1GraphSONFile.exists()) v1GraphSONFile.delete()
+new File("${project.build.directory}/dev-docs/out-graphson-1d0.txt").withWriter { writeSupportedV1Objects(it, mapper) }
+
+toJsonV2d0PartialTypes = { o, type, mapper, comment = "" ->
+ toJson(o, type, mapper, comment, "v2d0-partial")
+}
+
+toJsonV2d0NoTypes = { o, type, mapper, comment = "" ->
+ toJson(o, type, mapper, comment, "v2d0-no-types")
+}
+
+writeSupportedV2Objects = { writer, mapper, toJsonFunction ->
+ writer.write("Core\n")
+ writer.write("~~~~\n\n")
+ model.entries("Core").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("Graph Structure\n")
+ writer.write("~~~~~~~~~~~~~~~\n\n")
+ model.entries("Graph Structure").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("Graph Process\n")
+ writer.write("~~~~~~~~~~~~~\n\n")
+ model.entries("Graph Process").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("RequestMessage\n")
+ writer.write("~~~~~~~~~~~~~~\n\n")
+ model.entries("RequestMessage").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("ResponseMessage\n")
+ writer.write("~~~~~~~~~~~~~~~\n\n")
+ model.entries("ResponseMessage").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+
+ writer.write("\n")
+ writer.write("Extended\n")
+ writer.write("~~~~~~~~\n\n")
+ writer.write("""Note that the "extended" types require the addition of the separate `GraphSONXModuleV2d0` module as follows:\n
+[source,java]
+----
+mapper = GraphSONMapper.build().
+ typeInfo(TypeInfo.PARTIAL_TYPES).
+ addCustomModule(GraphSONXModuleV2d0.build().create(false)).
+ version(GraphSONVersion.V2_0).create().createMapper()
+----\n
+""")
+ model.entries("Extended").each {
+ writer.write(toJsonFunction(it.getObject(), it.getTitle(), mapper, it.getDescription()))
+ }
+}
+
+mapper = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistryV2d0.instance()).
+ typeInfo(TypeInfo.PARTIAL_TYPES).
+ addCustomModule(GraphSONXModuleV2d0.build().create(false)).
+ addCustomModule(new org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV2d0.GremlinServerModule()).
+ version(GraphSONVersion.V2_0).create().createMapper()
+
+file = new File("${project.build.directory}/dev-docs/out-graphson-2d0-partial.txt")
+if (file.exists()) file.delete()
+file.withWriter { writeSupportedV2Objects(it, mapper, toJsonV2d0PartialTypes) }
+
+mapper = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistryV2d0.instance()).
+ typeInfo(TypeInfo.NO_TYPES).
+ addCustomModule(GraphSONXModuleV2d0.build().create(false)).
+ addCustomModule(new org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV2d0.GremlinServerModule()).
+ version(GraphSONVersion.V2_0).create().createMapper()
+
+file = new File("${project.build.directory}/dev-docs/out-graphson-2d0-no-type.txt")
+if (file.exists()) file.delete()
+file.withWriter { writeSupportedV2Objects(it, mapper, toJsonV2d0NoTypes) }
+
+def ver = "_" + "${project.version}".replace(".","_").replace("-SNAPSHOT","")
+def target = "${project.basedir}/src/test/resources/org/apache/tinkerpop/gremlin/structure/io/graphson/" + ver
+def targetDir = new File(target)
+if (!targetDir.exists()) targetDir.mkdirs()
+new File("${project.build.directory}/test-case-data/io/graphson/").listFiles().each {
+ def copyTo = new File(target + "/" + it.name)
+ if (copyTo.exists()) copyTo.delete()
+ java.nio.file.Files.copy(it.toPath(), new File(target + "/" + it.name).toPath())
+}
+
+]]>
+ </script>
+ </scripts>
+ </configuration>
+ </execution>
+ <execution>
+ <id>generate-io-files-gryo</id>
+ <phase>generate-test-resources</phase>
+ <goals>
+ <goal>execute</goal>
+ </goals>
+ <configuration>
+ <scripts>
+ <script>
+ <![CDATA[
+import org.apache.tinkerpop.shaded.kryo.io.Output
+
+import java.time.*
+import java.nio.file.*
+import org.apache.tinkerpop.gremlin.driver.ser.*
+import org.apache.tinkerpop.gremlin.process.traversal.*
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.*
+import org.apache.tinkerpop.gremlin.structure.*
+import org.apache.tinkerpop.gremlin.structure.io.graphson.*
+import org.apache.tinkerpop.gremlin.driver.message.*
+import org.apache.tinkerpop.gremlin.process.traversal.step.*
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalOptionParent.Pick
+import org.apache.tinkerpop.gremlin.structure.io.gryo.*
+import org.apache.tinkerpop.gremlin.structure.io.*
+
+new File("${project.build.directory}/dev-docs/").mkdirs()
+new File("${project.build.directory}/test-case-data/io/gryo").mkdirs()
+
+graph = TinkerFactory.createTheCrew()
+g = graph.traversal()
+
+model = Model.instance()
+
+toGryo = { o, type, mapper, suffix = "" ->
+ def fileToWriteTo = new File("${project.build.directory}/test-case-data/io/gryo/" + type.toLowerCase().replace(" ","") + "-" + suffix + ".kryo")
+ if (fileToWriteTo.exists()) fileToWriteTo.delete()
+ final Output out = new Output(new FileOutputStream(fileToWriteTo))
+ mapper.writeObject(out, o)
+ out.close()
+}
+
+toGryoV1d0 = { o, type, mapper ->
+ toGryo(o, type, mapper, "v1d0")
+}
+
+writeSupportedObjects = { mapper, toGryoFunction ->
+ model.entries().findAll{it.hasGryoCompatibility()}.each {
+ if (it.getObject() instanceof Traversal)
+ toGryoFunction(it.getObject().bytecode, it.getTitle(), mapper)
+ else
+ toGryoFunction(it.getObject(), it.getTitle(), mapper)
+ }
+}
+
+mapper = GryoMapper.build().addRegistry(TinkerIoRegistryV2d0.getInstance()).create().createMapper()
+
+writeSupportedObjects(mapper, toGryoV1d0)
+
+def ver = "_" + "${project.version}".replace(".","_").replace("-SNAPSHOT","")
+def target = "${project.basedir}/src/test/resources/org/apache/tinkerpop/gremlin/structure/io/gryo/" + ver
+def targetDir = new File(target)
+if (!targetDir.exists()) targetDir.mkdirs()
+new File("${project.build.directory}/test-case-data/io/gryo/").listFiles().each {
+ def copyTo = new File(target + "/" + it.name)
+ if (copyTo.exists()) copyTo.delete()
+ java.nio.file.Files.copy(it.toPath(), new File(target + "/" + it.name).toPath())
+}
+
+]]>
+ </script>
+ </scripts>
+ </configuration>
+ </execution>
+ <execution>
+ <id>generate-io-model-csv</id>
+ <phase>generate-test-resources</phase>
+ <goals>
+ <goal>execute</goal>
+ </goals>
+ <configuration>
+ <scripts>
+ <script>
+ <![CDATA[
+import org.apache.tinkerpop.gremlin.structure.io.Model
+import java.io.File
+
+new File("${project.build.directory}/dev-docs/").mkdirs()
+Model.instance().saveAsCsv("${project.build.directory}/dev-docs/model.csv")
+]]>
+ </script>
+ </scripts>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+ </profile>
+ </profiles>
+
+</project>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Compatibility.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Compatibility.java b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Compatibility.java
new file mode 100644
index 0000000..7b9a5fe
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Compatibility.java
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io;
+
+import java.io.IOException;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public interface Compatibility {
+ public byte[] readFromResource(final String resource) throws IOException;
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Model.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Model.java b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Model.java
new file mode 100644
index 0000000..51d44b6
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/Model.java
@@ -0,0 +1,390 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io;
+
+import org.apache.tinkerpop.gremlin.driver.message.RequestMessage;
+import org.apache.tinkerpop.gremlin.driver.message.ResponseMessage;
+import org.apache.tinkerpop.gremlin.process.traversal.Bytecode;
+import org.apache.tinkerpop.gremlin.process.traversal.Operator;
+import org.apache.tinkerpop.gremlin.process.traversal.Order;
+import org.apache.tinkerpop.gremlin.process.traversal.P;
+import org.apache.tinkerpop.gremlin.process.traversal.Pop;
+import org.apache.tinkerpop.gremlin.process.traversal.SackFunctions;
+import org.apache.tinkerpop.gremlin.process.traversal.Scope;
+import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource;
+import org.apache.tinkerpop.gremlin.process.traversal.step.TraversalOptionParent;
+import org.apache.tinkerpop.gremlin.process.traversal.util.MutableMetrics;
+import org.apache.tinkerpop.gremlin.process.traversal.util.TraversalMetrics;
+import org.apache.tinkerpop.gremlin.structure.Column;
+import org.apache.tinkerpop.gremlin.structure.Direction;
+import org.apache.tinkerpop.gremlin.structure.Graph;
+import org.apache.tinkerpop.gremlin.structure.T;
+import org.apache.tinkerpop.gremlin.structure.VertexProperty;
+import org.apache.tinkerpop.gremlin.structure.io.graphson.GraphSONCompatibility;
+import org.apache.tinkerpop.gremlin.structure.io.gryo.GryoCompatibility;
+import org.apache.tinkerpop.gremlin.structure.util.star.StarGraph;
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.TinkerFactory;
+
+import java.io.File;
+import java.io.PrintWriter;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.net.InetAddress;
+import java.time.Duration;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.MonthDay;
+import java.time.OffsetDateTime;
+import java.time.OffsetTime;
+import java.time.Period;
+import java.time.Year;
+import java.time.YearMonth;
+import java.time.ZoneOffset;
+import java.time.ZonedDateTime;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public class Model {
+
+ private static final List<Compatibility> ALL = Collections.unmodifiableList(new ArrayList<Compatibility>() {{
+ addAll(Arrays.asList(GraphSONCompatibility.values()));
+ addAll(Arrays.asList(GryoCompatibility.values()));
+ }});
+
+ private static final List<Compatibility> GRAPHSON_ONLY = Collections.unmodifiableList(new ArrayList<Compatibility>() {{
+ addAll(Arrays.asList(GraphSONCompatibility.values()));
+ }});
+
+ private static final List<Compatibility> UNTYPED_GRAPHSON_ONLY = Collections.unmodifiableList(new ArrayList<Compatibility>() {{
+ add(GraphSONCompatibility.V1D0_3_2_3);
+ add(GraphSONCompatibility.V1D0_3_3_0);
+ add(GraphSONCompatibility.V2D0_NO_TYPE_3_2_3);
+ add(GraphSONCompatibility.V2D0_NO_TYPE_3_3_0);
+ }});
+
+ private static final List<Compatibility> GRYO_ONLY = Collections.unmodifiableList(new ArrayList<Compatibility>() {{
+ addAll(Arrays.asList(GryoCompatibility.values()));
+ }});
+
+ private static final Model model = new Model();
+
+ private final Map<String, List<Entry>> entries = new HashMap<>();
+
+ private Model() {
+ final Graph graph = TinkerFactory.createTheCrew();
+ final GraphTraversalSource g = graph.traversal();
+
+ addCoreEntry(File.class, "Class", GryoCompatibility.V1D0_3_2_3, GryoCompatibility.V1D0_3_3_0);
+ addCoreEntry(new Date(), "Date");
+ addCoreEntry(100.00d, "Double");
+ addCoreEntry(100.00f, "Float");
+ addCoreEntry(100, "Integer");
+ addCoreEntry(100L, "Long");
+ addCoreEntry(new java.sql.Timestamp(System.currentTimeMillis()), "Timestamp", GryoCompatibility.V1D0_3_2_3, GryoCompatibility.V1D0_3_3_0);
+ addCoreEntry(UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786"), "UUID");
+
+ addGraphStructureEntry(graph.edges().next(), "Edge");
+ addGraphStructureEntry(g.V().out().out().path().next(), "Path");
+ addGraphStructureEntry(graph.edges().next().properties().next(), "Property");
+ addGraphStructureEntry(StarGraph.of(graph.vertices().next()), "StarGraph");
+ addGraphStructureEntry(graph, "TinkerGraph", "`TinkerGraph` has a custom serializer that is registered as part of the `TinkerIoRegistry`.");
+ addGraphStructureEntry(g.V().out().out().tree().next(), "Tree");
+ addGraphStructureEntry(graph.vertices().next(), "Vertex");
+ addGraphStructureEntry(graph.vertices().next().properties().next(), "VertexProperty");
+
+ addEntry("Process", SackFunctions.Barrier.normSack, "Barrier", "", GRYO_ONLY);
+ addGraphProcessEntry(new Bytecode.Binding("x", 1), "Binding", "A \"Binding\" refers to a `Bytecode.Binding`.");
+ addGraphProcessEntry(g.V().hasLabel("person").out().in().tree(), "Bytecode", "The following `Bytecode` example represents the traversal of `g.V().hasLabel('person').out().in().tree()`. Obviously the serialized `Bytecode` woudl be quite different for the endless variations of commands that could be used together in the Gremlin language.");
+ addGraphProcessEntry(VertexProperty.Cardinality.list, "Cardinality");
+ addGraphProcessEntry(Column.keys, "Column");
+ addGraphProcessEntry(Direction.OUT, "Direction");
+ addGraphProcessEntry(Operator.sum, "Operator");
+ addGraphProcessEntry(Order.incr, "Order");
+ addGraphProcessEntry(TraversalOptionParent.Pick.any, "Pick");
+ addGraphProcessEntry(Pop.all, "Pop");
+ addGraphProcessEntry(org.apache.tinkerpop.gremlin.util.function.Lambda.function("{ it.get() }"), "Lambda");
+ final TraversalMetrics tm = g.V().hasLabel("person").out().out().tree().profile().next();
+ final MutableMetrics metrics = new MutableMetrics(tm.getMetrics(0));
+ metrics.addNested(new MutableMetrics(tm.getMetrics(1)));
+ addGraphProcessEntry(metrics, "Metrics");
+ addGraphProcessEntry(P.gt(0), "P");
+ addGraphProcessEntry(P.gt(0).and(P.lt(10)), "P and");
+ addGraphProcessEntry(P.gt(0).or(P.within(-1, -10, -100)), "P or");
+ addGraphProcessEntry(Scope.local, "Scope");
+ addGraphProcessEntry(T.label, "T");
+ addGraphProcessEntry(g.V().hasLabel("person").out().out().tree().profile().next(), "TraversalMetrics");
+ addGraphProcessEntry(g.V().hasLabel("person").asAdmin().nextTraverser(), "Traverser");
+
+ final Map<String,Object> requestBindings = new HashMap<String,Object>(){{
+ put("x", 1);
+ }};
+ final Map<String,Object> requestAliases = new HashMap<String,Object>(){{
+ put("g", "social");
+ }};
+ RequestMessage requestMessage;
+ requestMessage = RequestMessage.build("authentication").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("saslMechanism", "PLAIN", "sasl", "AHN0ZXBocGhlbgBwYXNzd29yZA==").create();
+ addRequestMessageEntry(requestMessage, "Authentication Response", "The following `RequestMessage` is an example of the response that should be made to a SASL-based authentication challenge.",
+ GraphSONCompatibility.V2D0_PARTIAL_3_2_3, GraphSONCompatibility.V2D0_PARTIAL_3_3_0, GryoCompatibility.V1D0_3_2_3, GryoCompatibility.V1D0_3_3_0);
+ requestMessage = RequestMessage.build("eval").processor("session").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("gremlin", "g.V(x)", "bindings", requestBindings, "language", "gremlin-groovy", "session", UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786")).create() ;
+ addRequestMessageEntry(requestMessage, "Session Eval", "The following `RequestMessage` is an example of a simple session request for a script evaluation with parameters.");
+ requestMessage = RequestMessage.build("eval").processor("session").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("gremlin", "social.V(x)", "bindings", requestBindings, "language", "gremlin-groovy", "aliases", requestAliases, "session", UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786")).create();
+ addRequestMessageEntry(requestMessage, "Session Eval", "The following `RequestMessage` is an example of a session request for a script evaluation with an alias that binds the `TraversalSource` of \"g\" to \"social\".");
+ requestMessage = RequestMessage.build("close").processor("session").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("session", UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786")).create();
+ addRequestMessageEntry(requestMessage, "Session Close", "The following `RequestMessage` is an example of a request to close a session.");
+ requestMessage = RequestMessage.build("eval").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("gremlin", "g.V(x)", "bindings", requestBindings, "language", "gremlin-groovy").create();
+ addRequestMessageEntry(requestMessage, "Sessionless Eval", "The following `RequestMessage` is an example of a simple sessionless request for a script evaluation with parameters.");
+ requestMessage = RequestMessage.build("eval").
+ overrideRequestId(UUID.fromString("cb682578-9d92-4499-9ebc-5c6aa73c5397")).
+ add("gremlin", "social.V(x)", "bindings", requestBindings, "language", "gremlin-groovy", "aliases", requestAliases).create();
+ addRequestMessageEntry(requestMessage, "Sessionless Eval", "The following `RequestMessage` is an example of a sessionless request for a script evaluation with an alias that binds the `TraversalSource` of \"g\" to \"social\".");
+
+ ResponseMessage responseMessage = ResponseMessage.build(UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786")).
+ code(org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode.AUTHENTICATE).create();
+ addResponseMessageEntry(responseMessage, "Authentication Challenge", "When authentication is enabled, an initial request to the server will result in an authentication challenge. The typical response message will appear as follows, but handling it could be different dependending on the SASL implementation (e.g. multiple challenges maybe requested in some cases, but no in the default provided by Gremlin Server).");
+ responseMessage = ResponseMessage.build(UUID.fromString("41d2e28a-20a4-4ab0-b379-d810dede3786")).
+ code(org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode.SUCCESS).
+ result(Collections.singletonList(graph.vertices().next())).create();
+ addResponseMessageEntry(responseMessage, "Standard Result", "The following `ResponseMessage` is a typical example of the typical successful response Gremlin Server will return when returning results from a script.");
+
+ addExtendedEntry(new BigDecimal(new java.math.BigInteger("123456789987654321123456789987654321")), "BigDecimal", "", UNTYPED_GRAPHSON_ONLY.toArray(new Compatibility[UNTYPED_GRAPHSON_ONLY.size()]));
+ addExtendedEntry(new BigInteger("123456789987654321123456789987654321"), "BigInteger", "", UNTYPED_GRAPHSON_ONLY.toArray(new Compatibility[UNTYPED_GRAPHSON_ONLY.size()]));
+ addExtendedEntry(new Byte("1"), "Byte", "", UNTYPED_GRAPHSON_ONLY.toArray(new Compatibility[UNTYPED_GRAPHSON_ONLY.size()]));
+ addExtendedEntry(java.nio.ByteBuffer.wrap("some bytes for you".getBytes()), "ByteBuffer", "",
+ GraphSONCompatibility.V1D0_3_2_3, GraphSONCompatibility.V1D0_3_3_0, GraphSONCompatibility.V2D0_NO_TYPE_3_2_3, GraphSONCompatibility.V2D0_NO_TYPE_3_3_0,
+ GryoCompatibility.V1D0_3_2_3, GryoCompatibility.V1D0_3_3_0);
+ addExtendedEntry("x".charAt(0), "Char", "", UNTYPED_GRAPHSON_ONLY.toArray(new Compatibility[UNTYPED_GRAPHSON_ONLY.size()]));
+ addExtendedEntry(Duration.ofDays(5), "Duration","The following example is a `Duration` of five days.");
+ try {
+ addExtendedEntry(InetAddress.getByName("localhost"), "InetAddress", "",
+ GraphSONCompatibility.V1D0_3_2_3, GraphSONCompatibility.V1D0_3_3_0, GraphSONCompatibility.V2D0_NO_TYPE_3_2_3, GraphSONCompatibility.V2D0_NO_TYPE_3_3_0,
+ GryoCompatibility.V1D0_3_2_3, GryoCompatibility.V1D0_3_3_0);
+ } catch (Exception ex) {
+ throw new RuntimeException(ex);
+ }
+ addExtendedEntry(Instant.now(), "Instant");
+ addExtendedEntry(LocalDate.of(2016, 1, 1), "LocalDate");
+ addExtendedEntry(LocalDateTime.of(2016, 1, 1, 12, 30), "LocalDateTime");
+ addExtendedEntry(LocalTime.of(12, 30, 45), "LocalTime");
+ addExtendedEntry(MonthDay.of(1, 1), "MonthDay");
+ addExtendedEntry(OffsetDateTime.now(), "OffsetDateTime");
+ addExtendedEntry(OffsetTime.now(), "OffsetTime");
+ addExtendedEntry(Period.of(1, 6, 15), "Period", "The following example is a `Period` of one year, six months and fifteen days.");
+ addExtendedEntry(new Short("100"), "Short", "", UNTYPED_GRAPHSON_ONLY.toArray(new Compatibility[UNTYPED_GRAPHSON_ONLY.size()]));
+ addExtendedEntry(Year.of(2016), "Year", "The following example is of the `Year` \"2016\".");
+ addExtendedEntry(YearMonth.of(2016, 6), "YearMonth", "The following example is a `YearMonth` of \"June 2016\"");
+ addExtendedEntry(ZonedDateTime.now(), "ZonedDateTime");
+ addExtendedEntry(ZoneOffset.ofHoursMinutesSeconds(3, 6, 9), "ZoneOffset", "The following example is a `ZoneOffset` of three hours, six minutes, and nine seconds.");
+ }
+
+ public static Model instance() {
+ return model;
+ }
+
+ public Set<String> groups() {
+ return Collections.unmodifiableSet(entries.keySet());
+ }
+
+ public List<Entry> entries(final String key) {
+ return Collections.unmodifiableList(entries.get(key));
+ }
+
+ public List<Entry> entries() {
+ return Collections.unmodifiableList(entries.values().stream().flatMap(Collection::stream).collect(Collectors.toList()));
+ }
+
+ public Optional<Entry> find(final String resource) {
+ return entries.values().stream().flatMap(Collection::stream).filter(e -> e.getResourceName().equals(resource)).findFirst();
+ }
+
+ private void addCoreEntry(final Object obj, final String title) {
+ addEntry("Core", obj, title, "");
+ }
+
+ private void addCoreEntry(final Object obj, final String title, final Compatibility... incompatibleWith) {
+ addEntry("Core", obj, title, "", incompatibleWith);
+ }
+
+ private void addGraphStructureEntry(final Object obj, final String title) {
+ addGraphStructureEntry(obj, title, "");
+ }
+
+ private void addGraphStructureEntry(final Object obj, final String title, final String description) {
+ addEntry("Graph Structure", obj, title, description);
+ }
+
+ private void addGraphProcessEntry(final Object obj, final String title) {
+ addGraphProcessEntry(obj, title, "");
+ }
+
+ private void addGraphProcessEntry(final Object obj, final String title, final String description) {
+ addEntry("Graph Process", obj, title, description);
+ }
+
+ private void addRequestMessageEntry(final Object obj, final String title, final String description) {
+ addEntry("RequestMessage", obj, title, description, GRAPHSON_ONLY);
+ }
+
+ private void addRequestMessageEntry(final Object obj, final String title, final String description, final Compatibility... incompatibleWith) {
+ addEntry("RequestMessage", obj, title, description, incompatibleWith);
+ }
+
+ private void addResponseMessageEntry(final Object obj, final String title, final String description) {
+ addEntry("ResponseMessage", obj, title, description, GRAPHSON_ONLY);
+ }
+
+ private void addResponseMessageEntry(final Object obj, final String title, final String description, final Compatibility... incompatibleWith) {
+ addEntry("ResponseMessage", obj, title, description, incompatibleWith);
+ }
+
+ private void addExtendedEntry(final Object obj, final String title) {
+ addExtendedEntry(obj, title, "");
+ }
+
+ private void addExtendedEntry(final Object obj, final String title, final String description) {
+ addEntry("Extended", obj, title, description);
+ }
+
+ private void addExtendedEntry(final Object obj, final String title, final String description, final Compatibility... incompatibleWith) {
+ addEntry("Extended", obj, title, description, incompatibleWith);
+ }
+
+ private void addEntry(final String group, final Object obj, final String title, final String description) {
+ addEntry(group, obj, title, description, ALL);
+ }
+
+ private void addEntry(final String group, final Object obj, final String title, final String description, final List<Compatibility> compatibleWith) {
+ if (!entries.containsKey(group))
+ entries.put(group, new ArrayList<>());
+
+ entries.get(group).add(new Entry(title, obj, description, compatibleWith));
+ }
+
+ private void addEntry(final String group, final Object obj, final String title, final String description, final Compatibility... incompatibleWith) {
+ addEntry(group, obj, title, description, Collections.unmodifiableList(ALL.stream()
+ .filter(c -> !Arrays.asList(incompatibleWith).contains(c))
+ .collect(Collectors.toList())));
+ }
+
+ public void saveAsCsv(final String file) throws Exception {
+ final File f = new File(file);
+ f.getParentFile().mkdirs();
+
+ final List<Compatibility> compatibilities = Stream.concat(
+ Stream.of(GraphSONCompatibility.values()),
+ Stream.of(GryoCompatibility.values())).collect(Collectors.toList());
+
+ final List<String> headers = new ArrayList<>();
+ headers.add("resource");
+ headers.addAll(compatibilities.stream().map(c -> {
+ if (c instanceof GryoCompatibility)
+ return ((GryoCompatibility) c).name();
+ else if (c instanceof GraphSONCompatibility)
+ return ((GraphSONCompatibility) c).name();
+ else
+ throw new IllegalStateException("No support for the provided Compatibility type");
+ }).collect(Collectors.toList()));
+
+ try (final PrintWriter writer = new PrintWriter(f)) {
+ writer.println(String.join("\t", headers));
+
+ final List<Entry> sorted = new ArrayList<>(entries());
+ Collections.sort(sorted, (o1, o2) -> o1.getResourceName().compareTo(o2.getResourceName()));
+
+ sorted.forEach(e -> {
+ writer.write(e.getResourceName());
+ writer.write("\t");
+ compatibilities.forEach(c -> {
+ writer.print(e.isCompatibleWith(c));
+ writer.print("\t");
+ });
+
+ writer.println();
+ });
+ }
+ }
+
+ public static class Entry {
+
+ private final String title;
+ private final Object obj;
+ private final String description;
+ private final List<Compatibility> compatibleWith;
+
+ public Entry(final String title, final Object obj, final String description, final List<Compatibility> compatibleWith) {
+ this.title = title;
+ this.obj = obj;
+ this.description = description;
+ this.compatibleWith = compatibleWith;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public String getResourceName() {
+ return title.replace(" ", "").toLowerCase();
+ }
+
+ public Object getObject() {
+ return obj;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public boolean isCompatibleWith(final Compatibility compatibility) {
+ return compatibleWith.contains(compatibility);
+ }
+
+ public boolean hasGryoCompatibility() {
+ return compatibleWith.stream().anyMatch(c -> c instanceof GryoCompatibility);
+ }
+
+ public boolean hasGraphSONCompatibility() {
+ return compatibleWith.stream().anyMatch(c -> c instanceof GryoCompatibility);
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONCompatibility.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONCompatibility.java b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONCompatibility.java
new file mode 100644
index 0000000..46b43e5
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONCompatibility.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io.graphson;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.tinkerpop.gremlin.structure.io.Compatibility;
+
+import java.io.File;
+import java.io.IOException;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public enum GraphSONCompatibility implements Compatibility {
+ V1D0_3_2_3("3.2.3", "1.0", "v1d0"),
+ V2D0_PARTIAL_3_2_3("3.2.3", "2.0", "v2d0-partial"),
+ V2D0_NO_TYPE_3_2_3("3.2.3", "2.0", "v2d0-no-types"),
+ V1D0_3_3_0("3.3.0", "2.0", "v1d0"),
+ V2D0_PARTIAL_3_3_0("3.3.0", "2.0", "v2d0-partial"),
+ V2D0_NO_TYPE_3_3_0("3.3.0", "2.0", "v2d0-no-types");
+
+ private static final String SEP = File.separator;
+
+ private final String graphSONVersion;
+ private final String tinkerpopVersion;
+ private final String configuration;
+
+ GraphSONCompatibility(final String tinkerpopVersion, final String graphSONVersion, final String configuration) {
+ this.tinkerpopVersion = tinkerpopVersion;
+ this.configuration = configuration;
+ this.graphSONVersion = graphSONVersion;
+ }
+
+ public byte[] readFromResource(final String resource) throws IOException {
+ final String testResource = "_" + tinkerpopVersion.replace(".", "_") + SEP + resource + "-" + configuration + ".json";
+ return IOUtils.toByteArray(getClass().getResourceAsStream(testResource));
+ }
+
+ @Override
+ public String toString() {
+ return tinkerpopVersion + "-" + configuration;
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/gryo/GryoCompatibility.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/gryo/GryoCompatibility.java b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/gryo/GryoCompatibility.java
new file mode 100644
index 0000000..11a89b9
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/main/java/org/apache/tinkerpop/gremlin/structure/io/gryo/GryoCompatibility.java
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io.gryo;
+
+import org.apache.commons.io.IOUtils;
+import org.apache.tinkerpop.gremlin.structure.io.Compatibility;
+
+import java.io.File;
+import java.io.IOException;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public enum GryoCompatibility implements Compatibility {
+ V1D0_3_2_3("3.2.3", "1.0", "v1d0"),
+ V1D0_3_3_0("3.3.0", "1.0", "v1d0");
+
+ private static final String SEP = File.separator;
+
+ private final String gryoVersion;
+ private final String tinkerpopVersion;
+ private final String configuration;
+
+ GryoCompatibility(final String tinkerpopVersion, final String gryoVersion, final String configuration) {
+ this.tinkerpopVersion = tinkerpopVersion;
+ this.gryoVersion = gryoVersion;
+ this.configuration = configuration;
+ }
+
+ public byte[] readFromResource(final String resource) throws IOException {
+ final String testResource = "_" + tinkerpopVersion.replace(".", "_") + SEP + resource + "-" + configuration + ".kryo";
+ return IOUtils.toByteArray(getClass().getResourceAsStream(testResource));
+ }
+
+ @Override
+ public String toString() {
+ return tinkerpopVersion + "-" + configuration;
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractCompatibilityTest.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractCompatibilityTest.java b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractCompatibilityTest.java
new file mode 100644
index 0000000..b0d7961
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractCompatibilityTest.java
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io;
+
+import static org.hamcrest.core.Is.is;
+import static org.junit.Assume.assumeThat;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public abstract class AbstractCompatibilityTest {
+ protected final Model model = Model.instance();
+
+ public abstract Compatibility getCompatibility();
+
+ protected void assumeCompatibility(final String resource) {
+ final Model.Entry e = model.find(resource).orElseThrow(() -> new IllegalStateException("Could not find model"));
+ assumeThat("Test model is not compatible with IO", e.isCompatibleWith(getCompatibility()), is(true));
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractTypedCompatibilityTest.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractTypedCompatibilityTest.java b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractTypedCompatibilityTest.java
new file mode 100644
index 0000000..bb174be
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractTypedCompatibilityTest.java
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io;
+
+import org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode;
+import org.apache.tinkerpop.gremlin.process.traversal.SackFunctions;
+import org.junit.Test;
+
+import java.math.BigDecimal;
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotSame;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public abstract class AbstractTypedCompatibilityTest extends AbstractCompatibilityTest {
+
+ public abstract <T> T read(final byte[] bytes, final Class<T> clazz) throws Exception;
+
+ public abstract byte[] write(final Object o, final Class<?> clazz) throws Exception;
+
+ @Test
+ public void shouldReadWriteAuthenticationChallenge() throws Exception {
+ assumeCompatibility("authenticationchallenge");
+
+ final HashMap fromStatic = read(getCompatibility().readFromResource("authenticationchallenge"), HashMap.class);
+ final HashMap recycled = read(write(fromStatic, HashMap.class), HashMap.class);
+ assertNotSame(fromStatic, recycled);
+ assertEquals("41d2e28a-20a4-4ab0-b379-d810dede3786", recycled.get("requestId"));
+ assertEquals(ResponseStatusCode.AUTHENTICATE.getValue(), ((Map) recycled.get("status")).get("code"));
+ }
+
+ @Test
+ public void shouldReadWriteAuthenticationResponse() throws Exception {
+ assumeCompatibility("authenticationresponse");
+
+ final HashMap fromStatic = read(getCompatibility().readFromResource("authenticationresponse"), HashMap.class);
+ final HashMap recycled = read(write(fromStatic, HashMap.class), HashMap.class);
+ assertNotSame(fromStatic, recycled);
+ assertEquals("cb682578-9d92-4499-9ebc-5c6aa73c5397", recycled.get("requestId"));
+ assertEquals("authentication", recycled.get("op"));
+ assertEquals("", recycled.get("processor"));
+ assertEquals("PLAIN", ((Map) recycled.get("args")).get("saslMechanism"));
+ assertEquals("AHN0ZXBocGhlbgBwYXNzd29yZA==", ((Map) recycled.get("args")).get("sasl"));
+ }
+
+ @Test
+ public void shouldReadWriteBarrier() throws Exception {
+ assumeCompatibility("barrier");
+
+ final SackFunctions.Barrier fromStatic = read(getCompatibility().readFromResource("barrier"), SackFunctions.Barrier.class);
+ final SackFunctions.Barrier recycled = read(write(fromStatic, SackFunctions.Barrier.class), SackFunctions.Barrier.class);
+ assertEquals(fromStatic, recycled);
+ }
+
+ @Test
+ public void shouldReadWriteBigDecimal() throws Exception {
+ assumeCompatibility("bigdecimal");
+
+ final BigDecimal fromStatic = read(getCompatibility().readFromResource("bigdecimal"), BigDecimal.class);
+ final BigDecimal recycled = read(write(fromStatic, BigDecimal.class), BigDecimal.class);
+ assertNotSame(fromStatic, recycled);
+ assertEquals(fromStatic, recycled);
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractUntypedCompatibilityTest.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractUntypedCompatibilityTest.java b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractUntypedCompatibilityTest.java
new file mode 100644
index 0000000..db57145
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/AbstractUntypedCompatibilityTest.java
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io;
+
+import org.apache.tinkerpop.gremlin.driver.message.ResponseStatusCode;
+import org.junit.Test;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotSame;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+public abstract class AbstractUntypedCompatibilityTest extends AbstractCompatibilityTest {
+
+ public abstract <T> T read(final byte[] bytes, final Class<T> clazz) throws Exception;
+
+ public abstract byte[] write(final Object o, final Class<?> clazz) throws Exception;
+
+ @Test
+ public void shouldReadWriteAuthenticationChallenge() throws Exception {
+ assumeCompatibility("authenticationchallenge");
+
+ final HashMap fromStatic = read(getCompatibility().readFromResource("authenticationchallenge"), HashMap.class);
+ final HashMap recycled = read(write(fromStatic, HashMap.class), HashMap.class);
+ assertNotSame(fromStatic, recycled);
+ assertEquals("41d2e28a-20a4-4ab0-b379-d810dede3786", recycled.get("requestId"));
+ assertEquals(ResponseStatusCode.AUTHENTICATE.getValue(), ((Map) recycled.get("status")).get("code"));
+ }
+
+ @Test
+ public void shouldReadWriteAuthenticationResponse() throws Exception {
+ assumeCompatibility("authenticationresponse");
+
+ final HashMap fromStatic = read(getCompatibility().readFromResource("authenticationresponse"), HashMap.class);
+ final HashMap recycled = read(write(fromStatic, HashMap.class), HashMap.class);
+ assertNotSame(fromStatic, recycled);
+ assertEquals("cb682578-9d92-4499-9ebc-5c6aa73c5397", recycled.get("requestId"));
+ assertEquals("authentication", recycled.get("op"));
+ assertEquals("", recycled.get("processor"));
+ assertEquals("PLAIN", ((Map) recycled.get("args")).get("saslMechanism"));
+ assertEquals("AHN0ZXBocGhlbgBwYXNzd29yZA==", ((Map) recycled.get("args")).get("sasl"));
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONTypedCompatibilityTest.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONTypedCompatibilityTest.java b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONTypedCompatibilityTest.java
new file mode 100644
index 0000000..52c0cb4
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONTypedCompatibilityTest.java
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io.graphson;
+
+import org.apache.tinkerpop.gremlin.structure.io.AbstractTypedCompatibilityTest;
+import org.apache.tinkerpop.gremlin.structure.io.Compatibility;
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.TinkerIoRegistryV2d0;
+import org.apache.tinkerpop.shaded.jackson.databind.ObjectMapper;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import java.util.Arrays;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+@RunWith(Parameterized.class)
+public class GraphSONTypedCompatibilityTest extends AbstractTypedCompatibilityTest {
+
+ private static ObjectMapper mapperV2 = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistryV2d0.instance()).
+ typeInfo(TypeInfo.PARTIAL_TYPES).
+ addCustomModule(GraphSONXModuleV2d0.build().create(false)).
+ addCustomModule(new org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV2d0.GremlinServerModule()).
+ version(GraphSONVersion.V2_0).create().createMapper();
+
+ @Parameterized.Parameters(name = "expect({0})")
+ public static Iterable<Object[]> data() {
+ return Arrays.asList(new Object[][]{
+ {GraphSONCompatibility.V2D0_PARTIAL_3_2_3, mapperV2 },
+ {GraphSONCompatibility.V2D0_PARTIAL_3_3_0, mapperV2 }});
+ }
+
+ @Parameterized.Parameter(value = 0)
+ public Compatibility compatibility;
+
+ @Parameterized.Parameter(value = 1)
+ public ObjectMapper mapper;
+
+ @Override
+ public <T> T read(final byte[] bytes, final Class<T> clazz) throws Exception {
+ return mapper.readValue(bytes, clazz);
+ }
+
+ @Override
+ public byte[] write(final Object o, final Class<?> clazz) throws Exception {
+ return mapper.writeValueAsBytes(o);
+ }
+
+ @Override
+ public Compatibility getCompatibility() {
+ return compatibility;
+ }
+}
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/5f5848b1/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONUntypedCompatibilityTest.java
----------------------------------------------------------------------
diff --git a/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONUntypedCompatibilityTest.java b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONUntypedCompatibilityTest.java
new file mode 100644
index 0000000..070308b
--- /dev/null
+++ b/gremlin-tools/gremlin-io-test/src/test/java/org/apache/tinkerpop/gremlin/structure/io/graphson/GraphSONUntypedCompatibilityTest.java
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tinkerpop.gremlin.structure.io.graphson;
+
+import org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV1d0;
+import org.apache.tinkerpop.gremlin.structure.io.AbstractUntypedCompatibilityTest;
+import org.apache.tinkerpop.gremlin.structure.io.Compatibility;
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.TinkerIoRegistry;
+import org.apache.tinkerpop.gremlin.tinkergraph.structure.TinkerIoRegistryV2d0;
+import org.apache.tinkerpop.shaded.jackson.databind.ObjectMapper;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import java.util.Arrays;
+
+/**
+ * @author Stephen Mallette (http://stephen.genoprime.com)
+ */
+@RunWith(Parameterized.class)
+public class GraphSONUntypedCompatibilityTest extends AbstractUntypedCompatibilityTest {
+
+ private static ObjectMapper mapperV1 = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistry.instance()).
+ addCustomModule(new AbstractGraphSONMessageSerializerV1d0.GremlinServerModule()).
+ version(GraphSONVersion.V1_0).create().createMapper();
+
+ private static ObjectMapper mapperV2 = GraphSONMapper.build().
+ addRegistry(TinkerIoRegistryV2d0.instance()).
+ typeInfo(TypeInfo.NO_TYPES).
+ addCustomModule(GraphSONXModuleV2d0.build().create(false)).
+ addCustomModule(new org.apache.tinkerpop.gremlin.driver.ser.AbstractGraphSONMessageSerializerV2d0.GremlinServerModule()).
+ version(GraphSONVersion.V2_0).create().createMapper();
+
+ @Parameterized.Parameters(name = "expect({0})")
+ public static Iterable<Object[]> data() {
+ return Arrays.asList(new Object[][]{
+ {GraphSONCompatibility.V1D0_3_2_3, mapperV1 },
+ {GraphSONCompatibility.V1D0_3_2_3, mapperV2 },
+ {GraphSONCompatibility.V2D0_NO_TYPE_3_2_3, mapperV2 },
+ {GraphSONCompatibility.V1D0_3_3_0, mapperV1 },
+ {GraphSONCompatibility.V1D0_3_3_0, mapperV2 },
+ {GraphSONCompatibility.V2D0_NO_TYPE_3_3_0, mapperV2 }
+ });
+ }
+
+ @Parameterized.Parameter(value = 0)
+ public Compatibility compatibility;
+
+ @Parameterized.Parameter(value = 1)
+ public ObjectMapper mapper;
+
+ @Override
+ public <T> T read(final byte[] bytes, final Class<T> clazz) throws Exception {
+ return mapper.readValue(bytes, clazz);
+ }
+
+ @Override
+ public byte[] write(final Object o, final Class<?> clazz) throws Exception {
+ return mapper.writeValueAsBytes(o);
+ }
+
+ @Override
+ public Compatibility getCompatibility() {
+ return compatibility;
+ }
+}