Merge remote-tracking branch 'remotes/upstream/ignite-2977' into ignite-2979
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0f376d7b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0f376d7b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0f376d7b Branch: refs/heads/ignite-2977 Commit: 0f376d7b96552062636987ac0d3e8bd1ea5fa25d Parents: 0778859 fcb2341 Author: Pavel Tupitsyn <[email protected]> Authored: Wed Apr 13 12:25:30 2016 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Wed Apr 13 12:25:30 2016 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheProcessor.java | 35 +- .../processors/hadoop/HadoopNoopProcessor.java | 24 +- .../processors/igfs/IgfsDeleteWorker.java | 16 +- .../processors/igfs/IgfsIpcHandler.java | 12 +- .../processors/igfs/IgfsMetaManager.java | 26 +- .../internal/processors/igfs/IgfsUtils.java | 34 ++ ...IgfsMetaDirectoryListingRemoveProcessor.java | 2 - .../PlatformDefaultJavaObjectFactory.java | 6 +- .../PlatformJavaObjectFactoryProxy.java | 35 +- .../platform/PlatformNoopProcessor.java | 4 +- .../platform/PlatformProcessorImpl.java | 9 + .../platform/utils/PlatformUtils.java | 4 +- .../platform/PlatformJavaObjectFactory.java | 8 +- .../local/LocalAffinityFunctionTest.java | 80 ++++ .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 26 +- ...latformDefaultJavaObjectFactorySelfTest.java | 185 +++++++++ .../PlatformJavaObjectFactoryProxySelfTest.java | 220 ++++++++++ .../platform/javaobject/TestJavaObject.java | 271 +++++++++++++ .../javaobject/TestJavaObjectNoDefaultCtor.java | 49 +++ .../TestJavaObjectNoDefaultCtorFactory.java | 68 ++++ .../ignite/testsuites/IgniteBasicTestSuite.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite.java | 2 + .../testsuites/IgnitePlatformsTestSuite.java | 41 ++ .../hadoop/igfs/HadoopIgfsWrapper.java | 11 +- .../ignite/igfs/Hadoop1DualAbstractTest.java | 2 +- .../apache/ignite/igfs/IgfsEventsTestSuite.java | 6 + ...IgniteHadoopFileSystemHandshakeSelfTest.java | 121 ++++-- .../hadoop/HadoopAbstractMapReduceTest.java | 405 +++++++++++++++++++ .../processors/hadoop/HadoopErrorSimulator.java | 326 +++++++++++++++ .../HadoopMapReduceErrorResilienceTest.java | 154 +++++++ .../processors/hadoop/HadoopMapReduceTest.java | 380 +---------------- .../hadoop/HadoopNoHadoopMapReduceTest.java | 47 +++ .../hadoop/HadoopSnappyFullMapReduceTest.java | 8 + .../hadoop/examples/HadoopWordCount1Map.java | 12 + .../hadoop/examples/HadoopWordCount1Reduce.java | 5 + .../hadoop/examples/HadoopWordCount2.java | 2 +- .../examples/HadoopWordCount2Combiner.java | 45 +++ .../hadoop/examples/HadoopWordCount2Mapper.java | 19 +- .../examples/HadoopWordCount2Reducer.java | 43 +- .../testsuites/IgniteHadoopTestSuite.java | 10 +- .../Cache/Query/CacheQueriesTest.cs | 13 +- .../Compute/MixedClusterTest.cs | 122 ++++-- .../Config/cache-query.xml | 2 + 43 files changed, 2390 insertions(+), 502 deletions(-) ----------------------------------------------------------------------
