Merge branch 'master' into ignite-2234
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0f36404f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0f36404f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0f36404f Branch: refs/heads/ignite-2234 Commit: 0f36404f74fc70d8228a652ae5f1e13aad059f75 Parents: b09b4a3 10012b4 Author: vozerov-gridgain <[email protected]> Authored: Mon Jan 11 18:27:23 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Mon Jan 11 18:27:23 2016 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 11 + README.md | 194 ++++++ RELEASE_NOTES.txt | 2 + assembly/release-fabric-base.xml | 7 + assembly/release-sources.xml | 79 +++ doap_Ignite.rdf | 67 ++ examples/pom.xml | 2 +- examples/schema-import/pom.xml | 2 +- .../hibernate/HibernateL2CacheExample.java | 26 +- .../hibernate/CacheHibernateStoreExample.java | 5 + .../store/auto/CacheBinaryAutoStoreExample.java | 1 + .../examples/datagrid/CacheAffinityExample.java | 5 + .../examples/datagrid/CacheApiExample.java | 5 + .../examples/datagrid/CacheAsyncApiExample.java | 5 + .../datagrid/CacheContinuousQueryExample.java | 5 + .../datagrid/CacheDataStreamerExample.java | 5 + .../datagrid/CacheEntryProcessorExample.java | 5 + .../examples/datagrid/CacheEventsExample.java | 5 + .../examples/datagrid/CacheQueryExample.java | 6 + .../datagrid/CacheTransactionExample.java | 6 +- .../starschema/CacheStarSchemaExample.java | 10 +- .../store/auto/CacheAutoStoreExample.java | 5 + .../store/jdbc/CacheJdbcStoreExample.java | 5 + .../store/spring/CacheSpringStoreExample.java | 5 + .../streaming/StreamTransformerExample.java | 4 + .../streaming/StreamVisitorExample.java | 13 +- .../streaming/wordcount/QueryWords.java | 51 +- .../socket/WordsSocketStreamerServer.java | 86 +-- .../java8/datagrid/CacheAffinityExample.java | 5 + .../java8/datagrid/CacheApiExample.java | 5 + .../java8/datagrid/CacheAsyncApiExample.java | 5 + .../datagrid/CacheEntryProcessorExample.java | 5 + .../streaming/StreamTransformerExample.java | 9 +- .../java8/streaming/StreamVisitorExample.java | 5 + modules/aop/pom.xml | 4 +- modules/apache-license-gen/pom.xml | 2 +- modules/aws/pom.xml | 2 +- modules/camel/pom.xml | 2 +- modules/clients/pom.xml | 4 +- modules/cloud/pom.xml | 2 +- modules/codegen/pom.xml | 2 +- modules/core/pom.xml | 2 +- .../configuration/FileSystemConfiguration.java | 54 +- .../org/apache/ignite/igfs/IgfsUserContext.java | 16 +- .../igfs/secondary/IgfsSecondaryFileSystem.java | 14 - .../apache/ignite/internal/IgniteKernal.java | 7 +- .../ignite/internal/IgniteNodeAttributes.java | 3 + .../GridDistributedTxRemoteAdapter.java | 12 +- .../dht/CacheDistributedGetFutureAdapter.java | 10 +- .../distributed/dht/GridDhtTxFinishFuture.java | 15 +- .../cache/distributed/dht/GridDhtTxLocal.java | 31 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 48 +- .../dht/GridPartitionedGetFuture.java | 2 +- .../distributed/near/GridNearGetFuture.java | 2 +- ...arOptimisticSerializableTxPrepareFuture.java | 94 +-- .../near/GridNearOptimisticTxPrepareFuture.java | 63 +- .../GridNearPessimisticTxPrepareFuture.java | 6 +- .../cache/distributed/near/GridNearTxLocal.java | 69 +- .../near/GridNearTxPrepareFutureAdapter.java | 8 +- .../cache/local/GridLocalLockFuture.java | 19 +- .../cache/transactions/IgniteTxAdapter.java | 24 +- .../cache/transactions/IgniteTxEntry.java | 12 +- .../transactions/IgniteTxLocalAdapter.java | 38 +- .../version/GridCachePlainVersionedEntry.java | 2 +- .../processors/hadoop/HadoopPayloadAware.java | 28 + .../ignite/internal/processors/igfs/IgfsEx.java | 13 - .../internal/processors/igfs/IgfsImpl.java | 28 +- .../internal/processors/igfs/IgfsPaths.java | 62 +- .../igfs/IgfsSecondaryFileSystemImpl.java | 11 - .../platform/PlatformAbstractTarget.java | 17 +- .../processors/platform/PlatformTarget.java | 22 + .../platform/compute/PlatformCompute.java | 34 +- .../platform/utils/PlatformFutureUtils.java | 119 +++- .../platform/utils/PlatformListenable.java | 47 ++ .../processors/rest/GridRestProcessor.java | 4 + .../rest/client/message/GridClientNodeBean.java | 4 +- .../ignite/internal/util/IgniteUtils.java | 40 ++ .../ignite/internal/util/lang/GridFunc.java | 3 + .../ignite/internal/util/nio/GridNioServer.java | 16 +- .../visor/node/VisorIgfsConfiguration.java | 43 -- .../plugin/security/AuthenticationContext.java | 33 +- .../core/src/main/resources/ignite.properties | 2 +- .../internal/GridUpdateNotifierSelfTest.java | 2 +- .../cache/IgniteCacheStoreCollectionTest.java | 163 +++++ ...eAbstractDataStructuresFailoverSelfTest.java | 311 +++------ .../processors/igfs/IgfsAbstractSelfTest.java | 8 +- .../igfs/IgfsExUniversalFileSystemAdapter.java | 11 +- .../igfs/UniversalFileSystemAdapter.java | 5 +- modules/extdata/p2p/pom.xml | 2 +- .../extdata/uri/modules/uri-dependency/pom.xml | 2 +- modules/extdata/uri/pom.xml | 2 +- modules/flume/pom.xml | 2 +- modules/gce/pom.xml | 2 +- modules/geospatial/pom.xml | 10 +- modules/hadoop/pom.xml | 2 +- .../hadoop/fs/BasicHadoopFileSystemFactory.java | 209 ++++++ .../fs/CachingHadoopFileSystemFactory.java | 86 +++ .../hadoop/fs/HadoopFileSystemFactory.java | 52 ++ .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 264 +++---- .../hadoop/fs/v1/IgniteHadoopFileSystem.java | 149 ++-- .../hadoop/fs/v2/IgniteHadoopFileSystem.java | 115 ++-- .../processors/hadoop/HadoopClassLoader.java | 689 ++++++++++++++----- .../hadoop/SecondaryFileSystemProvider.java | 139 ---- .../hadoop/fs/HadoopFileSystemCacheUtils.java | 8 +- .../hadoop/fs/HadoopLazyConcurrentMap.java | 5 +- .../hadoop/v2/HadoopNativeCodeLoader.java | 74 -- .../ignite/igfs/Hadoop1DualAbstractTest.java | 14 +- .../igfs/HadoopFIleSystemFactorySelfTest.java | 326 +++++++++ ...oopFileSystemUniversalFileSystemAdapter.java | 53 +- ...oopSecondaryFileSystemConfigurationTest.java | 27 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 71 +- ...condaryFileSystemInitializationSelfTest.java | 214 ++++++ .../hadoop/HadoopAbstractWordCountTest.java | 46 +- .../hadoop/HadoopClassLoaderTest.java | 101 ++- .../hadoop/HadoopMapReduceEmbeddedSelfTest.java | 2 +- .../processors/hadoop/HadoopMapReduceTest.java | 15 +- .../hadoop/HadoopSnappyFullMapReduceTest.java | 28 + .../processors/hadoop/HadoopSnappyTest.java | 102 +++ .../processors/hadoop/HadoopTasksV2Test.java | 2 +- .../hadoop/deps/CircularWIthHadoop.java | 32 + .../hadoop/deps/CircularWithoutHadoop.java | 27 + .../processors/hadoop/deps/WithCast.java | 41 ++ .../hadoop/deps/WithClassAnnotation.java | 28 + .../hadoop/deps/WithConstructorInvocation.java | 31 + .../processors/hadoop/deps/WithExtends.java | 27 + .../processors/hadoop/deps/WithField.java | 29 + .../processors/hadoop/deps/WithImplements.java | 36 + .../hadoop/deps/WithIndirectField.java | 27 + .../processors/hadoop/deps/WithInitializer.java | 33 + .../processors/hadoop/deps/WithInnerClass.java | 31 + .../hadoop/deps/WithLocalVariable.java | 38 + .../hadoop/deps/WithMethodAnnotation.java | 32 + .../hadoop/deps/WithMethodArgument.java | 31 + .../hadoop/deps/WithMethodCheckedException.java | 31 + .../hadoop/deps/WithMethodInvocation.java | 31 + .../hadoop/deps/WithMethodReturnType.java | 31 + .../hadoop/deps/WithMethodRuntimeException.java | 31 + .../processors/hadoop/deps/WithOuterClass.java | 38 + .../hadoop/deps/WithParameterAnnotation.java | 31 + .../processors/hadoop/deps/WithStaticField.java | 29 + .../hadoop/deps/WithStaticInitializer.java | 34 + .../processors/hadoop/deps/Without.java | 25 + .../hadoop/examples/HadoopWordCount1Reduce.java | 1 + .../hadoop/examples/HadoopWordCount2.java | 18 +- .../examples/HadoopWordCount2Reducer.java | 1 + .../testsuites/IgniteHadoopTestSuite.java | 26 +- modules/hibernate/pom.xml | 2 +- modules/indexing/pom.xml | 10 +- ...niteCacheP2pUnmarshallingQueryErrorTest.java | 4 + modules/jcl/pom.xml | 4 +- modules/jms11/pom.xml | 2 +- modules/jta/pom.xml | 2 +- modules/kafka/pom.xml | 2 +- modules/log4j/pom.xml | 2 +- modules/log4j2/pom.xml | 4 +- modules/mesos/pom.xml | 2 +- modules/mqtt/pom.xml | 2 +- modules/osgi-karaf/pom.xml | 6 +- modules/osgi-paxlogging/pom.xml | 2 +- modules/osgi/pom.xml | 10 +- modules/platforms/cpp/DEVNOTES.txt | 59 ++ modules/platforms/cpp/README.txt | 64 +- modules/platforms/cpp/common/configure.ac | 2 +- .../cpp/common/include/ignite/common/exports.h | 7 +- .../cpp/common/include/ignite/common/java.h | 13 +- .../platforms/cpp/common/project/vs/module.def | 6 +- modules/platforms/cpp/common/src/exports.cpp | 20 +- modules/platforms/cpp/common/src/java.cpp | 70 +- modules/platforms/cpp/core-test/configure.ac | 2 +- modules/platforms/cpp/core/configure.ac | 2 +- modules/platforms/cpp/examples/configure.ac | 2 +- modules/platforms/cpp/ignite/configure.ac | 2 +- modules/platforms/cpp/project/vs/ignite.sln | 6 +- modules/platforms/cpp/project/vs/ignite.slnrel | 10 + .../platforms/cpp/project/vs/ignite_x86.slnrel | 10 + .../Properties/AssemblyInfo.cs | 8 +- .../Properties/AssemblyInfo.cs | 8 +- .../Compute/ComputeApiTest.cs | 20 + .../Properties/AssemblyInfo.cs | 8 +- .../Apache.Ignite.Core.csproj | 2 + .../Common/IgniteFutureCancelledException.cs | 65 ++ .../Apache.Ignite.Core/Compute/ICompute.cs | 233 +++++++ .../Impl/Common/CancelledTask.cs | 47 ++ .../Apache.Ignite.Core/Impl/Common/Future.cs | 74 +- .../Apache.Ignite.Core/Impl/Compute/Compute.cs | 157 ++++- .../Impl/Compute/ComputeImpl.cs | 15 +- .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 4 + .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 52 ++ .../Impl/Unmanaged/IgniteJniNativeMethods.cs | 16 +- .../Impl/Unmanaged/UnmanagedUtils.cs | 31 +- .../Properties/AssemblyInfo.cs | 8 +- modules/platforms/dotnet/Apache.Ignite.sln | 5 +- .../Apache.Ignite/Properties/AssemblyInfo.cs | 8 +- modules/platforms/dotnet/DEVNOTES.txt | 18 + .../Properties/AssemblyInfo.cs | 8 +- .../Properties/AssemblyInfo.cs | 8 +- modules/rest-http/pom.xml | 2 +- .../rest/protocols/http/jetty/rest.html | 2 +- modules/scalar-2.10/pom.xml | 4 +- modules/scalar/pom.xml | 4 +- modules/schedule/pom.xml | 4 +- modules/schema-import/pom.xml | 2 +- modules/slf4j/pom.xml | 2 +- modules/spark-2.10/pom.xml | 2 +- modules/spark/pom.xml | 2 +- modules/spring/pom.xml | 4 +- modules/ssh/pom.xml | 2 +- modules/tools/pom.xml | 2 +- modules/twitter/pom.xml | 2 +- modules/urideploy/pom.xml | 2 +- modules/visor-console-2.10/pom.xml | 2 +- modules/visor-console/pom.xml | 2 +- modules/visor-plugins/pom.xml | 2 +- modules/web/pom.xml | 4 +- modules/yardstick/pom.xml | 2 +- modules/yarn/pom.xml | 2 +- modules/zookeeper/pom.xml | 2 +- parent/pom.xml | 4 +- pom.xml | 25 +- 219 files changed, 5457 insertions(+), 1582 deletions(-) ----------------------------------------------------------------------
