Merge branch 'TINKERPOP-1585' into tp32
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/2d824cf2 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/2d824cf2 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/2d824cf2 Branch: refs/heads/tp32 Commit: 2d824cf29f7d914405e262f4111aa2f5a7c272dc Parents: c3e6ed9 3fd74fc Author: Marko A. Rodriguez <[email protected]> Authored: Mon Jan 9 07:54:03 2017 -0700 Committer: Marko A. Rodriguez <[email protected]> Committed: Mon Jan 9 07:54:03 2017 -0700 ---------------------------------------------------------------------- CHANGELOG.asciidoc | 5 + .../process/computer/MemoryComputeKey.java | 24 +++- .../traversal/TraversalVertexProgram.java | 20 +++- .../computer/traversal/WorkerExecutor.java | 2 +- .../traversal/step/branch/RepeatStep.java | 17 ++- .../traversal/step/filter/DedupGlobalStep.java | 42 ++++--- .../process/traversal/step/map/GroupStep.java | 21 +++- .../traversal/step/map/OrderGlobalStep.java | 13 ++- .../optimization/RepeatUnrollStrategy.java | 6 +- .../tinkerpop/gremlin/util/Serializer.java | 4 + .../util/function/ChainedComparator.java | 18 ++- .../step/filter/GroovyDedupTest.groovy | 5 + .../traversal/step/filter/DedupTest.java | 20 +++- .../SparkInterceptorStrategyTest.java | 2 +- .../process/computer/TinkerGraphComputer.java | 22 ++-- .../computer/TinkerGraphComputerView.java | 32 +++--- .../process/computer/TinkerMemory.java | 2 +- .../process/computer/TinkerWorkerMemory.java | 109 +++++++++++++++++++ .../process/computer/TinkerWorkerPool.java | 43 +++++++- 19 files changed, 340 insertions(+), 67 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/2d824cf2/CHANGELOG.asciidoc ---------------------------------------------------------------------- diff --cc CHANGELOG.asciidoc index c090940,d7f4256..805db7b --- a/CHANGELOG.asciidoc +++ b/CHANGELOG.asciidoc @@@ -26,10 -26,13 +26,15 @@@ image::https://raw.githubusercontent.co TinkerPop 3.2.4 (Release Date: NOT OFFICIALLY RELEASED YET) ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ +* Fixed a bug in `LazyBarrierStrategy` where `profile()` was deactivating it accidentally. + * Fixed a bug in `RepeatUnrollStrategy` where stateful `DedupGlobalStep` was cloned and thus, maintained two deduplication sets. * Added documentation around "terminal steps" in Gremlin: `hasNext()`, `next()`, `toList()`, etc. +* Added `CloseableIterator` to allow `Graph` providers who open expensive resources a way to let users release them. * Fixed minor bug in `gremlin-driver` where closing a session-based `Client` without initializing it could generate an error. + * Relieved synchronization pressure in various areas of `TinkerGraphComputer`. + * Fixed an optimization bug in OLAP-based `DedupGlobalStep` where deduping occurred twice. + * `MemoryComputeKey` now implements `Cloneable` which is useful for `BiOperator` reducers that maintain thread-unsafe state. + * `TinkerGraphComputer` now supports distributed `Memory` with lock-free partition aggregation. * `TinkerGraph` Gryo and GraphSON deserialization is now configured to use multi-properties. * Changed behavior of `ElementHelper.areEqual(Property, Property)` to not throw exceptions with `null` arguments. * Added `GryoVersion` for future flexibility when introducing a new verison of Gryo and moved serializer registrations to it.
