ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject [50/50] [abbrv] ignite git commit: Merge branch 'master' into ignite-gg-10837
Date Wed, 13 Jan 2016 13:55:34 GMT
Merge branch 'master' into ignite-gg-10837


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/32cc1393
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/32cc1393
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/32cc1393

Branch: refs/heads/ignite-gg-10837
Commit: 32cc1393565e85b29cd1db6ae706f4f8488a4763
Parents: 7bc1501 cd44be5
Author: Tikhonov Nikolay <tikhonovnicolay@gmail.com>
Authored: Wed Jan 13 14:10:39 2016 +0300
Committer: Tikhonov Nikolay <tikhonovnicolay@gmail.com>
Committed: Wed Jan 13 14:10:39 2016 +0300

----------------------------------------------------------------------
 README.md                                       | 194 ++++++
 assembly/release-fabric-base.xml                |   1 +
 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                         |   2 +-
 modules/cloud/pom.xml                           |   2 +-
 modules/codegen/pom.xml                         |   2 +-
 modules/core/pom.xml                            |   2 +-
 .../org/apache/ignite/IgniteTransactions.java   |   4 +-
 .../configuration/FileSystemConfiguration.java  |  54 +-
 .../org/apache/ignite/igfs/IgfsUserContext.java |  16 +-
 .../igfs/secondary/IgfsSecondaryFileSystem.java |  14 -
 .../apache/ignite/internal/IgniteKernal.java    |  95 ++-
 .../ignite/internal/MarshallerContextImpl.java  |  86 ++-
 .../cache/CacheEntrySerializablePredicate.java  |   3 +-
 .../cache/CacheInvokeDirectResult.java          |   4 +-
 .../processors/cache/GridCacheIoManager.java    |  23 +
 .../processors/cache/GridCacheProcessor.java    |  52 +-
 .../processors/cache/GridCacheReturn.java       |   2 +
 .../processors/cache/IgniteCacheProxy.java      |   2 +-
 .../GridDistributedLockResponse.java            |   2 +-
 .../GridDistributedTxFinishRequest.java         |  11 +-
 .../GridDistributedTxPrepareRequest.java        |   2 +-
 .../GridDistributedTxPrepareResponse.java       |   4 +-
 .../GridDistributedTxRemoteAdapter.java         |  12 +-
 .../dht/CacheDistributedGetFutureAdapter.java   |  10 +-
 .../dht/GridDhtAffinityAssignmentResponse.java  |   4 +-
 .../distributed/dht/GridDhtLockFuture.java      |  44 +-
 .../distributed/dht/GridDhtLockRequest.java     |   2 +-
 .../distributed/dht/GridDhtTxFinishFuture.java  |  15 +-
 .../distributed/dht/GridDhtTxFinishRequest.java |  90 ++-
 .../dht/GridDhtTxFinishResponse.java            |   4 +-
 .../cache/distributed/dht/GridDhtTxLocal.java   |  32 +-
 .../distributed/dht/GridDhtTxPrepareFuture.java |  48 +-
 .../dht/GridDhtTxPrepareRequest.java            |   2 +-
 .../dht/GridPartitionedGetFuture.java           |   2 +-
 .../dht/atomic/GridDhtAtomicUpdateRequest.java  |  21 +-
 .../dht/atomic/GridDhtAtomicUpdateResponse.java |   6 +-
 .../dht/atomic/GridNearAtomicUpdateRequest.java |  22 +-
 .../atomic/GridNearAtomicUpdateResponse.java    |   4 +-
 .../dht/preloader/GridDhtForceKeysResponse.java |   6 +-
 .../GridDhtPartitionDemandMessage.java          |   6 +-
 .../GridDhtPartitionSupplyMessageV2.java        |   6 +-
 .../preloader/GridDhtPartitionsFullMessage.java |   2 +-
 .../GridDhtPartitionsSingleMessage.java         |   4 +-
 .../distributed/near/GridNearGetFuture.java     |   2 +-
 .../distributed/near/GridNearGetResponse.java   |   4 +-
 ...arOptimisticSerializableTxPrepareFuture.java |  94 +--
 .../near/GridNearOptimisticTxPrepareFuture.java |  63 +-
 ...ridNearOptimisticTxPrepareFutureAdapter.java |   6 +-
 .../GridNearPessimisticTxPrepareFuture.java     |   6 +-
 .../near/GridNearSingleGetResponse.java         |   2 +-
 .../near/GridNearTxFinishFuture.java            | 432 +++++++++---
 .../near/GridNearTxFinishRequest.java           |   5 +
 .../near/GridNearTxFinishResponse.java          |   4 +-
 .../cache/distributed/near/GridNearTxLocal.java |  71 +-
 .../near/GridNearTxPrepareFutureAdapter.java    |   8 +-
 .../near/GridNearTxPrepareResponse.java         |   4 +-
 .../cache/local/GridLocalLockFuture.java        |  19 +-
 .../cache/query/GridCacheQueryRequest.java      |  16 +-
 .../cache/query/GridCacheQueryResponse.java     |  18 +-
 .../cache/transactions/IgniteInternalTx.java    |   6 +
 .../cache/transactions/IgniteTxAdapter.java     |  47 +-
 .../cache/transactions/IgniteTxEntry.java       |  23 +-
 .../cache/transactions/IgniteTxHandler.java     |  26 +-
 .../transactions/IgniteTxLocalAdapter.java      |  44 +-
 .../cache/transactions/IgniteTxManager.java     |  20 +
 .../version/GridCachePlainVersionedEntry.java   |   2 +-
 .../datastreamer/DataStreamerRequest.java       |   1 +
 .../datastructures/DataStructuresProcessor.java |  11 +-
 .../processors/hadoop/HadoopPayloadAware.java   |  28 +
 .../processors/igfs/IgfsAckMessage.java         |   4 +-
 .../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 ++
 .../handlers/cache/GridCacheCommandHandler.java |   6 +-
 .../ignite/internal/util/GridStringBuilder.java |  19 +
 .../ignite/internal/util/IgniteUtils.java       |  50 ++
 .../ignite/internal/util/lang/GridFunc.java     |   3 +
 .../ignite/internal/util/nio/GridNioServer.java |  16 +-
 .../visor/node/VisorIgfsConfiguration.java      |  43 --
 .../ignite/spi/discovery/DiscoverySpi.java      |   2 +
 .../ignite/stream/socket/SocketStreamer.java    |   3 +-
 .../core/src/main/resources/ignite.properties   |   2 +-
 .../internal/GridUpdateNotifierSelfTest.java    |   2 +-
 ...cheAbstractFullApiMultithreadedSelfTest.java |  13 +-
 .../cache/GridCacheAbstractFullApiSelfTest.java |   2 +-
 .../processors/cache/GridCacheStopSelfTest.java |   2 +-
 .../cache/IgniteCacheStoreCollectionTest.java   | 163 +++++
 .../cache/IgniteDynamicCacheStartSelfTest.java  |  30 +-
 ...eMarshallerCacheConcurrentReadWriteTest.java | 189 +++++
 ...eAbstractDataStructuresFailoverSelfTest.java | 311 +++------
 .../IgniteClientDataStructuresAbstractTest.java |   3 +
 .../dht/GridCacheTxNodeFailureSelfTest.java     |  13 +-
 .../IgniteCacheCommitDelayTxRecoveryTest.java   | 376 ++++++++++
 .../IgniteCachePutRetryAbstractSelfTest.java    |  36 +-
 ...gniteCachePutRetryTransactionalSelfTest.java |  21 +
 .../continuous/GridEventConsumeSelfTest.java    |   3 +
 .../processors/igfs/IgfsAbstractSelfTest.java   |   8 +-
 .../igfs/IgfsExUniversalFileSystemAdapter.java  |  11 +-
 .../igfs/UniversalFileSystemAdapter.java        |   5 +-
 .../internal/util/nio/GridNioSelfTest.java      |  11 +-
 ...dTcpCommunicationSpiRecoveryAckSelfTest.java |   1 -
 ...CommunicationRecoveryAckClosureSelfTest.java |  19 +-
 .../spi/discovery/tcp/TcpDiscoverySelfTest.java |   2 +
 .../junits/common/GridCommonAbstractTest.java   |  34 +-
 .../ignite/testsuites/IgniteBasicTestSuite.java |   2 +
 .../IgniteCacheTxRecoverySelfTestSuite.java     |   3 +
 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/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 +-
 .../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 +-
 .../Apache.Ignite/Properties/AssemblyInfo.cs    |   8 +-
 .../Properties/AssemblyInfo.cs                  |   8 +-
 .../Properties/AssemblyInfo.cs                  |   8 +-
 modules/rest-http/pom.xml                       |   2 +-
 modules/scalar-2.10/pom.xml                     |   2 +-
 modules/scalar/pom.xml                          |   2 +-
 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 +-
 .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java  |  69 +-
 pom.xml                                         |   2 +-
 268 files changed, 6788 insertions(+), 1879 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/32cc1393/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/32cc1393/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
----------------------------------------------------------------------


Mime
View raw message