Merge branches 'ignite-1486' and 'ignite-1753' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-1753
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/22222112 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/22222112 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/22222112 Branch: refs/heads/ignite-1753 Commit: 22222112d0153ad7fca56c26807f44f6a6f936e2 Parents: 10e4dbe 4f1120f Author: AKuznetsov <[email protected]> Authored: Thu Oct 22 23:39:20 2015 +0700 Committer: AKuznetsov <[email protected]> Committed: Thu Oct 22 23:39:20 2015 +0700 ---------------------------------------------------------------------- DEVNOTES.txt | 3 +- RELEASE_NOTES.txt | 3 + assembly/dependencies-fabric.xml | 2 +- assembly/dependencies-hadoop.xml | 1 + assembly/release-fabric-lgpl.xml | 63 + assembly/release-fabric.xml | 10 +- assembly/release-hadoop-lgpl.xml | 39 + bin/igniterouter.bat | 2 +- bin/igniterouter.sh | 2 +- examples-lgpl/README.txt | 27 + examples-lgpl/config/example-cache.xml | 73 + examples-lgpl/config/example-ignite.xml | 83 ++ examples-lgpl/config/hibernate/README.txt | 8 + .../hibernate/example-hibernate-L2-cache.xml | 64 + examples-lgpl/pom-standalone.xml | 186 +++ examples-lgpl/pom.xml | 128 ++ .../hibernate/HibernateL2CacheExample.java | 245 ++++ .../examples/datagrid/hibernate/Post.java | 130 ++ .../examples/datagrid/hibernate/User.java | 154 ++ .../datagrid/hibernate/package-info.java | 22 + .../hibernate/CacheHibernatePersonStore.java | 122 ++ .../hibernate/CacheHibernateStoreExample.java | 151 ++ .../datagrid/store/hibernate/Person.hbm.xml | 34 + .../datagrid/store/hibernate/hibernate.cfg.xml | 41 + .../datagrid/store/hibernate/package-info.java | 22 + .../misc/schedule/ComputeScheduleExample.java | 82 ++ .../examples/misc/schedule/package-info.java | 22 + .../misc/schedule/ComputeScheduleExample.java | 68 + .../java8/misc/schedule/package-info.java | 22 + .../ignite/examples/java8/package-info.java | 23 + .../scalar/examples/ScalarScheduleExample.scala | 66 + ...ibernateL2CacheExampleMultiNodeSelfTest.java | 31 + .../HibernateL2CacheExampleSelfTest.java | 33 + .../IgniteLgplExamplesSelfTestSuite.java | 48 + ...ibernateL2CacheExampleMultiNodeSelfTest.java | 29 + .../HibernateL2CacheExampleSelfTest.java | 37 + .../IgniteLgplExamplesJ8SelfTestSuite.java | 46 + .../ScalarLgplExamplesMultiNodeSelfTest.scala | 33 + .../examples/ScalarLgplExamplesSelfTest.scala | 36 + .../ScalarLgplExamplesSelfTestSuite.scala | 37 + examples/config/filesystem/README.txt | 2 +- examples/config/filesystem/example-igfs.xml | 7 - examples/config/hibernate/README.txt | 8 - .../hibernate/example-hibernate-L2-cache.xml | 64 - examples/pom-standalone.xml | 12 - examples/pom.xml | 12 - examples/schema-import/pom-standalone.xml | 90 ++ examples/schema-import/pom.xml | 23 +- .../computegrid/ComputeClosureExample.java | 2 +- .../hibernate/HibernateL2CacheExample.java | 245 ---- .../examples/datagrid/hibernate/Post.java | 130 -- .../examples/datagrid/hibernate/User.java | 154 -- .../datagrid/hibernate/package-info.java | 22 - .../hibernate/CacheHibernatePersonStore.java | 122 -- .../hibernate/CacheHibernateStoreExample.java | 151 -- .../datagrid/store/hibernate/Person.hbm.xml | 34 - .../datagrid/store/hibernate/hibernate.cfg.xml | 41 - .../datagrid/store/hibernate/package-info.java | 22 - .../misc/schedule/ComputeScheduleExample.java | 82 -- .../examples/misc/schedule/package-info.java | 22 - .../socket/WordsSocketStreamerServer.java | 5 +- .../misc/schedule/ComputeScheduleExample.java | 68 - .../java8/misc/schedule/package-info.java | 22 - .../scalar/examples/ScalarScheduleExample.scala | 66 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 31 - .../HibernateL2CacheExampleSelfTest.java | 33 - .../testsuites/IgniteExamplesSelfTestSuite.java | 4 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 29 - .../HibernateL2CacheExampleSelfTest.java | 37 - .../tests/examples/ScalarExamplesSelfTest.scala | 5 - modules/apache-license-gen/README.txt | 33 + modules/apache-license-gen/pom.xml | 3 + .../JettyRestProcessorAbstractSelfTest.java | 252 +++- .../TcpDiscoveryCloudIpFinderSelfTest.java | 2 + .../org/apache/ignite/IgniteAtomicLong.java | 17 +- .../apache/ignite/IgniteAtomicReference.java | 9 +- .../org/apache/ignite/IgniteAtomicSequence.java | 9 +- .../org/apache/ignite/IgniteAtomicStamped.java | 13 +- .../org/apache/ignite/IgniteFileSystem.java | 4 +- .../java/org/apache/ignite/IgnitePortables.java | 2 +- .../apache/ignite/IgniteSystemProperties.java | 3 + .../org/apache/ignite/IgniteTransactions.java | 4 - .../apache/ignite/cache/CacheAtomicityMode.java | 17 +- .../configuration/CacheConfiguration.java | 24 +- .../configuration/NearCacheConfiguration.java | 18 +- .../java/org/apache/ignite/igfs/IgfsPath.java | 2 +- .../apache/ignite/internal/IgniteKernal.java | 82 +- .../managers/discovery/CustomEventListener.java | 4 +- .../discovery/GridDiscoveryManager.java | 91 +- .../internal/portable/PortableContext.java | 19 +- .../cache/DynamicCacheChangeRequest.java | 19 + .../cache/DynamicCacheDescriptor.java | 46 +- .../processors/cache/GridCacheAdapter.java | 386 +++-- .../cache/GridCacheClearAllRunnable.java | 18 +- .../cache/GridCacheConcurrentMap.java | 4 +- .../processors/cache/GridCacheContext.java | 8 +- .../processors/cache/GridCacheEventManager.java | 12 +- .../cache/GridCacheEvictionManager.java | 6 +- .../cache/GridCacheEvictionResponse.java | 2 +- .../cache/GridCacheExplicitLockSpan.java | 13 +- .../processors/cache/GridCacheIoManager.java | 152 +- .../processors/cache/GridCacheMapEntry.java | 66 +- .../processors/cache/GridCacheMessage.java | 14 +- .../cache/GridCacheMvccCandidate.java | 5 +- .../processors/cache/GridCacheMvccManager.java | 93 +- .../GridCachePartitionExchangeManager.java | 127 +- .../processors/cache/GridCacheProcessor.java | 224 ++- .../processors/cache/GridCacheProxyImpl.java | 14 +- .../cache/GridCacheSharedContext.java | 32 - .../cache/GridCacheSwapEntryImpl.java | 31 +- .../processors/cache/GridCacheSwapManager.java | 124 +- .../processors/cache/GridCacheUtils.java | 8 - .../processors/cache/IgniteCacheProxy.java | 6 +- .../processors/cache/IgniteInternalCache.java | 19 +- .../distributed/GridDistributedCacheEntry.java | 2 +- .../GridDistributedLockResponse.java | 6 +- .../GridDistributedTxPrepareResponse.java | 6 +- .../GridDistributedTxRemoteAdapter.java | 8 +- .../dht/GridClientPartitionTopology.java | 117 +- .../dht/GridDhtAffinityAssignmentRequest.java | 5 - .../dht/GridDhtAffinityAssignmentResponse.java | 5 - .../distributed/dht/GridDhtCacheAdapter.java | 6 +- .../cache/distributed/dht/GridDhtGetFuture.java | 4 +- .../distributed/dht/GridDhtLocalPartition.java | 29 +- .../distributed/dht/GridDhtLockRequest.java | 10 +- .../dht/GridDhtPartitionTopology.java | 4 +- .../dht/GridDhtPartitionTopologyImpl.java | 28 +- .../distributed/dht/GridDhtTopologyFuture.java | 6 +- .../dht/GridDhtTransactionalCacheAdapter.java | 2 +- .../distributed/dht/GridDhtTxFinishRequest.java | 5 - .../distributed/dht/GridDhtTxPrepareFuture.java | 8 +- .../dht/GridDhtTxPrepareRequest.java | 7 +- .../dht/GridPartitionedGetFuture.java | 5 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 7 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 12 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 33 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 2 + .../atomic/GridNearAtomicUpdateResponse.java | 11 +- .../dht/colocated/GridDhtColocatedCache.java | 12 +- .../colocated/GridDhtColocatedLockFuture.java | 71 +- .../dht/preloader/GridDhtForceKeysFuture.java | 2 +- .../dht/preloader/GridDhtForceKeysRequest.java | 5 - .../dht/preloader/GridDhtForceKeysResponse.java | 11 +- .../GridDhtPartitionDemandMessage.java | 9 +- .../GridDhtPartitionSupplyMessage.java | 8 +- .../GridDhtPartitionsAbstractMessage.java | 5 - .../GridDhtPartitionsExchangeFuture.java | 31 +- .../preloader/GridDhtPartitionsFullMessage.java | 12 +- .../GridDhtPartitionsSingleMessage.java | 11 +- .../dht/preloader/GridDhtPreloader.java | 26 +- .../distributed/near/GridNearCacheAdapter.java | 21 +- .../near/GridNearCacheClearAllRunnable.java | 9 +- .../distributed/near/GridNearGetFuture.java | 2 + .../distributed/near/GridNearGetResponse.java | 6 +- .../distributed/near/GridNearLockFuture.java | 37 +- .../near/GridNearOptimisticTxPrepareFuture.java | 47 +- .../near/GridNearTxFinishFuture.java | 36 +- .../near/GridNearTxFinishResponse.java | 6 +- .../cache/distributed/near/GridNearTxLocal.java | 21 +- .../cache/local/GridLocalCacheEntry.java | 2 +- .../query/GridCacheDistributedQueryFuture.java | 27 +- .../cache/query/GridCacheLocalQueryFuture.java | 5 + .../cache/query/GridCacheQueryAdapter.java | 170 ++- .../query/GridCacheQueryFutureAdapter.java | 11 +- .../cache/query/GridCacheQueryManager.java | 63 +- .../cache/query/GridCacheQueryResponse.java | 6 +- .../cache/query/GridCacheSqlIndexMetadata.java | 7 +- .../cache/query/GridCacheSqlMetadata.java | 22 +- .../continuous/CacheContinuousQueryHandler.java | 22 +- .../continuous/CacheContinuousQueryManager.java | 66 +- .../cache/transactions/IgniteTxHandler.java | 9 +- .../transactions/IgniteTxLocalAdapter.java | 37 +- .../continuous/GridContinuousProcessor.java | 42 +- .../datastreamer/DataStreamerImpl.java | 2 - .../datastructures/DataStructuresProcessor.java | 54 +- .../processors/igfs/IgfsDataManager.java | 2 - .../processors/igfs/IgfsDeleteWorker.java | 102 +- .../internal/processors/igfs/IgfsFileInfo.java | 15 +- .../processors/igfs/IgfsFileWorkerBatch.java | 15 +- .../internal/processors/igfs/IgfsImpl.java | 372 +---- .../processors/igfs/IgfsMetaManager.java | 1255 ++++++++++++---- .../processors/igfs/IgfsOutputStreamImpl.java | 2 + .../internal/processors/igfs/IgfsUtils.java | 23 + .../processors/rest/GridRestCommand.java | 8 +- .../processors/rest/GridRestProcessor.java | 364 ++++- .../handlers/cache/GridCacheCommandHandler.java | 364 ++--- .../handlers/query/QueryCommandHandler.java | 195 ++- .../top/GridTopologyCommandHandler.java | 31 +- .../rest/request/RestQueryRequest.java | 175 +++ .../rest/request/RestSqlQueryRequest.java | 125 -- .../ignite/internal/util/GridArgumentCheck.java | 5 +- .../ignite/internal/util/GridJavaProcess.java | 12 +- .../ignite/internal/util/GridSpinBusyLock.java | 10 + .../ignite/internal/util/IgniteUtils.java | 18 +- .../ignite/internal/util/lang/GridFunc.java | 12 + .../util/nio/GridNioRecoveryDescriptor.java | 4 +- .../util/offheap/GridOffHeapEvictListener.java | 2 +- .../util/offheap/GridOffHeapPartitionedMap.java | 1 + .../util/offheap/unsafe/GridUnsafeMap.java | 4 +- .../apache/ignite/marshaller/Marshaller.java | 2 +- .../optimized/OptimizedMarshallerUtils.java | 6 +- .../marshaller/portable/PortableMarshaller.java | 40 +- .../org/apache/ignite/mxbean/IgniteMXBean.java | 8 +- .../portable/PortableProtocolVersion.java | 41 - .../communication/tcp/TcpCommunicationSpi.java | 29 +- .../ignite/spi/deployment/DeploymentSpi.java | 8 +- .../discovery/DiscoverySpiCustomMessage.java | 12 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 410 ++++-- .../spi/discovery/tcp/TcpDiscoveryImpl.java | 6 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +- .../tcp/internal/TcpDiscoveryNodesRing.java | 94 +- .../messages/TcpDiscoveryDiscardMessage.java | 15 +- .../TcpDiscoveryNodeAddFinishedMessage.java | 2 +- .../messages/TcpDiscoveryNodeAddedMessage.java | 19 +- .../org/apache/ignite/stream/StreamAdapter.java | 104 +- .../stream/StreamMultipleTupleExtractor.java | 38 + .../stream/StreamSingleTupleExtractor.java | 40 + .../ignite/stream/StreamTupleExtractor.java | 20 +- .../ignite/stream/socket/SocketStreamer.java | 3 +- .../resources/META-INF/classnames.properties | 1 - modules/core/src/test/config/tests.properties | 3 + .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 6 +- .../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 +- .../internal/GridUpdateNotifierSelfTest.java | 1 + .../IgniteClientReconnectAbstractTest.java | 35 +- .../IgniteClientReconnectCacheTest.java | 154 ++ .../GridDiscoveryManagerAliveCacheSelfTest.java | 2 + .../GridDiscoveryManagerAttributesSelfTest.java | 50 - .../cache/CacheAffinityCallSelfTest.java | 4 +- .../processors/cache/CrossCacheLockTest.java | 142 ++ .../GridCacheAbstractFailoverSelfTest.java | 3 + .../cache/GridCacheAbstractFullApiSelfTest.java | 493 ++++--- .../GridCacheAbstractRemoveFailureTest.java | 208 ++- .../cache/GridCacheClearSelfTest.java | 308 ++++ .../GridCacheDeploymentOffHeapSelfTest.java | 15 + .../GridCacheFinishPartitionsSelfTest.java | 5 +- .../cache/GridCacheMemoryModeSelfTest.java | 9 +- .../cache/GridCachePutAllFailoverSelfTest.java | 60 + .../GridCacheVariableTopologySelfTest.java | 3 +- ...IgniteCacheAtomicPutAllFailoverSelfTest.java | 4 + .../IgniteCacheConfigurationTemplateTest.java | 31 + .../cache/IgniteCacheCreateRestartSelfTest.java | 109 ++ .../IgniteCacheEntryListenerAbstractTest.java | 65 +- .../cache/IgniteCacheEntryListenerTxTest.java | 4 + .../IgniteCacheEntryProcessorNodeJoinTest.java | 97 +- .../IgniteCacheP2pUnmarshallingErrorTest.java | 7 + ...CacheP2pUnmarshallingRebalanceErrorTest.java | 12 +- .../cache/IgniteCachePutAllRestartTest.java | 4 +- .../cache/IgniteDynamicCacheFilterTest.java | 150 ++ .../IgniteTxExceptionAbstractSelfTest.java | 3 + ...omicOffheapQueueCreateMultiNodeSelfTest.java | 5 - ...ionedAtomicQueueCreateMultiNodeSelfTest.java | 9 +- ...artitionedOffHeapValuesQueueApiSelfTest.java | 4 + ...PartitionedQueueCreateMultiNodeSelfTest.java | 16 +- ...nedQueueFailoverDataConsistencySelfTest.java | 5 - ...GridCachePartitionedSetFailoverSelfTest.java | 4 + .../CacheAbstractRestartSelfTest.java | 247 ++++ .../distributed/CacheAffinityEarlyTest.java | 168 +++ ...acheAsyncOperationsFailoverAbstractTest.java | 11 + .../CacheGetFutureHangsSelfTest.java | 159 +- ...NearDisabledAtomicInvokeRestartSelfTest.java | 179 +++ ...abledTransactionalInvokeRestartSelfTest.java | 173 +++ ...edTransactionalWriteReadRestartSelfTest.java | 124 ++ .../CacheNoValueClassOnServerNodeTest.java | 1 + .../CachePutAllFailoverAbstractTest.java | 11 + .../GridCacheAbstractNodeRestartSelfTest.java | 149 +- .../IgniteCacheAtomicNodeRestartTest.java | 8 + ...niteCacheClientNodeChangingTopologyTest.java | 10 +- .../IgniteCacheCreatePutMultiNodeSelfTest.java | 151 ++ .../distributed/IgniteCacheCreatePutTest.java | 125 ++ .../IgniteCachePutGetRestartAbstractTest.java | 3 + .../IgniteCacheSizeFailoverTest.java | 3 + .../IgniteTxPreloadAbstractTest.java | 43 +- .../GridCacheColocatedTxExceptionSelfTest.java | 5 - .../GridCacheDhtAtomicRemoveFailureTest.java | 16 +- .../dht/GridCacheDhtEntrySelfTest.java | 2 +- .../dht/GridCacheDhtPreloadPerformanceTest.java | 133 ++ .../dht/GridCacheDhtRemoveFailureTest.java | 16 +- .../dht/GridCacheTxNodeFailureSelfTest.java | 4 +- .../dht/GridNearCacheTxNodeFailureSelfTest.java | 4 + ...gniteAtomicLongChangingTopologySelfTest.java | 190 ++- .../IgniteCacheCrossCacheTxFailoverTest.java | 56 +- .../IgniteCachePutRetryAbstractSelfTest.java | 199 ++- .../dht/IgniteCachePutRetryAtomicSelfTest.java | 2 + ...gniteCachePutRetryTransactionalSelfTest.java | 50 +- .../IgniteCrossCacheTxNearEnabledSelfTest.java | 28 + .../dht/IgniteCrossCacheTxSelfTest.java | 213 +++ ...eAtomicInvalidPartitionHandlingSelfTest.java | 98 +- ...tomicPrimaryWriteOrderRemoveFailureTest.java | 15 +- .../GridCacheAtomicRemoveFailureTest.java | 15 +- ...GridCacheValueConsistencyAtomicSelfTest.java | 2 +- ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 71 +- ...ledFairAffinityMultiNodeFullApiSelfTest.java | 12 +- .../GridCacheAtomicNearRemoveFailureTest.java | 15 +- ...icOffHeapTieredMultiNodeFullApiSelfTest.java | 7 +- ...cPrimaryWriteOrderNearRemoveFailureTest.java | 15 +- .../near/GridCacheNearRemoveFailureTest.java | 15 +- .../near/GridCacheNearTxExceptionSelfTest.java | 9 +- .../near/GridCacheNearTxForceKeyTest.java | 2 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 129 +- .../GridCachePartitionedNodeRestartTest.java | 9 +- ...ePartitionedOptimisticTxNodeRestartTest.java | 9 +- .../near/NearCacheMultithreadedUpdateTest.java | 217 +++ .../GridCacheReplicatedInvalidateSelfTest.java | 249 ---- .../GridCacheReplicatedNodeRestartSelfTest.java | 8 +- .../GridCacheReplicatedTxExceptionSelfTest.java | 5 - .../replicated/GridReplicatedTxPreloadTest.java | 9 +- ...eCacheExpiryPolicyWithStoreAbstractTest.java | 5 +- .../GridCacheLocalTxExceptionSelfTest.java | 5 - ...bledFairAffinityMultiJvmFullApiSelfTest.java | 5 + ...tomicNearEnabledMultiJvmFullApiSelfTest.java | 5 + .../GridCacheSwapScanQueryAbstractSelfTest.java | 118 +- ...ontinuousQueryReplicatedOneNodeSelfTest.java | 120 ++ .../DataStreamerMultiThreadedSelfTest.java | 4 +- .../DataStreamerMultinodeCreateCacheTest.java | 2 + .../processors/igfs/IgfsAbstractSelfTest.java | 983 ++++++++++--- .../igfs/IgfsClientCacheSelfTest.java | 15 +- .../igfs/IgfsDataManagerSelfTest.java | 13 +- .../igfs/IgfsDualAbstractSelfTest.java | 10 +- .../igfs/IgfsMetaManagerSelfTest.java | 258 ++-- .../processors/igfs/IgfsMetricsSelfTest.java | 2 +- .../processors/igfs/IgfsProcessorSelfTest.java | 41 +- .../igfs/UniversalFileSystemAdapter.java | 1 - .../offheap/GridOffHeapMapAbstractSelfTest.java | 6 +- ...idOffHeapPartitionedMapAbstractSelfTest.java | 10 +- .../loadtests/hashmap/GridCacheTestContext.java | 4 +- ...lientDiscoverySpiFailureTimeoutSelfTest.java | 139 +- .../tcp/TcpClientDiscoverySpiSelfTest.java | 15 +- .../tcp/TcpDiscoveryMultiThreadedTest.java | 53 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 315 +++- .../stream/socket/SocketStreamerSelfTest.java | 112 +- .../ignite/testframework/GridTestUtils.java | 131 +- .../testframework/junits/GridAbstractTest.java | 116 +- .../junits/IgniteTestResources.java | 8 +- .../junits/common/GridCommonAbstractTest.java | 15 +- .../junits/multijvm/AffinityProcessProxy.java | 440 ++++-- .../multijvm/IgniteCacheProcessProxy.java | 1357 ++++++++++++++---- .../multijvm/IgniteClusterProcessProxy.java | 115 +- .../multijvm/IgniteEventsProcessProxy.java | 50 +- .../junits/multijvm/IgniteNodeRunner.java | 39 +- .../junits/multijvm/IgniteProcessProxy.java | 105 +- .../IgniteCacheFailoverTestSuite.java | 10 - .../IgniteCacheFailoverTestSuite3.java | 48 + .../IgniteCacheFullApiSelfTestSuite.java | 8 +- .../IgniteCacheLoadConsistencyTestSuite.java | 42 + .../testsuites/IgniteCacheRestartTestSuite.java | 15 +- .../IgniteCacheRestartTestSuite2.java | 47 + .../testsuites/IgniteCacheTestSuite3.java | 2 - .../testsuites/IgniteCacheTestSuite4.java | 24 + .../ignite/testsuites/IgniteIgfsTestSuite.java | 6 + modules/extdata/uri/pom.xml | 11 +- .../hadoop/SecondaryFileSystemProvider.java | 4 +- .../processors/hadoop/igfs/HadoopIgfsUtils.java | 36 + .../hadoop/igfs/HadoopIgfsWrapper.java | 144 +- ...oopFileSystemUniversalFileSystemAdapter.java | 4 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 34 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 7 +- .../testsuites/IgniteHadoopTestSuite.java | 25 +- .../CacheHibernateBlobStoreSelfTest.java | 6 +- .../processors/query/h2/IgniteH2Indexing.java | 19 +- .../query/h2/opt/GridH2AbstractKeyValueRow.java | 73 +- .../query/h2/opt/GridH2KeyValueRowOffheap.java | 11 +- .../query/h2/opt/GridH2RowDescriptor.java | 5 + .../processors/query/h2/opt/GridH2Table.java | 10 +- .../processors/query/h2/sql/GridSqlArray.java | 52 + .../processors/query/h2/sql/GridSqlElement.java | 2 +- .../query/h2/sql/GridSqlFunction.java | 60 +- .../query/h2/sql/GridSqlFunctionType.java | 3 + .../query/h2/sql/GridSqlPlaceholder.java | 7 +- .../query/h2/sql/GridSqlQueryParser.java | 84 +- .../processors/query/h2/sql/GridSqlType.java | 29 +- .../cache/CacheConfigurationP2PTest.java | 3 + .../cache/CacheIndexStreamerTest.java | 154 ++ ...CacheScanPartitionQueryFallbackSelfTest.java | 244 +--- .../processors/cache/GridCacheSwapSelfTest.java | 4 +- ...QueryOffheapEvictsMultiThreadedSelfTest.java | 5 - .../cache/SqlFieldsQuerySelfTest.java | 172 +++ ...lientQueryReplicatedNodeRestartSelfTest.java | 8 +- .../IgniteCacheQueryNodeRestartSelfTest.java | 4 +- .../IgniteCacheQueryNodeRestartSelfTest2.java | 10 +- .../query/h2/sql/GridQueryParsingTest.java | 27 + .../IgniteCacheQuerySelfTestSuite.java | 6 +- .../IgniteCacheWithIndexingTestSuite.java | 2 + modules/mqtt/pom.xml | 114 ++ .../apache/ignite/stream/mqtt/MqttStreamer.java | 611 ++++++++ .../stream/mqtt/IgniteMqttStreamerTest.java | 553 +++++++ .../mqtt/IgniteMqttStreamerTestSuite.java | 34 + .../main/cpp/common/project/vs/common.vcxproj | 4 +- .../Apache.Ignite.Core/Impl/IgniteManager.cs | 2 - .../http/jetty/GridJettyJsonConfig.java | 158 +- .../http/jetty/GridJettyRestHandler.java | 186 +-- .../spi/deployment/uri/UriDeploymentSpi.java | 93 +- .../scanners/http/UriDeploymentHttpScanner.java | 10 +- .../http/GridHttpDeploymentSelfTest.java | 132 +- .../ignite/visor/commands/VisorConsole.scala | 37 +- .../visor/commands/kill/VisorKillCommand.scala | 2 +- .../scala/org/apache/ignite/visor/visor.scala | 1 - .../config/benchmark-put-indexed-val.properties | 2 +- modules/yardstick/config/ignite-base-config.xml | 2 +- modules/yardstick/pom.xml | 10 +- .../yardstick/IgniteBenchmarkArguments.java | 24 +- .../org/apache/ignite/yardstick/IgniteNode.java | 12 +- pom.xml | 114 +- 403 files changed, 18030 insertions(+), 6668 deletions(-) ----------------------------------------------------------------------
