Merge sprint-2 to ignite-379-1
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d1ffd0e4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d1ffd0e4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d1ffd0e4 Branch: refs/heads/ignite-379-1 Commit: d1ffd0e42669f1eaab3eacc26f5fbcc385ef4b05 Parents: 1ec04df 6837e12 Author: sevdokimov <sergey.evdoki...@jetbrains.com> Authored: Sun Mar 22 22:28:04 2015 +0300 Committer: sevdokimov <sergey.evdoki...@jetbrains.com> Committed: Sun Mar 22 22:28:04 2015 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 23 + DISCLAIMER.txt | 15 + LICENSE.txt | 68 +- NOTICE.txt | 20 +- README.txt | 25 + RELEASE_NOTES.txt | 18 + assembly/dependencies-hadoop.xml | 7 +- assembly/dependencies-optional-fabric.xml | 2 +- assembly/dependencies-optional-hadoop.xml | 2 +- assembly/dependencies-schema-import.xml | 56 + assembly/dependencies-schema-load.xml | 56 - assembly/release-base.xml | 20 +- assembly/release-fabric.xml | 5 - assembly/release-hadoop.xml | 16 +- bin/ignite-schema-import.bat | 97 + bin/ignite-schema-import.sh | 78 + bin/ignite-schema-load.bat | 116 - bin/ignite-schema-load.sh | 78 - bin/igniterouter.sh | 7 +- bin/ignitevisorcmd.bat | 7 +- bin/ignitevisorcmd.sh | 7 +- bin/include/igniteservice.exe | Bin 6144 -> 0 bytes bin/include/target-classpath.bat | 2 +- bin/include/target-classpath.sh | 2 +- bin/setup-hadoop.sh | 7 +- config/hadoop/default-config.xml | 10 +- docs/core-site.ignite.xml | 90 - docs/hadoop_readme.md | 117 - docs/hadoop_readme.pdf | Bin 82297 -> 0 bytes docs/hive-site.ignite.xml | 37 - docs/ignite_readme.md | 100 - docs/ignite_readme.pdf | Bin 77136 -> 0 bytes docs/mapred-site.ignite.xml | 66 - docs/release_notes.md | 16 - docs/release_notes.pdf | Bin 33174 -> 0 bytes examples/config/example-cache.xml | 46 +- examples/config/filesystem/example-igfs.xml | 24 +- examples/config/store/example-database.script | 27 + examples/pom-standalone.xml | 2 +- examples/pom.xml | 7 + .../apache/ignite/examples/ExamplesUtils.java | 18 - .../ComputeContinuousMapperExample.java | 2 +- .../ComputeFibonacciContinuationExample.java | 14 +- .../failover/ComputeFailoverExample.java | 1 + .../computegrid/failover/package-info.java | 22 + .../examples/computegrid/failover/package.html | 24 - .../computegrid/montecarlo/package-info.java | 22 + .../computegrid/montecarlo/package.html | 24 - .../examples/computegrid/package-info.java | 22 + .../ignite/examples/computegrid/package.html | 24 - .../examples/datagrid/CacheApiExample.java | 2 +- .../datagrid/CacheDataLoaderExample.java | 85 - .../datagrid/CacheDataStreamerExample.java | 85 + .../datagrid/CachePopularNumbersExample.java | 18 +- .../examples/datagrid/CacheQueryExample.java | 73 +- .../datagrid/hibernate/package-info.java | 22 + .../examples/datagrid/hibernate/package.html | 24 - .../ignite/examples/datagrid/package-info.java | 22 + .../ignite/examples/datagrid/package.html | 24 - .../starschema/CacheStarSchemaExample.java | 17 +- .../datagrid/starschema/DimProduct.java | 3 +- .../examples/datagrid/starschema/DimStore.java | 3 +- .../datagrid/starschema/FactPurchase.java | 2 + .../datagrid/starschema/package-info.java | 22 + .../examples/datagrid/starschema/package.html | 24 - .../store/CacheNodeWithStoreStartup.java | 67 +- .../datagrid/store/CacheStoreExample.java | 20 + .../store/CacheStoreLoadDataExample.java | 20 +- .../ignite/examples/datagrid/store/Person.java | 103 - .../store/dummy/CacheDummyPersonStore.java | 3 +- .../datagrid/store/dummy/package-info.java | 22 + .../examples/datagrid/store/dummy/package.html | 24 - .../hibernate/CacheHibernatePersonStore.java | 2 +- .../datagrid/store/hibernate/Person.hbm.xml | 2 +- .../datagrid/store/hibernate/hibernate.cfg.xml | 3 - .../datagrid/store/hibernate/package-info.java | 22 + .../datagrid/store/hibernate/package.html | 24 - .../store/jdbc/CacheJdbcPersonStore.java | 4 +- .../store/jdbc/CacheJdbcPojoPersonStore.java | 85 + .../datagrid/store/jdbc/package-info.java | 22 + .../examples/datagrid/store/jdbc/package.html | 24 - .../examples/datagrid/store/model/Person.java | 155 ++ .../examples/datagrid/store/package-info.java | 22 + .../ignite/examples/datagrid/store/package.html | 24 - .../examples/datastructures/package-info.java | 22 + .../ignite/examples/datastructures/package.html | 24 - .../ignite/examples/events/package-info.java | 22 + .../apache/ignite/examples/events/package.html | 24 - .../ignite/examples/igfs/package-info.java | 22 + .../apache/ignite/examples/igfs/package.html | 24 - .../ignite/examples/messaging/package-info.java | 22 + .../ignite/examples/messaging/package.html | 24 - .../MemcacheRestExampleNodeStartup.java | 12 +- .../misc/client/memcache/package-info.java | 22 + .../examples/misc/client/memcache/package.html | 24 - .../examples/misc/client/package-info.java | 22 + .../ignite/examples/misc/client/package.html | 24 - .../examples/misc/deployment/package-info.java | 22 + .../examples/misc/deployment/package.html | 24 - .../examples/misc/lifecycle/package-info.java | 22 + .../ignite/examples/misc/lifecycle/package.html | 24 - .../ignite/examples/misc/package-info.java | 22 + .../apache/ignite/examples/misc/package.html | 24 - .../examples/misc/springbean/package-info.java | 22 + .../examples/misc/springbean/package.html | 24 - .../apache/ignite/examples/package-info.java | 22 + .../org/apache/ignite/examples/package.html | 24 - .../streaming/StreamingCheckInExample.java | 580 ----- .../streaming/StreamingNodeStartup.java | 35 - .../StreamingPopularNumbersExample.java | 250 --- .../streaming/StreamingPriceBarsExample.java | 451 ---- .../StreamingRunningAverageExample.java | 247 --- .../ignite/examples/streaming/package.html | 24 - .../apache/ignite/examples/ComputeExample.java | 2 +- .../ScalarCachePopularNumbersExample.scala | 49 +- .../examples/ScalarContinuationExample.scala | 12 +- .../ignite/examples/CacheExamplesSelfTest.java | 6 +- ipc/shmem/compile | 4 + ipc/shmem/config.guess | 4 + ipc/shmem/config.sub | 4 + ipc/shmem/depcomp | 4 + ipc/shmem/ltmain.sh | 3 + ipc/shmem/missing | 4 + license/header-customisation.xml | 51 - license/header.txt | 14 - .../gridify/aop/aspectj/package-info.java | 22 + .../compute/gridify/aop/aspectj/package.html | 24 - .../gridify/aop/spring/package-info.java | 22 + .../compute/gridify/aop/spring/package.html | 25 - .../apache/ignite/gridify/AbstractAopTest.java | 2 +- .../ignite/gridify/hierarchy/package-info.java | 22 + .../ignite/gridify/hierarchy/package.html | 25 - .../org/apache/ignite/gridify/package-info.java | 22 + .../java/org/apache/ignite/gridify/package.html | 25 - .../direct/singlesplit/package-info.java | 22 + .../loadtests/direct/singlesplit/package.html | 24 - .../java/org/test/gridify/package-info.java | 22 + .../src/test/java/org/test/gridify/package.html | 24 - .../spi/checkpoint/s3/S3CheckpointData.java | 62 +- .../spi/checkpoint/s3/S3CheckpointSpi.java | 8 +- .../ignite/spi/checkpoint/s3/package-info.java | 22 + .../ignite/spi/checkpoint/s3/package.html | 24 - .../discovery/tcp/ipfinder/s3/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/s3/package.html | 24 - .../checkpoint/s3/S3CheckpointSpiSelfTest.java | 2 +- .../s3/S3CheckpointSpiStartStopSelfTest.java | 2 +- .../ignite/spi/checkpoint/s3/package-info.java | 22 + .../ignite/spi/checkpoint/s3/package.html | 24 - .../discovery/tcp/ipfinder/s3/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/s3/package.html | 24 - modules/clients/readme.md | 17 + .../ClientAbstractMultiNodeSelfTest.java | 12 +- .../client/suite/IgniteClientTestSuite.java | 3 +- .../rest/AbstractRestProcessorSelfTest.java | 2 +- .../rest/protocols/tcp/MockNioSession.java | 7 +- .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 8 +- .../ignite/jdbc/JdbcEmptyCacheSelfTest.java | 5 +- .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 16 +- .../ignite/jdbc/JdbcMetadataSelfTest.java | 6 +- .../jdbc/JdbcPreparedStatementSelfTest.java | 5 +- .../ignite/jdbc/JdbcResultSetSelfTest.java | 7 +- .../ignite/jdbc/JdbcStatementSelfTest.java | 7 +- modules/clients/src/test/keystore/generate.sh | 26 +- .../clients/src/test/resources/spring-cache.xml | 23 +- .../src/test/resources/spring-server-node.xml | 7 - .../test/resources/spring-server-ssl-node.xml | 4 - modules/codegen/pom.xml | 6 + .../ignite/codegen/MessageCodeGenerator.java | 14 +- modules/core/licenses/snaptree-bsd-license.txt | 35 + modules/core/licenses/snaptree-license.txt | 35 - modules/core/licenses/sun-bcl-license.txt | 50 - modules/core/pom.xml | 168 +- .../META-INF/native/linux64/libigniteshmem.so | Bin 138345 -> 0 bytes .../META-INF/native/osx/libigniteshmem.dylib | Bin 33116 -> 0 bytes .../src/main/java/com/romix/scala/None.java | 27 - .../src/main/java/com/romix/scala/Option.java | 42 - .../src/main/java/com/romix/scala/Some.java | 38 - .../scala/collection/concurrent/BasicNode.java | 32 - .../scala/collection/concurrent/CNodeBase.java | 49 - .../romix/scala/collection/concurrent/Gen.java | 29 - .../scala/collection/concurrent/INodeBase.java | 47 - .../scala/collection/concurrent/ListMap.java | 247 --- .../scala/collection/concurrent/MainNode.java | 51 - .../romix/scala/collection/concurrent/Pair.java | 54 - .../scala/collection/concurrent/TrieMap.java | 1826 --------------- .../src/main/java/org/apache/ignite/Ignite.java | 29 +- .../java/org/apache/ignite/IgniteCache.java | 140 +- .../java/org/apache/ignite/IgniteCompute.java | 4 - .../org/apache/ignite/IgniteDataLoader.java | 379 ---- .../org/apache/ignite/IgniteDataStreamer.java | 401 ++++ .../org/apache/ignite/IgniteFileSystem.java | 24 +- .../java/org/apache/ignite/IgniteQueue.java | 4 +- .../main/java/org/apache/ignite/IgniteSet.java | 2 +- .../java/org/apache/ignite/IgniteStreamer.java | 154 -- .../apache/ignite/IgniteSystemProperties.java | 35 +- .../org/apache/ignite/IgniteTransactions.java | 2 +- .../ignite/cache/CacheEntryProcessor.java | 28 + .../apache/ignite/cache/CacheInterceptor.java | 34 +- .../ignite/cache/CacheInterceptorAdapter.java | 12 +- .../org/apache/ignite/cache/CacheManager.java | 2 - .../cache/CachePartialUpdateException.java | 3 + .../apache/ignite/cache/CachePreloadMode.java | 67 - .../apache/ignite/cache/CacheRebalanceMode.java | 67 + .../apache/ignite/cache/CacheTypeMetadata.java | 6 + .../java/org/apache/ignite/cache/GridCache.java | 223 -- .../ignite/cache/IgniteEntryProcessor.java | 28 - .../cache/affinity/CacheAffinityKeyMapped.java | 56 +- .../cache/affinity/fair/package-info.java | 21 + .../ignite/cache/affinity/fair/package.html | 24 - .../ignite/cache/affinity/package-info.java | 21 + .../apache/ignite/cache/affinity/package.html | 24 - .../CacheRendezvousAffinityFunction.java | 13 +- .../cache/affinity/rendezvous/package-info.java | 21 + .../cache/affinity/rendezvous/package.html | 24 - .../cache/eviction/CacheEvictionFilter.java | 4 +- .../cache/eviction/CacheEvictionPolicy.java | 7 +- .../eviction/fifo/CacheFifoEvictionPolicy.java | 3 - .../cache/eviction/fifo/package-info.java | 21 + .../ignite/cache/eviction/fifo/package.html | 24 - .../cache/eviction/igfs/package-info.java | 21 + .../ignite/cache/eviction/igfs/package.html | 24 - .../eviction/lru/CacheLruEvictionPolicy.java | 1 - .../ignite/cache/eviction/lru/package-info.java | 21 + .../ignite/cache/eviction/lru/package.html | 24 - .../ignite/cache/eviction/package-info.java | 21 + .../apache/ignite/cache/eviction/package.html | 24 - .../cache/eviction/random/package-info.java | 21 + .../ignite/cache/eviction/random/package.html | 24 - .../org/apache/ignite/cache/package-info.java | 22 + .../java/org/apache/ignite/cache/package.html | 24 - .../ignite/cache/query/ContinuousQuery.java | 4 +- .../org/apache/ignite/cache/query/Query.java | 75 +- .../apache/ignite/cache/query/QueryMetrics.java | 4 +- .../ignite/cache/query/QueryTypeResolver.java | 32 - .../org/apache/ignite/cache/query/SqlQuery.java | 9 +- .../apache/ignite/cache/query/TextQuery.java | 7 +- .../query/annotations/QuerySqlFunction.java | 4 +- .../apache/ignite/cache/query/package-info.java | 21 + .../org/apache/ignite/cache/query/package.html | 24 - .../cache/store/CacheLoadOnlyStoreAdapter.java | 8 +- .../apache/ignite/cache/store/CacheStore.java | 4 +- .../store/jdbc/CacheAbstractJdbcStore.java | 200 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 54 +- .../cache/store/jdbc/dialect/package-info.java | 21 + .../cache/store/jdbc/dialect/package.html | 24 - .../ignite/cache/store/jdbc/package-info.java | 22 + .../apache/ignite/cache/store/jdbc/package.html | 24 - .../apache/ignite/cache/store/package-info.java | 22 + .../org/apache/ignite/cache/store/package.html | 24 - .../org/apache/ignite/cluster/ClusterGroup.java | 9 - .../apache/ignite/cluster/ClusterMetrics.java | 66 +- .../ignite/compute/ComputeJobContext.java | 1 - .../compute/gridify/aop/package-info.java | 22 + .../ignite/compute/gridify/aop/package.html | 24 - .../ignite/compute/gridify/package-info.java | 22 + .../apache/ignite/compute/gridify/package.html | 24 - .../org/apache/ignite/compute/package-info.java | 22 + .../java/org/apache/ignite/compute/package.html | 24 - .../configuration/CacheConfiguration.java | 576 ++--- .../configuration/CacheQueryConfiguration.java | 182 -- .../configuration/FileSystemConfiguration.java | 55 +- .../configuration/HadoopConfiguration.java | 17 +- .../configuration/IgniteConfiguration.java | 51 +- .../configuration/QueryConfiguration.java | 227 -- .../ignite/events/CachePreloadingEvent.java | 172 -- .../ignite/events/CacheQueryExecutedEvent.java | 2 +- .../ignite/events/CacheQueryReadEvent.java | 2 + .../ignite/events/CacheRebalancingEvent.java | 172 ++ .../java/org/apache/ignite/events/Event.java | 2 +- .../org/apache/ignite/events/EventType.java | 46 +- .../org/apache/ignite/events/package-info.java | 22 + .../java/org/apache/ignite/events/package.html | 24 - .../IgfsConcurrentModificationException.java | 29 +- .../ignite/igfs/IgfsCorruptedFileException.java | 16 +- .../igfs/IgfsDirectoryNotEmptyException.java | 56 + .../org/apache/ignite/igfs/IgfsException.java | 16 +- .../ignite/igfs/IgfsFileNotFoundException.java | 44 - .../org/apache/ignite/igfs/IgfsInputStream.java | 2 - .../igfs/IgfsInvalidHdfsVersionException.java | 23 +- .../ignite/igfs/IgfsInvalidPathException.java | 16 +- .../igfs/IgfsIpcEndpointConfiguration.java | 241 ++ .../apache/ignite/igfs/IgfsIpcEndpointType.java | 29 + .../ignite/igfs/IgfsOutOfSpaceException.java | 16 +- .../igfs/IgfsParentNotDirectoryException.java | 20 +- .../igfs/IgfsPathAlreadyExistsException.java | 19 +- .../igfs/IgfsPathIsDirectoryException.java | 56 + .../igfs/IgfsPathIsNotDirectoryException.java | 56 + .../ignite/igfs/IgfsPathNotFoundException.java | 56 + .../ignite/igfs/mapreduce/package-info.java | 22 + .../apache/ignite/igfs/mapreduce/package.html | 24 - .../igfs/mapreduce/records/package-info.java | 22 + .../ignite/igfs/mapreduce/records/package.html | 24 - .../org/apache/ignite/igfs/package-info.java | 22 + .../java/org/apache/ignite/igfs/package.html | 24 - .../igfs/secondary/IgfsSecondaryFileSystem.java | 10 +- .../ignite/igfs/secondary/package-info.java | 22 + .../apache/ignite/igfs/secondary/package.html | 24 - .../ignite/internal/AsyncSupportAdapter.java | 16 +- .../ClusterLocalNodeMetricsMXBeanImpl.java | 5 + .../ignite/internal/ClusterMetricsSnapshot.java | 27 +- .../internal/ComputeTaskInternalFuture.java | 41 +- .../internal/GridEventConsumeHandler.java | 13 +- .../ignite/internal/GridJobContextImpl.java | 6 +- .../ignite/internal/GridJobSessionImpl.java | 2 +- .../ignite/internal/GridKernalContext.java | 70 +- .../ignite/internal/GridKernalContextImpl.java | 114 +- .../ignite/internal/GridKernalGatewayImpl.java | 26 - .../internal/GridMessageListenHandler.java | 11 +- .../ignite/internal/GridTaskSessionImpl.java | 5 +- .../org/apache/ignite/internal/GridTopic.java | 91 +- .../ignite/internal/GridUpdateNotifier.java | 3 +- .../internal/IgniteCodeGeneratingFail.java | 29 + .../org/apache/ignite/internal/IgniteEx.java | 10 +- .../ignite/internal/IgniteInternalFuture.java | 79 +- .../apache/ignite/internal/IgniteKernal.java | 344 ++- .../ignite/internal/IgniteTransactionsEx.java | 16 - .../org/apache/ignite/internal/IgnitionEx.java | 93 +- .../internal/MarshallerContextAdapter.java | 130 ++ .../ignite/internal/MarshallerContextImpl.java | 101 + .../org/apache/ignite/internal/SkipDaemon.java | 29 + .../internal/client/GridClientCacheFlag.java | 2 +- .../internal/client/GridClientFuture.java | 9 +- .../balancer/GridClientBalancerAdapter.java | 2 +- .../client/impl/GridClientComputeImpl.java | 2 +- .../client/impl/GridClientDataImpl.java | 2 +- .../client/impl/GridClientFutureAdapter.java | 23 +- .../GridClientConnectionManagerAdapter.java | 2 +- .../connection/GridClientNioTcpConnection.java | 5 +- .../GridClientOptimizedMarshaller.java | 42 +- .../impl/GridRouterCommandLineStartup.java | 2 +- .../impl/GridTcpRouterNioListenerAdapter.java | 2 +- .../internal/cluster/ClusterGroupAdapter.java | 40 - .../cluster/IgniteClusterAsyncImpl.java | 5 - .../internal/cluster/IgniteClusterImpl.java | 13 +- .../internal/direct/DirectByteBufferStream.java | 62 +- .../internal/direct/DirectMessageWriter.java | 7 + .../direct/DirectMessageWriterState.java | 3 + .../internal/executor/GridExecutorService.java | 2 +- .../ignite/internal/executor/package-info.java | 22 + .../ignite/internal/executor/package.html | 24 - .../igfs/common/IgfsControlResponse.java | 5 +- .../ignite/internal/igfs/common/IgfsLogger.java | 4 +- .../internal/igfs/common/IgfsMarshaller.java | 1 - .../internal/igfs/common/package-info.java | 22 + .../ignite/internal/igfs/common/package.html | 24 - .../ignite/internal/managers/GridManager.java | 20 +- .../internal/managers/GridManagerAdapter.java | 114 +- .../checkpoint/GridCheckpointManager.java | 4 +- .../managers/checkpoint/package-info.java | 22 + .../internal/managers/checkpoint/package.html | 24 - .../collision/GridCollisionManager.java | 4 +- .../managers/collision/package-info.java | 22 + .../internal/managers/collision/package.html | 24 - .../managers/communication/GridIoManager.java | 139 +- .../communication/GridIoMessageFactory.java | 137 +- .../managers/communication/GridIoPolicy.java | 5 +- .../managers/communication/package-info.java | 22 + .../managers/communication/package.html | 24 - .../deployment/GridDeploymentLocalStore.java | 5 +- .../GridDeploymentPerLoaderStore.java | 6 +- .../GridDeploymentPerVersionStore.java | 6 +- .../managers/deployment/package-info.java | 22 + .../internal/managers/deployment/package.html | 24 - .../deployment/protocol/gg/package-info.java | 22 + .../deployment/protocol/gg/package.html | 24 - .../discovery/GridDiscoveryManager.java | 55 +- .../GridDiscoveryTopologySnapshot.java | 16 +- .../managers/discovery/package-info.java | 22 + .../internal/managers/discovery/package.html | 24 - .../eventstorage/GridEventStorageManager.java | 6 +- .../managers/eventstorage/package-info.java | 22 + .../internal/managers/eventstorage/package.html | 24 - .../managers/failover/package-info.java | 22 + .../internal/managers/failover/package.html | 24 - .../managers/indexing/GridIndexingManager.java | 4 +- .../managers/indexing/package-info.java | 22 + .../internal/managers/indexing/package.html | 24 - .../loadbalancer/GridLoadBalancerManager.java | 3 - .../managers/loadbalancer/package-info.java | 22 + .../internal/managers/loadbalancer/package.html | 24 - .../ignite/internal/managers/package-info.java | 22 + .../ignite/internal/managers/package.html | 24 - .../swapspace/GridSwapSpaceManager.java | 13 +- .../managers/swapspace/package-info.java | 22 + .../internal/managers/swapspace/package.html | 24 - .../ignite/internal/mxbean/package-info.java | 22 + .../apache/ignite/internal/mxbean/package.html | 24 - .../apache/ignite/internal/package-info.java | 22 + .../org/apache/ignite/internal/package.html | 24 - .../internal/processors/GridProcessor.java | 11 +- .../processors/GridProcessorAdapter.java | 5 - .../affinity/GridAffinityAssignmentCache.java | 31 +- .../affinity/GridAffinityMessage.java | 13 +- .../affinity/GridAffinityProcessor.java | 37 +- .../processors/affinity/package-info.java | 22 + .../internal/processors/affinity/package.html | 24 - .../cache/CacheEntryInfoCollection.java | 111 + .../processors/cache/CacheEntryPredicate.java | 45 + .../cache/CacheEntryPredicateAdapter.java | 88 + .../cache/CacheEntryPredicateContainsValue.java | 132 ++ .../cache/CacheEntryPredicateHasValue.java | 31 + .../cache/CacheEntryPredicateNoValue.java | 31 + .../cache/CacheEntrySerializablePredicate.java | 152 ++ .../processors/cache/CacheEvictionEntry.java | 182 ++ .../internal/processors/cache/CacheFlag.java | 2 - .../cache/CacheInvokeDirectResult.java | 213 ++ .../processors/cache/CacheInvokeEntry.java | 79 +- .../processors/cache/CacheInvokeResult.java | 12 +- .../processors/cache/CacheLazyEntry.java | 133 ++ .../internal/processors/cache/CacheObject.java | 73 + .../processors/cache/CacheObjectAdapter.java | 118 + .../cache/CacheObjectByteArrayImpl.java | 156 ++ .../processors/cache/CacheObjectContext.java | 130 ++ .../processors/cache/CacheObjectImpl.java | 126 ++ .../processors/cache/CachePeekModes.java | 28 + .../processors/cache/CacheProjection.java | 302 ++- .../cache/CacheStoreBalancingWrapper.java | 2 + .../cache/CacheWeakQueryIteratorsHolder.java | 2 +- .../processors/cache/EvictableEntryImpl.java | 33 +- .../internal/processors/cache/GridCache.java | 221 ++ .../processors/cache/GridCacheAdapter.java | 1842 ++++++++------- .../cache/GridCacheAffinityManager.java | 72 +- .../processors/cache/GridCacheAtomicFuture.java | 4 +- .../processors/cache/GridCacheAttributes.java | 74 +- .../cache/GridCacheBatchSwapEntry.java | 27 +- .../cache/GridCacheClearAllRunnable.java | 33 +- .../cache/GridCacheConcurrentMap.java | 357 +-- .../processors/cache/GridCacheContext.java | 487 ++-- .../GridCacheDefaultAffinityKeyMapper.java | 47 +- .../cache/GridCacheDeploymentManager.java | 126 +- .../processors/cache/GridCacheEntryEx.java | 201 +- .../processors/cache/GridCacheEntryInfo.java | 337 +-- .../GridCacheEntryInfoCollectSwapListener.java | 56 +- .../processors/cache/GridCacheEventManager.java | 133 +- .../cache/GridCacheEvictionManager.java | 263 ++- .../cache/GridCacheEvictionRequest.java | 46 +- .../cache/GridCacheEvictionResponse.java | 27 +- .../cache/GridCacheExplicitLockSpan.java | 40 +- .../cache/GridCacheFilterFailedException.java | 8 +- .../processors/cache/GridCacheGateway.java | 6 + .../processors/cache/GridCacheIoManager.java | 125 +- .../processors/cache/GridCacheKeySet.java | 4 +- .../cache/GridCacheManagerAdapter.java | 2 +- .../processors/cache/GridCacheMapEntry.java | 1543 ++++++------- .../cache/GridCacheMapEntryFactory.java | 12 +- .../processors/cache/GridCacheMessage.java | 242 +- .../cache/GridCacheMultiTxFuture.java | 55 +- .../processors/cache/GridCacheMvcc.java | 217 +- .../processors/cache/GridCacheMvccCallback.java | 12 +- .../cache/GridCacheMvccCandidate.java | 50 +- .../processors/cache/GridCacheMvccFuture.java | 4 +- .../processors/cache/GridCacheMvccManager.java | 223 +- .../cache/GridCacheOffheapSwapEntry.java | 20 +- .../GridCachePartitionExchangeManager.java | 118 +- .../processors/cache/GridCachePeekMode.java | 6 +- .../processors/cache/GridCachePreloader.java | 10 +- .../cache/GridCachePreloaderAdapter.java | 16 +- .../processors/cache/GridCacheProcessor.java | 223 +- .../processors/cache/GridCacheProjectionEx.java | 85 +- .../cache/GridCacheProjectionImpl.java | 635 ++---- .../processors/cache/GridCacheProxyImpl.java | 223 +- .../processors/cache/GridCacheReturn.java | 317 ++- .../cache/GridCacheSharedContext.java | 44 +- .../processors/cache/GridCacheStoreManager.java | 238 +- .../processors/cache/GridCacheSwapEntry.java | 16 +- .../cache/GridCacheSwapEntryImpl.java | 60 +- .../processors/cache/GridCacheSwapListener.java | 8 +- .../processors/cache/GridCacheSwapManager.java | 748 ++++--- .../processors/cache/GridCacheTtlManager.java | 26 +- .../cache/GridCacheUpdateAtomicResult.java | 27 +- .../cache/GridCacheUpdateTxResult.java | 8 +- .../processors/cache/GridCacheUtils.java | 236 +- .../processors/cache/GridCacheValueBytes.java | 194 -- .../cache/GridCacheValueCollection.java | 4 +- .../cache/GridCacheWriteBehindStore.java | 73 +- .../processors/cache/GridPartitionLockKey.java | 104 - .../cache/IgniteCacheExpiryPolicy.java | 8 +- .../IgniteCacheOsSerializationManager.java | 48 - .../processors/cache/IgniteCacheProxy.java | 225 +- .../processors/cache/KeyCacheObject.java | 33 + .../processors/cache/KeyCacheObjectImpl.java | 132 ++ .../processors/cache/QueryCursorImpl.java | 116 + .../cache/affinity/GridCacheAffinityImpl.java | 10 +- .../CacheDataStructuresManager.java | 14 +- .../distributed/GridCacheCommittedTxInfo.java | 10 +- ...ridCacheOptimisticCheckPreparedTxFuture.java | 40 +- ...idCacheOptimisticCheckPreparedTxRequest.java | 4 +- ...dCacheOptimisticCheckPreparedTxResponse.java | 2 +- .../distributed/GridCacheTtlUpdateRequest.java | 75 +- .../distributed/GridCacheTxFinishSync.java | 2 +- .../distributed/GridDistributedBaseMessage.java | 28 +- .../GridDistributedCacheAdapter.java | 60 +- .../distributed/GridDistributedCacheEntry.java | 154 +- .../distributed/GridDistributedLockRequest.java | 73 +- .../GridDistributedLockResponse.java | 93 +- .../GridDistributedTxFinishRequest.java | 83 +- .../GridDistributedTxFinishResponse.java | 2 +- .../distributed/GridDistributedTxMapping.java | 44 +- .../GridDistributedTxPrepareRequest.java | 273 ++- .../GridDistributedTxPrepareResponse.java | 14 +- .../GridDistributedTxRemoteAdapter.java | 168 +- .../GridDistributedUnlockRequest.java | 52 +- .../IgniteExternalizableExpiryPolicy.java | 12 +- .../dht/GridClientPartitionTopology.java | 24 +- .../dht/GridDhtAffinityAssignmentRequest.java | 2 +- .../dht/GridDhtAffinityAssignmentResponse.java | 6 +- .../dht/GridDhtAssignmentFetchFuture.java | 31 +- .../cache/distributed/dht/GridDhtCache.java | 2 +- .../distributed/dht/GridDhtCacheAdapter.java | 187 +- .../distributed/dht/GridDhtCacheEntry.java | 134 +- .../distributed/dht/GridDhtEmbeddedFuture.java | 40 +- .../distributed/dht/GridDhtFinishedFuture.java | 22 +- .../cache/distributed/dht/GridDhtGetFuture.java | 133 +- .../distributed/dht/GridDhtLocalPartition.java | 60 +- .../distributed/dht/GridDhtLockFuture.java | 131 +- .../distributed/dht/GridDhtLockRequest.java | 69 +- .../distributed/dht/GridDhtLockResponse.java | 77 +- .../dht/GridDhtPartitionTopology.java | 20 +- .../dht/GridDhtPartitionTopologyImpl.java | 62 +- .../dht/GridDhtTransactionalCacheAdapter.java | 314 +-- .../distributed/dht/GridDhtTxFinishFuture.java | 66 +- .../distributed/dht/GridDhtTxFinishRequest.java | 48 +- .../dht/GridDhtTxFinishResponse.java | 2 +- .../cache/distributed/dht/GridDhtTxLocal.java | 67 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 203 +- .../cache/distributed/dht/GridDhtTxMapping.java | 4 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 305 ++- .../dht/GridDhtTxPrepareRequest.java | 152 +- .../dht/GridDhtTxPrepareResponse.java | 84 +- .../cache/distributed/dht/GridDhtTxRemote.java | 53 +- .../distributed/dht/GridDhtUnlockRequest.java | 46 +- .../distributed/dht/GridNoStorageCacheMap.java | 28 +- .../dht/GridPartitionedGetFuture.java | 158 +- .../dht/atomic/GridDhtAtomicCache.java | 706 +++--- .../dht/atomic/GridDhtAtomicCacheEntry.java | 13 +- .../GridDhtAtomicDeferredUpdateResponse.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 88 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 222 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 66 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 209 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 238 +- .../atomic/GridNearAtomicUpdateResponse.java | 142 +- .../dht/colocated/GridDhtColocatedCache.java | 207 +- .../colocated/GridDhtColocatedCacheEntry.java | 13 +- .../colocated/GridDhtColocatedLockFuture.java | 172 +- .../colocated/GridDhtDetachedCacheEntry.java | 30 +- .../dht/preloader/GridDhtForceKeysFuture.java | 113 +- .../dht/preloader/GridDhtForceKeysRequest.java | 43 +- .../dht/preloader/GridDhtForceKeysResponse.java | 63 +- .../GridDhtPartitionDemandMessage.java | 8 +- .../preloader/GridDhtPartitionDemandPool.java | 182 +- .../GridDhtPartitionSupplyMessage.java | 93 +- .../preloader/GridDhtPartitionSupplyPool.java | 105 +- .../GridDhtPartitionsAbstractMessage.java | 2 +- .../GridDhtPartitionsExchangeFuture.java | 120 +- .../preloader/GridDhtPartitionsFullMessage.java | 6 +- .../GridDhtPartitionsSingleMessage.java | 6 +- .../GridDhtPartitionsSingleRequest.java | 2 +- .../dht/preloader/GridDhtPreloader.java | 98 +- .../preloader/GridDhtPreloaderAssignments.java | 8 +- .../distributed/near/CacheVersionedValue.java | 169 ++ .../distributed/near/GridNearAtomicCache.java | 151 +- .../distributed/near/GridNearCacheAdapter.java | 186 +- .../distributed/near/GridNearCacheEntry.java | 143 +- .../distributed/near/GridNearGetFuture.java | 171 +- .../distributed/near/GridNearGetRequest.java | 106 +- .../distributed/near/GridNearGetResponse.java | 37 +- .../distributed/near/GridNearLockFuture.java | 196 +- .../distributed/near/GridNearLockMapping.java | 23 +- .../distributed/near/GridNearLockRequest.java | 50 +- .../distributed/near/GridNearLockResponse.java | 12 +- .../near/GridNearTransactionalCache.java | 141 +- .../near/GridNearTxFinishFuture.java | 59 +- .../near/GridNearTxFinishRequest.java | 34 +- .../near/GridNearTxFinishResponse.java | 6 +- .../cache/distributed/near/GridNearTxLocal.java | 297 ++- .../near/GridNearTxPrepareFuture.java | 193 +- .../near/GridNearTxPrepareRequest.java | 58 +- .../near/GridNearTxPrepareResponse.java | 177 +- .../distributed/near/GridNearTxRemote.java | 66 +- .../distributed/near/GridNearUnlockRequest.java | 2 +- .../cache/dr/GridCacheDrExpirationInfo.java | 23 +- .../processors/cache/dr/GridCacheDrInfo.java | 28 +- .../processors/cache/dr/GridCacheDrManager.java | 10 +- .../cache/dr/os/GridOsCacheDrManager.java | 10 +- .../extras/GridCacheAttributesEntryExtras.java | 24 +- .../GridCacheAttributesMvccEntryExtras.java | 30 +- ...dCacheAttributesMvccObsoleteEntryExtras.java | 30 +- ...cheAttributesMvccObsoleteTtlEntryExtras.java | 30 +- .../GridCacheAttributesMvccTtlEntryExtras.java | 30 +- .../GridCacheAttributesObsoleteEntryExtras.java | 26 +- ...idCacheAttributesObsoleteTtlEntryExtras.java | 26 +- .../GridCacheAttributesTtlEntryExtras.java | 26 +- .../cache/extras/GridCacheEntryExtras.java | 16 +- .../extras/GridCacheEntryExtrasAdapter.java | 8 +- .../cache/extras/GridCacheMvccEntryExtras.java | 24 +- .../GridCacheMvccObsoleteEntryExtras.java | 26 +- .../GridCacheMvccObsoleteTtlEntryExtras.java | 26 +- .../extras/GridCacheMvccTtlEntryExtras.java | 26 +- .../extras/GridCacheObsoleteEntryExtras.java | 18 +- .../extras/GridCacheObsoleteTtlEntryExtras.java | 20 +- .../cache/extras/GridCacheTtlEntryExtras.java | 18 +- .../cache/jta/CacheJtaManagerAdapter.java | 2 +- .../cache/jta/CacheNoopJtaManager.java | 2 +- .../processors/cache/local/GridLocalCache.java | 57 +- .../cache/local/GridLocalCacheEntry.java | 85 +- .../cache/local/GridLocalLockCallback.java | 9 +- .../cache/local/GridLocalLockFuture.java | 57 +- .../processors/cache/local/GridLocalTx.java | 206 -- .../cache/local/GridLocalTxFuture.java | 351 --- .../local/atomic/GridLocalAtomicCache.java | 350 ++- .../processors/cache/query/CacheQuery.java | 7 +- .../GridCacheDistributedFieldsQueryFuture.java | 10 +- .../query/GridCacheDistributedQueryFuture.java | 10 +- .../query/GridCacheDistributedQueryManager.java | 44 +- .../query/GridCacheFieldsQueryErrorFuture.java | 53 - .../query/GridCacheLocalFieldsQueryFuture.java | 10 +- .../cache/query/GridCacheLocalQueryFuture.java | 18 +- .../cache/query/GridCacheQueriesEx.java | 9 +- .../cache/query/GridCacheQueriesImpl.java | 30 +- .../cache/query/GridCacheQueriesProxy.java | 4 +- .../cache/query/GridCacheQueryAdapter.java | 22 +- .../cache/query/GridCacheQueryErrorFuture.java | 5 +- .../query/GridCacheQueryFutureAdapter.java | 14 +- .../cache/query/GridCacheQueryInfo.java | 14 - .../cache/query/GridCacheQueryManager.java | 162 +- .../cache/query/GridCacheQueryRequest.java | 66 +- .../cache/query/GridCacheQueryResponse.java | 6 +- .../cache/query/GridCacheSqlQuery.java | 2 +- .../cache/query/GridCacheSqlResult.java | 29 - .../cache/query/GridCacheTwoStepQuery.java | 22 +- .../processors/cache/query/QueryCursorEx.java | 46 + .../processors/cache/query/QueryCursorImpl.java | 87 - .../continuous/CacheContinuousQueryEntry.java | 273 ++- .../continuous/CacheContinuousQueryEvent.java | 41 +- .../continuous/CacheContinuousQueryHandler.java | 83 +- .../continuous/CacheContinuousQueryManager.java | 173 +- .../jdbc/GridCacheQueryJdbcMetadataTask.java | 14 +- .../query/jdbc/GridCacheQueryJdbcTask.java | 255 ++- .../IgniteCacheSerializationManager.java | 51 - .../cache/transactions/IgniteInternalTx.java | 56 +- .../transactions/IgniteTransactionsImpl.java | 36 +- .../cache/transactions/IgniteTxAdapter.java | 160 +- .../cache/transactions/IgniteTxEntry.java | 700 +++--- .../cache/transactions/IgniteTxHandler.java | 263 +-- .../cache/transactions/IgniteTxKey.java | 99 +- .../transactions/IgniteTxLocalAdapter.java | 1135 +++++----- .../cache/transactions/IgniteTxLocalEx.java | 56 +- .../cache/transactions/IgniteTxManager.java | 390 ++-- .../cache/transactions/IgniteTxMap.java | 40 +- .../cache/transactions/IgniteTxRemoteEx.java | 4 +- .../transactions/TransactionProxyImpl.java | 16 +- .../cache/transactions/TxEntryValueHolder.java | 237 ++ .../version/GridCacheRawVersionedEntry.java | 247 ++- .../cache/version/GridCacheVersion.java | 12 +- .../cache/version/GridCacheVersionEx.java | 66 +- .../cache/version/GridCacheVersionManager.java | 2 +- .../cacheobject/IgniteCacheObjectProcessor.java | 163 ++ .../IgniteCacheObjectProcessorImpl.java | 371 ++++ .../processors/cacheobject/package-info.java | 22 + .../processors/clock/GridClockMessage.java | 1 - .../processors/clock/GridClockServer.java | 2 +- .../clock/GridClockSyncProcessor.java | 13 +- .../closure/GridClosureProcessor.java | 245 +- .../processors/closure/package-info.java | 22 + .../internal/processors/closure/package.html | 24 - .../continuous/GridContinuousHandler.java | 9 +- .../continuous/GridContinuousMessage.java | 43 +- .../continuous/GridContinuousProcessor.java | 78 +- .../dataload/GridDataLoadCacheUpdaters.java | 199 -- .../dataload/GridDataLoadRequest.java | 450 ---- .../dataload/GridDataLoadResponse.java | 166 -- .../dataload/GridDataLoadUpdateJob.java | 119 - .../dataload/GridDataLoaderFuture.java | 75 - .../dataload/GridDataLoaderProcessor.java | 316 --- .../dataload/IgniteDataLoaderImpl.java | 1453 ------------ .../internal/processors/dataload/package.html | 24 - .../datastreamer/DataStreamProcessor.java | 307 +++ .../datastreamer/DataStreamerCacheUpdaters.java | 206 ++ .../datastreamer/DataStreamerEntry.java | 170 ++ .../datastreamer/DataStreamerFuture.java | 60 + .../datastreamer/DataStreamerImpl.java | 1403 ++++++++++++ .../datastreamer/DataStreamerRequest.java | 451 ++++ .../datastreamer/DataStreamerResponse.java | 166 ++ .../datastreamer/DataStreamerUpdateJob.java | 150 ++ .../processors/datastreamer/package-info.java | 22 + .../datastructures/DataStructuresProcessor.java | 44 +- .../GridCacheAtomicSequenceImpl.java | 4 +- .../datastructures/GridCacheSetImpl.java | 5 +- .../dr/GridDrDataLoadCacheUpdater.java | 85 - .../dr/IgniteDrDataStreamerCacheUpdater.java | 92 + .../internal/processors/dr/package-info.java | 22 + .../ignite/internal/processors/dr/package.html | 26 - .../processors/hadoop/HadoopNoopProcessor.java | 2 +- .../processors/hadoop/package-info.java | 22 + .../internal/processors/hadoop/package.html | 24 - .../processors/igfs/IgfsDataManager.java | 58 +- .../processors/igfs/IgfsDeleteWorker.java | 2 +- .../igfs/IgfsDirectoryNotEmptyException.java | 44 - .../internal/processors/igfs/IgfsFileImpl.java | 7 + .../internal/processors/igfs/IgfsFileInfo.java | 3 +- .../internal/processors/igfs/IgfsImpl.java | 617 ++---- .../processors/igfs/IgfsInputStreamImpl.java | 10 +- .../processors/igfs/IgfsIpcHandler.java | 4 +- .../processors/igfs/IgfsMetaManager.java | 47 +- .../processors/igfs/IgfsOutputStreamImpl.java | 2 +- .../internal/processors/igfs/IgfsProcessor.java | 107 +- .../internal/processors/igfs/IgfsServer.java | 59 +- .../processors/igfs/IgfsServerManager.java | 39 +- .../internal/processors/igfs/IgfsUtils.java | 86 + .../internal/processors/igfs/package-info.java | 22 + .../internal/processors/igfs/package.html | 24 - .../processors/job/GridJobProcessor.java | 5 +- .../internal/processors/job/package-info.java | 22 + .../ignite/internal/processors/job/package.html | 24 - .../processors/jobmetrics/package-info.java | 22 + .../internal/processors/jobmetrics/package.html | 24 - .../offheap/GridOffHeapProcessor.java | 9 +- .../internal/processors/package-info.java | 22 + .../ignite/internal/processors/package.html | 24 - .../internal/processors/port/package-info.java | 22 + .../internal/processors/port/package.html | 24 - .../portable/GridPortableProcessor.java | 142 -- .../portable/os/GridOsPortableProcessor.java | 120 - .../processors/portable/os/package.html | 24 - .../processors/portable/package-info.java | 22 + .../internal/processors/portable/package.html | 24 - .../query/GridQueryCacheObjectsIterator.java | 70 + .../processors/query/GridQueryIndexing.java | 40 +- .../processors/query/GridQueryProcessor.java | 575 +++-- .../query/GridQueryTypeDescriptor.java | 18 +- .../messages/GridQueryCancelRequest.java | 114 + .../twostep/messages/GridQueryFailResponse.java | 140 ++ .../messages/GridQueryNextPageRequest.java | 167 ++ .../messages/GridQueryNextPageResponse.java | 240 ++ .../h2/twostep/messages/GridQueryRequest.java | 211 ++ .../resource/GridNoImplicitInjection.java | 25 + .../processors/resource/GridResourceField.java | 15 +- .../processors/resource/GridResourceIoc.java | 90 +- .../processors/resource/GridResourceMethod.java | 3 + .../resource/GridResourceProcessor.java | 57 +- .../resource/GridResourceServiceInjector.java | 2 +- .../processors/resource/GridResourceUtils.java | 4 +- .../processors/resource/package-info.java | 22 + .../internal/processors/resource/package.html | 24 - .../processors/rest/GridRestCommand.java | 8 +- .../processors/rest/GridRestProcessor.java | 80 +- .../processors/rest/GridRestResponse.java | 1 - .../message/GridClientAbstractMessage.java | 1 - .../message/GridClientHandshakeRequest.java | 1 - .../rest/client/message/package-info.java | 22 + .../processors/rest/client/message/package.html | 24 - .../handlers/cache/GridCacheCommandHandler.java | 52 +- .../cache/GridCacheQueryCommandHandler.java | 4 +- .../rest/handlers/cache/package-info.java | 22 + .../processors/rest/handlers/cache/package.html | 24 - .../DataStructuresCommandHandler.java | 4 +- .../processors/rest/handlers/package-info.java | 22 + .../processors/rest/handlers/package.html | 24 - .../handlers/task/GridTaskCommandHandler.java | 9 +- .../top/GridTopologyCommandHandler.java | 4 +- .../rest/handlers/top/package-info.java | 22 + .../processors/rest/handlers/top/package.html | 24 - .../version/GridVersionCommandHandler.java | 2 +- .../rest/handlers/version/package-info.java | 22 + .../rest/handlers/version/package.html | 24 - .../internal/processors/rest/package-info.java | 22 + .../internal/processors/rest/package.html | 24 - .../processors/rest/protocols/package-info.java | 22 + .../processors/rest/protocols/package.html | 24 - .../protocols/tcp/GridMemcachedMessage.java | 1 - .../tcp/GridTcpMemcachedNioListener.java | 6 +- .../protocols/tcp/GridTcpRestNioListener.java | 9 +- .../rest/protocols/tcp/GridTcpRestParser.java | 6 +- .../rest/protocols/tcp/GridTcpRestProtocol.java | 9 - .../rest/protocols/tcp/package-info.java | 22 + .../processors/rest/protocols/tcp/package.html | 24 - .../rest/request/GridRestRequest.java | 17 - .../rest/request/GridRestTaskRequest.java | 17 - .../processors/rest/request/package-info.java | 22 + .../processors/rest/request/package.html | 24 - .../processors/schedule/package-info.java | 22 + .../internal/processors/schedule/package.html | 24 - .../processors/segmentation/package-info.java | 22 + .../processors/segmentation/package.html | 24 - .../service/GridServiceDeploymentFuture.java | 6 +- .../service/GridServiceProcessor.java | 10 +- .../processors/service/GridServiceProxy.java | 2 +- .../processors/session/package-info.java | 23 + .../internal/processors/session/package.html | 25 - .../streamer/GridStreamProcessor.java | 354 --- .../streamer/GridStreamerAttributes.java | 127 -- .../streamer/GridStreamerCancelRequest.java | 110 - .../streamer/GridStreamerContextDelegate.java | 102 - .../streamer/GridStreamerContextImpl.java | 201 -- .../streamer/GridStreamerExecutionBatch.java | 185 -- .../streamer/GridStreamerExecutionRequest.java | 293 --- .../streamer/GridStreamerResponse.java | 144 -- .../GridStreamerRouteFailedException.java | 36 - .../GridStreamerStageExecutionFuture.java | 363 --- .../streamer/GridStreamerWindowIterator.java | 40 - .../processors/streamer/IgniteStreamerEx.java | 94 - .../processors/streamer/IgniteStreamerImpl.java | 1394 ------------ .../streamer/StreamerMBeanAdapter.java | 116 - .../streamer/StreamerMetricsAdapter.java | 272 --- .../streamer/StreamerMetricsHolder.java | 424 ---- .../streamer/StreamerStageMBeanAdapter.java | 101 - .../streamer/StreamerStageMetricsAdapter.java | 135 -- .../streamer/StreamerStageMetricsHolder.java | 167 -- .../streamer/StreamerStageWrapper.java | 90 - .../streamer/StreamerWindowMetricsAdapter.java | 65 - .../streamer/StreamerWindowMetricsHolder.java | 50 - .../internal/processors/streamer/package.html | 24 - .../task/GridStreamerBroadcastTask.java | 137 -- .../streamer/task/GridStreamerQueryTask.java | 140 -- .../streamer/task/GridStreamerReduceTask.java | 144 -- .../processors/task/GridTaskProcessor.java | 33 +- .../internal/processors/task/package-info.java | 22 + .../internal/processors/task/package.html | 24 - .../timeout/GridTimeoutProcessor.java | 2 +- .../processors/timeout/package-info.java | 22 + .../internal/processors/timeout/package.html | 24 - .../org/apache/ignite/internal/util/F0.java | 147 ++ .../ignite/internal/util/GridArgumentCheck.java | 1 - .../internal/util/GridConcurrentFactory.java | 59 - .../internal/util/GridIdentityHashSet.java | 63 - .../internal/util/GridLeanIdentitySet.java | 117 + .../ignite/internal/util/GridLeanMap.java | 2 +- .../internal/util/GridSerializableFuture.java | 28 - .../ignite/internal/util/GridThreadLocal.java | 175 -- .../ignite/internal/util/GridThreadLocalEx.java | 210 -- .../apache/ignite/internal/util/GridTimer.java | 2 +- .../internal/util/IgniteExceptionRegistry.java | 164 +- .../ignite/internal/util/IgniteUtils.java | 218 +- .../util/future/GridCompoundFuture.java | 49 +- .../util/future/GridCompoundIdentityFuture.java | 15 +- .../util/future/GridEmbeddedFuture.java | 74 +- .../util/future/GridFinishedFuture.java | 158 +- .../util/future/GridFinishedFutureEx.java | 197 -- .../internal/util/future/GridFutureAdapter.java | 360 +-- .../util/future/GridFutureAdapterEx.java | 517 ----- .../util/future/GridFutureChainListener.java | 18 +- .../util/future/IgniteFinishedFutureImpl.java | 27 +- .../util/future/IgniteFinishedFutureImplEx.java | 30 - .../internal/util/future/IgniteFutureImpl.java | 36 +- .../internal/util/future/package-info.java | 22 + .../ignite/internal/util/future/package.html | 24 - .../internal/util/gridify/package-info.java | 22 + .../ignite/internal/util/gridify/package.html | 24 - .../internal/util/io/GridFilenameUtils.java | 15 +- .../util/ipc/IpcServerEndpointDeserializer.java | 66 - .../util/ipc/loopback/package-info.java | 22 + .../internal/util/ipc/loopback/package.html | 24 - .../ignite/internal/util/ipc/package-info.java | 22 + .../ignite/internal/util/ipc/package.html | 24 - .../internal/util/ipc/shmem/package-info.java | 22 + .../ignite/internal/util/ipc/shmem/package.html | 24 - .../internal/util/lang/GridAbsClosure.java | 2 - .../ignite/internal/util/lang/GridFunc.java | 670 +----- .../ignite/internal/util/lang/GridMapEntry.java | 4 +- .../util/lang/GridMetadataAwareAdapter.java | 71 +- .../internal/util/lang/GridPlainFuture.java | 79 - .../util/lang/GridPlainFutureAdapter.java | 299 --- .../nio/GridConnectionBytesVerifyFilter.java | 1 - .../util/nio/GridNioEmbeddedFuture.java | 9 +- .../util/nio/GridNioFinishedFuture.java | 77 +- .../ignite/internal/util/nio/GridNioFuture.java | 84 +- .../internal/util/nio/GridNioFutureImpl.java | 279 +-- .../ignite/internal/util/nio/GridNioServer.java | 4 +- .../util/nio/GridShmemCommunicationClient.java | 146 -- .../util/nio/GridTcpCommunicationClient.java | 1 - .../util/nio/GridTcpNioCommunicationClient.java | 18 +- .../ignite/internal/util/nio/package-info.java | 22 + .../ignite/internal/util/nio/package.html | 24 - .../internal/util/nio/ssl/package-info.java | 22 + .../ignite/internal/util/nio/ssl/package.html | 24 - .../util/offheap/unsafe/GridUnsafeMemory.java | 26 +- .../ignite/internal/util/package-info.java | 22 + .../apache/ignite/internal/util/package.html | 24 - .../internal/util/portscanner/package-info.java | 22 + .../internal/util/portscanner/package.html | 24 - .../internal/util/scala/package-info.java | 22 + .../ignite/internal/util/scala/package.html | 24 - .../internal/util/snaptree/package-info.java | 22 + .../ignite/internal/util/snaptree/package.html | 24 - .../ignite/internal/util/test/package-info.java | 22 + .../ignite/internal/util/test/package.html | 24 - .../internal/util/tostring/package-info.java | 22 + .../ignite/internal/util/tostring/package.html | 24 - .../ignite/internal/util/typedef/PCE.java | 2 +- .../util/typedef/internal/package-info.java | 22 + .../internal/util/typedef/internal/package.html | 24 - .../internal/util/typedef/package-info.java | 22 + .../ignite/internal/util/typedef/package.html | 24 - .../ignite/internal/util/worker/GridWorker.java | 41 +- .../internal/util/worker/GridWorkerFuture.java | 17 - .../internal/util/worker/package-info.java | 22 + .../ignite/internal/util/worker/package.html | 24 - .../apache/ignite/internal/visor/VisorJob.java | 3 + .../internal/visor/VisorMultiNodeTask.java | 1 + .../visor/cache/VisorCacheClearTask.java | 8 +- .../visor/cache/VisorCacheCompactTask.java | 91 - .../visor/cache/VisorCacheConfiguration.java | 46 +- .../cache/VisorCacheDefaultConfiguration.java | 1 - .../visor/cache/VisorCacheMetadataTask.java | 2 +- .../internal/visor/cache/VisorCacheMetrics.java | 1 + .../cache/VisorCacheMetricsCollectorTask.java | 2 +- .../cache/VisorCachePreloadConfiguration.java | 16 +- .../visor/cache/VisorCachePreloadTask.java | 2 +- .../cache/VisorCacheQueryConfiguration.java | 123 + .../visor/cache/VisorCacheResetMetricsTask.java | 2 +- .../visor/cache/VisorCacheSwapBackupsTask.java | 2 +- .../compute/VisorComputeMonitoringHolder.java | 10 +- .../node/VisorCacheQueryConfiguration.java | 106 - .../visor/node/VisorGridConfiguration.java | 29 +- .../visor/node/VisorIgfsConfiguration.java | 7 +- .../visor/node/VisorNodeDataCollectorJob.java | 42 +- .../node/VisorNodeDataCollectorJobResult.java | 27 +- .../visor/node/VisorNodeDataCollectorTask.java | 8 +- .../node/VisorNodeDataCollectorTaskResult.java | 45 +- .../node/VisorNodeSuppressedErrorsTask.java | 99 + .../visor/node/VisorQueryConfiguration.java | 138 -- .../internal/visor/query/VisorQueryTask.java | 4 +- .../internal/visor/streamer/VisorStreamer.java | 104 - .../streamer/VisorStreamerConfiguration.java | 177 -- .../visor/streamer/VisorStreamerMetrics.java | 350 --- .../streamer/VisorStreamerMetricsResetTask.java | 75 - .../visor/streamer/VisorStreamerResetTask.java | 75 - .../streamer/VisorStreamerStageMetrics.java | 277 --- .../org/apache/ignite/lang/IgniteCallable.java | 2 +- .../org/apache/ignite/lang/IgniteFuture.java | 94 +- .../org/apache/ignite/lang/IgniteImmutable.java | 49 + .../org/apache/ignite/lang/IgnitePredicate.java | 4 +- .../ignite/lang/IgniteProductVersion.java | 1 - .../java/org/apache/ignite/lang/IgniteUuid.java | 13 +- .../org/apache/ignite/lang/package-info.java | 22 + .../java/org/apache/ignite/lang/package.html | 24 - .../apache/ignite/logger/java/package-info.java | 22 + .../org/apache/ignite/logger/java/package.html | 24 - .../org/apache/ignite/logger/package-info.java | 22 + .../java/org/apache/ignite/logger/package.html | 24 - .../ignite/marshaller/AbstractMarshaller.java | 8 + .../apache/ignite/marshaller/Marshaller.java | 7 + .../ignite/marshaller/MarshallerContext.java | 42 + .../ignite/marshaller/jdk/package-info.java | 22 + .../apache/ignite/marshaller/jdk/package.html | 24 - .../optimized/OptimizedClassDescriptor.java | 741 +++---- .../optimized/OptimizedClassResolver.java | 477 ---- .../optimized/OptimizedMarshallable.java | 65 - .../optimized/OptimizedMarshaller.java | 168 +- .../optimized/OptimizedMarshallerIdMapper.java | 33 + .../optimized/OptimizedMarshallerUtils.java | 316 +-- .../optimized/OptimizedObjectInputStream.java | 255 ++- .../optimized/OptimizedObjectOutputStream.java | 175 +- .../optimized-classnames.previous.properties | 15 - .../optimized/optimized-classnames.properties | 116 - .../marshaller/optimized/package-info.java | 22 + .../ignite/marshaller/optimized/package.html | 24 - .../apache/ignite/marshaller/package-info.java | 22 + .../org/apache/ignite/marshaller/package.html | 24 - .../apache/ignite/messaging/package-info.java | 22 + .../org/apache/ignite/messaging/package.html | 24 - .../mxbean/ClusterLocalNodeMetricsMXBean.java | 4 + .../org/apache/ignite/mxbean/package-info.java | 22 + .../java/org/apache/ignite/mxbean/package.html | 24 - .../java/org/apache/ignite/package-info.java | 21 + .../main/java/org/apache/ignite/package.html | 24 - .../apache/ignite/plugin/PluginProvider.java | 3 +- .../extensions/communication/MessageWriter.java | 11 + .../extensions/communication/package-info.java | 22 + .../extensions/communication/package.html | 24 - .../security/GridSecurityCredentials.java | 1 - .../ignite/plugin/security/package-info.java | 22 + .../apache/ignite/plugin/security/package.html | 24 - .../plugin/segmentation/package-info.java | 22 + .../ignite/plugin/segmentation/package.html | 24 - .../apache/ignite/scheduler/package-info.java | 22 + .../org/apache/ignite/scheduler/package.html | 24 - .../apache/ignite/services/package-info.java | 21 + .../org/apache/ignite/services/package.html | 23 - .../org/apache/ignite/spi/IgniteSpiAdapter.java | 45 +- .../ignite/spi/IgniteSpiConsistencyChecked.java | 7 - .../org/apache/ignite/spi/IgniteSpiContext.java | 51 - .../spi/checkpoint/cache/package-info.java | 23 + .../ignite/spi/checkpoint/cache/package.html | 25 - .../spi/checkpoint/jdbc/package-info.java | 23 + .../ignite/spi/checkpoint/jdbc/package.html | 25 - .../spi/checkpoint/noop/package-info.java | 22 + .../ignite/spi/checkpoint/noop/package.html | 24 - .../ignite/spi/checkpoint/package-info.java | 22 + .../apache/ignite/spi/checkpoint/package.html | 24 - .../spi/checkpoint/sharedfs/package-info.java | 22 + .../ignite/spi/checkpoint/sharedfs/package.html | 24 - .../spi/collision/fifoqueue/package-info.java | 22 + .../ignite/spi/collision/fifoqueue/package.html | 24 - .../spi/collision/jobstealing/package-info.java | 22 + .../spi/collision/jobstealing/package.html | 24 - .../ignite/spi/collision/noop/package-info.java | 22 + .../ignite/spi/collision/noop/package.html | 24 - .../ignite/spi/collision/package-info.java | 22 + .../apache/ignite/spi/collision/package.html | 24 - .../collision/priorityqueue/package-info.java | 22 + .../spi/collision/priorityqueue/package.html | 24 - .../ignite/spi/communication/package-info.java | 22 + .../ignite/spi/communication/package.html | 24 - .../communication/tcp/TcpCommunicationSpi.java | 421 +--- .../tcp/TcpCommunicationSpiMBean.java | 8 - .../spi/communication/tcp/package-info.java | 22 + .../ignite/spi/communication/tcp/package.html | 24 - .../spi/deployment/local/package-info.java | 22 + .../ignite/spi/deployment/local/package.html | 24 - .../ignite/spi/deployment/package-info.java | 22 + .../apache/ignite/spi/deployment/package.html | 24 - .../ignite/spi/discovery/package-info.java | 22 + .../apache/ignite/spi/discovery/package.html | 24 - .../spi/discovery/tcp/TcpDiscoverySpi.java | 13 +- .../tcp/internal/TcpDiscoveryNode.java | 1 - .../discovery/tcp/internal/package-info.java | 22 + .../spi/discovery/tcp/internal/package.html | 24 - .../tcp/ipfinder/jdbc/package-info.java | 22 + .../discovery/tcp/ipfinder/jdbc/package.html | 24 - .../TcpDiscoveryMulticastIpFinder.java | 5 +- .../tcp/ipfinder/multicast/package-info.java | 22 + .../tcp/ipfinder/multicast/package.html | 24 - .../discovery/tcp/ipfinder/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/package.html | 24 - .../tcp/ipfinder/sharedfs/package-info.java | 22 + .../tcp/ipfinder/sharedfs/package.html | 24 - .../discovery/tcp/ipfinder/vm/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/vm/package.html | 24 - .../messages/TcpDiscoveryAuthFailedMessage.java | 1 - .../messages/TcpDiscoveryHeartbeatMessage.java | 1 - .../discovery/tcp/messages/package-info.java | 22 + .../spi/discovery/tcp/messages/package.html | 24 - .../ignite/spi/discovery/tcp/package-info.java | 22 + .../ignite/spi/discovery/tcp/package.html | 24 - .../spi/eventstorage/memory/package-info.java | 22 + .../ignite/spi/eventstorage/memory/package.html | 24 - .../ignite/spi/eventstorage/package-info.java | 22 + .../apache/ignite/spi/eventstorage/package.html | 24 - .../spi/failover/always/package-info.java | 22 + .../ignite/spi/failover/always/package.html | 24 - .../spi/failover/jobstealing/package-info.java | 22 + .../spi/failover/jobstealing/package.html | 24 - .../ignite/spi/failover/never/package-info.java | 22 + .../ignite/spi/failover/never/package.html | 24 - .../ignite/spi/failover/package-info.java | 22 + .../org/apache/ignite/spi/failover/package.html | 24 - .../spi/indexing/IndexingQueryFilter.java | 2 +- .../ignite/spi/indexing/noop/package-info.java | 22 + .../ignite/spi/indexing/package-info.java | 22 + .../org/apache/ignite/spi/indexing/package.html | 24 - .../loadbalancing/adaptive/package-info.java | 22 + .../spi/loadbalancing/adaptive/package.html | 24 - .../ignite/spi/loadbalancing/package-info.java | 22 + .../ignite/spi/loadbalancing/package.html | 24 - .../loadbalancing/roundrobin/package-info.java | 22 + .../spi/loadbalancing/roundrobin/package.html | 24 - .../weightedrandom/package-info.java | 22 + .../loadbalancing/weightedrandom/package.html | 24 - .../org/apache/ignite/spi/package-info.java | 22 + .../java/org/apache/ignite/spi/package.html | 24 - .../spi/swapspace/file/FileSwapSpaceSpi.java | 10 +- .../ignite/spi/swapspace/file/package-info.java | 22 + .../ignite/spi/swapspace/file/package.html | 24 - .../ignite/spi/swapspace/noop/package-info.java | 22 + .../ignite/spi/swapspace/noop/package.html | 24 - .../ignite/spi/swapspace/package-info.java | 22 + .../apache/ignite/spi/swapspace/package.html | 24 - .../ignite/startup/BasicWarmupClosure.java | 1 + .../ignite/startup/cmdline/package-info.java | 22 + .../apache/ignite/startup/cmdline/package.html | 24 - .../ignite/streamer/StreamerConfiguration.java | 249 --- .../apache/ignite/streamer/StreamerContext.java | 142 -- .../ignite/streamer/StreamerEventRouter.java | 55 - .../streamer/StreamerEventRouterAdapter.java | 60 - .../streamer/StreamerFailureListener.java | 44 - .../apache/ignite/streamer/StreamerMBean.java | 169 -- .../apache/ignite/streamer/StreamerMetrics.java | 209 -- .../apache/ignite/streamer/StreamerStage.java | 61 - .../ignite/streamer/StreamerStageMBean.java | 114 - .../ignite/streamer/StreamerStageMetrics.java | 93 - .../apache/ignite/streamer/StreamerWindow.java | 206 -- .../ignite/streamer/StreamerWindowMBean.java | 58 - .../ignite/streamer/StreamerWindowMetrics.java | 44 - .../ignite/streamer/index/StreamerIndex.java | 305 --- .../streamer/index/StreamerIndexEntry.java | 57 - .../streamer/index/StreamerIndexPolicy.java | 50 - .../streamer/index/StreamerIndexProvider.java | 107 - .../index/StreamerIndexProviderAdapter.java | 796 ------- .../index/StreamerIndexProviderMBean.java | 74 - .../streamer/index/StreamerIndexUpdateSync.java | 77 - .../streamer/index/StreamerIndexUpdater.java | 88 - .../index/hash/StreamerHashIndexProvider.java | 500 ----- .../ignite/streamer/index/hash/package.html | 23 - .../apache/ignite/streamer/index/package.html | 23 - .../index/tree/StreamerTreeIndexProvider.java | 953 -------- .../ignite/streamer/index/tree/package.html | 23 - .../org/apache/ignite/streamer/package.html | 23 - .../router/StreamerAffinityEventRouter.java | 150 -- .../StreamerCacheAffinityEventRouter.java | 70 - .../router/StreamerLocalEventRouter.java | 46 - .../router/StreamerRandomEventRouter.java | 89 - .../router/StreamerRoundRobinEventRouter.java | 53 - .../apache/ignite/streamer/router/package.html | 23 - .../window/StreamerBoundedSizeBatchWindow.java | 804 ------- .../window/StreamerBoundedSizeSortedWindow.java | 218 -- .../window/StreamerBoundedSizeWindow.java | 144 -- .../StreamerBoundedSizeWindowAdapter.java | 357 --- .../window/StreamerBoundedTimeBatchWindow.java | 906 -------- .../window/StreamerBoundedTimeWindow.java | 462 ---- .../window/StreamerUnboundedWindow.java | 111 - .../streamer/window/StreamerWindowAdapter.java | 537 ----- .../apache/ignite/streamer/window/package.html | 23 - .../org/apache/ignite/thread/package-info.java | 22 + .../java/org/apache/ignite/thread/package.html | 24 - .../TransactionSynchronization.java | 2 +- .../org/jdk8/backport/ConcurrentHashMap8.java | 46 +- .../jdk8/backport/ConcurrentLinkedDeque8.java | 32 +- .../jdk8/backport/ConcurrentLinkedHashMap.java | 32 +- .../main/java/org/jdk8/backport/LongAdder.java | 32 +- .../main/java/org/jdk8/backport/Striped64.java | 27 +- .../org/jdk8/backport/ThreadLocalRandom8.java | 32 +- .../java/org/pcollections/AmortizedPQueue.java | 156 -- .../main/java/org/pcollections/ConsPStack.java | 225 -- .../src/main/java/org/pcollections/Empty.java | 47 - .../main/java/org/pcollections/HashPMap.java | 175 -- .../java/org/pcollections/HashTreePBag.java | 47 - .../java/org/pcollections/HashTreePMap.java | 52 - .../java/org/pcollections/HashTreePSet.java | 46 - .../src/main/java/org/pcollections/IntTree.java | 320 --- .../main/java/org/pcollections/IntTreePMap.java | 165 -- .../src/main/java/org/pcollections/MapPBag.java | 143 -- .../src/main/java/org/pcollections/MapPSet.java | 101 - .../main/java/org/pcollections/OrderedPSet.java | 85 - .../src/main/java/org/pcollections/PBag.java | 23 - .../main/java/org/pcollections/PCollection.java | 56 - .../src/main/java/org/pcollections/PMap.java | 49 - .../main/java/org/pcollections/POrderedSet.java | 25 - .../src/main/java/org/pcollections/PQueue.java | 38 - .../main/java/org/pcollections/PSequence.java | 73 - .../src/main/java/org/pcollections/PSet.java | 23 - .../src/main/java/org/pcollections/PStack.java | 51 - .../src/main/java/org/pcollections/PVector.java | 45 - .../org/pcollections/SimpleImmutableEntry.java | 146 -- .../main/java/org/pcollections/TreePVector.java | 155 -- .../META-INF/classnames-jdk.properties | 371 ++++ .../resources/META-INF/classnames.properties | 1605 ++++++++++++++ .../resources/META-INF/licenses/apache-2.0.txt | 0 .../core/src/main/resources/ignite.properties | 2 +- .../core/src/test/bin/start-nodes-custom.bat | 3 +- .../spring-cache-client-benchmark-1.xml | 2 - .../spring-cache-client-benchmark-2.xml | 2 - .../spring-cache-client-benchmark-3.xml | 2 - .../core/src/test/config/discovery-stress.xml | 3 +- modules/core/src/test/config/example-cache.xml | 7 +- modules/core/src/test/config/igfs-loopback.xml | 8 +- modules/core/src/test/config/igfs-shmem.xml | 10 +- .../src/test/config/io-manager-benchmark.xml | 13 - modules/core/src/test/config/jobs-load-base.xml | 11 - .../src/test/config/load/cache-benchmark.xml | 2 - .../test/config/load/cache-client-benchmark.xml | 2 - .../config/load/dsi-49-server-production.xml | 4 +- .../core/src/test/config/load/dsi-load-base.xml | 16 - .../src/test/config/load/dsi-load-client.xml | 4 +- .../src/test/config/load/dsi-load-server.xml | 4 +- modules/core/src/test/config/log4j-test.xml | 6 + .../core/src/test/config/spring-cache-load.xml | 2 +- .../config/spring-cache-put-remove-load.xml | 8 - .../core/src/test/config/spring-multicache.xml | 16 +- modules/core/src/test/config/start-nodes.ini | 15 + .../core/src/test/config/store/jdbc/Ignite.xml | 84 +- .../test/config/websession/example-cache.xml | 164 ++ .../test/config/websession/spring-cache-1.xml | 6 +- .../test/config/websession/spring-cache-2.xml | 6 +- .../test/config/websession/spring-cache-3.xml | 6 +- modules/core/src/test/java/ExcludeList | 20 + .../GridCacheAffinityBackupsSelfTest.java | 2 + .../IgniteExternalizableAbstractTest.java | 9 +- .../store/jdbc/CacheJdbcPojoStoreTest.java | 561 +---- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 11 +- .../cache/store/jdbc/model/Organization.java | 2 +- .../cache/store/jdbc/model/OrganizationKey.java | 2 +- .../ignite/cache/store/jdbc/model/Person.java | 2 +- .../store/jdbc/model/PersonComplexKey.java | 2 +- .../cache/store/jdbc/model/PersonKey.java | 2 +- .../cache/store/jdbc/model/package-info.java | 22 + .../ignite/cache/store/jdbc/model/package.html | 24 - .../ignite/cache/store/jdbc/package-info.java | 22 + .../apache/ignite/cache/store/jdbc/package.html | 24 - .../apache/ignite/cache/store/package-info.java | 22 + .../org/apache/ignite/cache/store/package.html | 24 - .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 5 +- .../igfs/IgfsFragmentizerAbstractSelfTest.java | 6 +- .../ignite/igfs/IgfsFragmentizerSelfTest.java | 1 + .../ignite/internal/ClusterMetricsSelfTest.java | 2 + .../internal/ClusterNodeMetricsSelfTest.java | 31 +- .../ignite/internal/GridAffinitySelfTest.java | 3 +- .../internal/GridDiscoveryEventSelfTest.java | 44 - .../internal/GridMultipleJobsSelfTest.java | 2 +- .../GridTaskFutureImplStopGridSelfTest.java | 2 +- .../internal/GridTaskListenerSelfTest.java | 2 +- .../internal/GridUpdateNotifierSelfTest.java | 16 + .../managers/checkpoint/package-info.java | 22 + .../internal/managers/checkpoint/package.html | 24 - .../GridCommunicationSendMessageSelfTest.java | 2 +- .../managers/communication/package-info.java | 22 + .../managers/communication/package.html | 24 - .../managers/deployment/package-info.java | 22 + .../internal/managers/deployment/package.html | 24 - .../GridDiscoveryManagerAliveCacheSelfTest.java | 5 +- .../ignite/internal/managers/package-info.java | 22 + .../ignite/internal/managers/package.html | 24 - .../managers/swapspace/package-info.java | 22 + .../internal/managers/swapspace/package.html | 24 - .../apache/ignite/internal/package-info.java | 22 + .../org/apache/ignite/internal/package.html | 24 - .../GridCacheAbstractFailoverSelfTest.java | 4 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 290 ++- .../GridCacheAbstractLocalStoreSelfTest.java | 8 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 8 +- .../cache/GridCacheAbstractSelfTest.java | 8 + ...acheAbstractUsersAffinityMapperSelfTest.java | 4 +- .../cache/GridCacheAffinityRoutingSelfTest.java | 6 - .../GridCacheAsyncOperationsLimitSelfTest.java | 3 +- ...dCacheAtomicUsersAffinityMapperSelfTest.java | 7 +- .../cache/GridCacheBasicStoreAbstractTest.java | 4 +- .../cache/GridCacheClearLocalySelfTest.java | 19 +- .../cache/GridCacheConcurrentMapTest.java | 4 +- .../GridCacheConcurrentTxMultiNodeTest.java | 17 +- ...idCacheConfigurationConsistencySelfTest.java | 29 +- ...ridCacheConfigurationValidationSelfTest.java | 11 +- .../GridCacheDeploymentOffHeapSelfTest.java | 1 - .../cache/GridCacheDeploymentSelfTest.java | 9 +- .../cache/GridCacheEntryMemorySizeSelfTest.java | 12 +- .../cache/GridCacheEntryVersionSelfTest.java | 4 +- .../GridCacheExAbstractFullApiSelfTest.java | 2 +- .../GridCacheFieldsQueryNoDataSelfTest.java | 83 - .../GridCacheFinishPartitionsSelfTest.java | 13 +- ...CacheFullTextQueryMultithreadedSelfTest.java | 1 - ...idCacheGetAndTransformStoreAbstractTest.java | 4 +- .../cache/GridCacheIncrementTransformTest.java | 4 +- .../GridCacheInterceptorAbstractSelfTest.java | 186 +- .../cache/GridCacheKeyCheckSelfTest.java | 1 - .../processors/cache/GridCacheLeakTest.java | 3 +- .../cache/GridCacheLifecycleAwareSelfTest.java | 10 +- .../cache/GridCacheMemoryModeSelfTest.java | 9 +- .../cache/GridCacheMultiUpdateLockSelfTest.java | 4 +- .../cache/GridCacheMvccFlagsTest.java | 8 +- .../cache/GridCacheMvccPartitionedSelfTest.java | 128 +- .../processors/cache/GridCacheMvccSelfTest.java | 232 +- .../cache/GridCacheObjectToStringSelfTest.java | 2 +- .../cache/GridCacheOffHeapSelfTest.java | 11 +- .../processors/cache/GridCacheOffHeapTest.java | 1 - .../GridCacheOnCopyFlagAbstractSelfTest.java | 688 ++++++ .../GridCacheOnCopyFlagAtomicSelfTest.java | 38 + .../cache/GridCacheOnCopyFlagLocalSelfTest.java | 38 + .../GridCacheOnCopyFlagReplicatedSelfTest.java | 38 + ...ridCacheOnCopyFlagTxPartitionedSelfTest.java | 38 + .../GridCacheOrderedPreloadingSelfTest.java | 6 +- .../cache/GridCacheP2PUndeploySelfTest.java | 10 +- .../cache/GridCachePartitionedGetSelfTest.java | 4 +- .../GridCachePartitionedLocalStoreSelfTest.java | 7 - ...chePartitionedOffHeapLocalStoreSelfTest.java | 7 - ...hePartitionedProjectionAffinitySelfTest.java | 4 +- .../GridCachePreloadingEvictionsSelfTest.java | 6 +- .../cache/GridCachePutAllFailoverSelfTest.java | 8 +- .../cache/GridCacheQueryEmbeddedValue.java | 2 + .../cache/GridCacheQueryIndexSelfTest.java | 126 -- .../GridCacheQueryIndexingDisabledSelfTest.java | 1 - .../GridCacheQueryInternalKeysSelfTest.java | 5 +- .../GridCacheReferenceCleanupSelfTest.java | 2 +- .../GridCacheReplicatedLocalStoreSelfTest.java | 7 - ...heReplicatedUsersAffinityMapperSelfTest.java | 7 +- .../GridCacheReturnValueTransferSelfTest.java | 2 + .../processors/cache/GridCacheStopSelfTest.java | 1 - .../cache/GridCacheStoreValueBytesSelfTest.java | 24 +- .../cache/GridCacheSwapPreloadSelfTest.java | 10 +- .../processors/cache/GridCacheTestEntryEx.java | 276 +-- .../processors/cache/GridCacheTestValue.java | 2 +- .../processors/cache/GridCacheTestValue2.java | 2 + ...cheTransactionalAbstractMetricsSelfTest.java | 7 + .../cache/GridCacheTtlManagerLoadTest.java | 2 +- ...ridCacheTxPartitionedLocalStoreSelfTest.java | 7 - .../GridCacheTxUsersAffinityMapperSelfTest.java | 7 +- .../GridCacheValueBytesPreloadingSelfTest.java | 4 +- ...idCacheValueConsistencyAbstractSelfTest.java | 4 +- .../cache/GridCacheVersionMultinodeTest.java | 2 +- .../cache/GridCacheVersionSelfTest.java | 3 + ...idCacheWriteBehindStoreAbstractSelfTest.java | 2 +- .../IgniteCacheAbstractStopBusySelfTest.java | 2 +- ...IgniteCacheAtomicCopyOnReadDisabledTest.java | 32 + .../IgniteCacheContainsKeyAbstractSelfTest.java | 6 +- ...niteCacheCopyOnReadDisabledAbstractTest.java | 123 + .../IgniteCacheInterceptorSelfTestSuite.java | 5 + .../IgniteCacheTxCopyOnReadDisabledTest.java | 32 + .../cache/IgniteCacheTxPreloadNoWriteTest.java | 111 + .../cache/IgnitePutAllLargeBatchSelfTest.java | 6 +- ...tAllUpdateNonPreloadedPartitionSelfTest.java | 10 +- .../IgniteTxConcurrentGetAbstractTest.java | 4 +- .../IgniteTxExceptionAbstractSelfTest.java | 1 - .../cache/IgniteTxMultiNodeAbstractTest.java | 8 +- .../IgniteTxStoreExceptionAbstractSelfTest.java | 8 +- ...IgniteCacheAbstractExecutionContextTest.java | 5 +- ...actQueueFailoverDataConsistencySelfTest.java | 2 +- .../GridCacheQueueCleanupSelfTest.java | 2 +- ...dCacheQueueMultiNodeConsistencySelfTest.java | 3 +- .../GridCacheSetAbstractSelfTest.java | 4 +- .../GridCacheSetFailoverAbstractSelfTest.java | 4 +- .../IgniteCollectionAbstractTest.java | 4 +- ...GridCachePartitionedNodeRestartSelfTest.java | 4 +- ...idCachePartitionedNodeRestartTxSelfTest.java | 4 +- ...PartitionedQueueCreateMultiNodeSelfTest.java | 4 +- .../IgnitePartitionedSetNoBackupsSelfTest.java | 2 +- .../GridCacheAbstractJobExecutionTest.java | 9 +- .../GridCacheAbstractNodeRestartSelfTest.java | 6 +- ...tractPartitionedByteArrayValuesSelfTest.java | 2 - .../GridCacheAbstractPrimarySyncSelfTest.java | 4 +- .../GridCacheAtomicTimeoutSelfTest.java | 3 +- ...acheEntrySetIterationPreloadingSelfTest.java | 2 +- .../distributed/GridCacheEventAbstractTest.java | 29 +- ...heExpiredEntriesPreloadAbstractSelfTest.java | 6 +- ...GridCacheLoadingConcurrentGridStartTest.java | 154 ++ .../distributed/GridCacheLockAbstractTest.java | 6 +- ...dCacheMultithreadedFailoverAbstractTest.java | 4 +- .../GridCacheNodeFailureAbstractTest.java | 1 + ...dCachePartitionedAffinityFilterSelfTest.java | 4 +- ...chePartitionedReloadAllAbstractSelfTest.java | 61 +- .../GridCachePreloadEventsAbstractSelfTest.java | 8 +- .../GridCachePreloadLifecycleAbstractTest.java | 6 +- ...GridCachePreloadRestartAbstractSelfTest.java | 11 +- .../IgniteCacheSystemTransactionsSelfTest.java | 188 ++ .../IgniteCrossCacheTxStoreSelfTest.java | 6 - ...iteTxConsistencyRestartAbstractSelfTest.java | 6 +- .../IgniteTxPreloadAbstractTest.java | 6 +- .../IgniteTxTimeoutAbstractTest.java | 2 +- .../dht/GridCacheAtomicNearCacheSelfTest.java | 16 +- .../dht/GridCacheColocatedDebugTest.java | 6 +- ...dCacheColocatedTxSingleThreadedSelfTest.java | 4 +- .../dht/GridCacheDhtEntrySelfTest.java | 12 +- ...GridCacheDhtEvictionNearReadersSelfTest.java | 16 +- .../dht/GridCacheDhtEvictionSelfTest.java | 24 +- .../dht/GridCacheDhtInternalEntrySelfTest.java | 8 +- .../dht/GridCacheDhtMappingSelfTest.java | 4 +- .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 10 +- .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 30 +- .../GridCacheDhtPreloadDisabledSelfTest.java | 12 +- .../GridCacheDhtPreloadMessageCountTest.java | 4 +- .../dht/GridCacheDhtPreloadOffHeapSelfTest.java | 1 - .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 6 +- .../dht/GridCacheDhtPreloadSelfTest.java | 37 +- .../GridCacheDhtPreloadStartStopSelfTest.java | 16 +- .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 10 +- .../distributed/dht/GridCacheDhtTestUtils.java | 25 +- ...ePartitionedNearDisabledMetricsSelfTest.java | 4 +- ...idCachePartitionedPreloadEventsSelfTest.java | 8 +- ...dCachePartitionedTopologyChangeSelfTest.java | 4 +- ...ridCachePartitionedUnloadEventsSelfTest.java | 18 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 11 +- .../atomic/GridCacheAtomicPreloadSelfTest.java | 2 +- ...unctionExcludeNeighborsAbstractSelfTest.java | 5 +- ...tomicClientOnlyMultiNodeFullApiSelfTest.java | 31 + ...yOnReadDisabledMultiNodeFullApiSelfTest.java | 36 + ...GridCacheAtomicMultiNodeFullApiSelfTest.java | 4 +- ...idCacheAtomicPartitionedMetricsSelfTest.java | 4 +- .../near/GridCacheNearEvictionSelfTest.java | 6 +- .../near/GridCacheNearMultiGetSelfTest.java | 4 +- .../near/GridCacheNearMultiNodeSelfTest.java | 13 +- .../near/GridCacheNearOneNodeSelfTest.java | 2 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 46 +- .../near/GridCacheNearOnlyTopologySelfTest.java | 4 +- .../GridCacheNearPartitionedClearSelfTest.java | 4 +- .../near/GridCacheNearReadersSelfTest.java | 25 +- .../near/GridCacheNearTxMultiNodeSelfTest.java | 4 +- ...AffinityExcludeNeighborsPerformanceTest.java | 4 +- .../GridCachePartitionedAffinitySelfTest.java | 4 +- .../GridCachePartitionedBasicOpSelfTest.java | 2 +- ...yOnReadDisabledMultiNodeFullApiSelfTest.java | 37 + .../near/GridCachePartitionedEventSelfTest.java | 4 +- ...GridCachePartitionedFilteredPutSelfTest.java | 1 + ...idCachePartitionedHitsAndMissesSelfTest.java | 16 +- .../GridCachePartitionedMetricsSelfTest.java | 4 +- ...achePartitionedMultiNodeCounterSelfTest.java | 22 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 19 +- .../GridCachePartitionedNodeRestartTest.java | 4 +- ...ePartitionedOptimisticTxNodeRestartTest.java | 4 +- ...achePartitionedPreloadLifecycleSelfTest.java | 5 +- ...hePartitionedQueryMultiThreadedSelfTest.java | 305 --- .../GridCachePartitionedTxSalvageSelfTest.java | 4 +- ...achePartitionedTxSingleThreadedSelfTest.java | 4 +- ...stractReplicatedByteArrayValuesSelfTest.java | 2 - .../GridCacheReplicatedFullApiSelfTest.java | 1 + .../GridCacheReplicatedInvalidateSelfTest.java | 6 +- .../GridCacheReplicatedNodeRestartSelfTest.java | 6 +- .../GridCacheSyncReplicatedPreloadSelfTest.java | 6 +- ...CacheReplicatedPreloadLifecycleSelfTest.java | 5 +- ...idCacheReplicatedPreloadOffHeapSelfTest.java | 3 +- .../GridCacheReplicatedPreloadSelfTest.java | 20 +- ...eplicatedPreloadStartStopEventsSelfTest.java | 6 +- .../GridCacheEvictionFilterSelfTest.java | 4 +- .../cache/eviction/GridCacheMockEntry.java | 5 +- .../GridCacheLruNearEvictionPolicySelfTest.java | 7 +- ...heNearOnlyLruNearEvictionPolicySelfTest.java | 7 +- .../IgniteCacheExpiryPolicyAbstractTest.java | 68 +- ...eCacheExpiryPolicyWithStoreAbstractTest.java | 2 +- ...eCacheAtomicStoreSessionWriteBehindTest.java | 38 + ...acheStoreSessionWriteBehindAbstractTest.java | 269 +++ ...gniteCacheTxStoreSessionWriteBehindTest.java | 32 + .../GridCacheLocalByteArrayValuesSelfTest.java | 1 - .../GridCacheSwapScanQueryAbstractSelfTest.java | 1 + .../query/GridCacheSwapScanQuerySelfTest.java | 1 + ...ridCacheContinuousQueryAbstractSelfTest.java | 140 +- ...dCacheContinuousQueryReplicatedSelfTest.java | 6 +- ...dCacheAbstractReduceFieldsQuerySelfTest.java | 429 ---- ...ridCacheReduceFieldsQueryAtomicSelfTest.java | 38 - ...GridCacheReduceFieldsQueryLocalSelfTest.java | 37 - ...cheReduceFieldsQueryPartitionedSelfTest.java | 59 - ...acheReduceFieldsQueryReplicatedSelfTest.java | 37 - .../processors/closure/package-info.java | 22 + .../internal/processors/closure/package.html | 24 - .../continuous/GridEventConsumeSelfTest.java | 3 +- .../dataload/GridDataLoaderImplSelfTest.java | 215 -- .../dataload/GridDataLoaderPerformanceTest.java | 199 -- .../GridDataLoaderProcessorSelfTest.java | 925 -------- .../DataStreamProcessorSelfTest.java | 970 ++++++++ .../datastreamer/DataStreamerImplSelfTest.java | 205 ++ .../IgniteDataStreamerPerformanceTest.java | 197 ++ .../processors/igfs/IgfsAbstractSelfTest.java | 299 ++- ...sCachePerBlockLruEvictionPolicySelfTest.java | 16 +- .../processors/igfs/IgfsCacheSelfTest.java | 1 - .../igfs/IgfsDataManagerSelfTest.java | 7 +- .../igfs/IgfsDualAbstractSelfTest.java | 90 +- .../igfs/IgfsExUniversalFileSystemAdapter.java | 104 + .../processors/igfs/IgfsFileInfoSelfTest.java | 2 + .../igfs/IgfsMetaManagerSelfTest.java | 1 - .../processors/igfs/IgfsMetricsSelfTest.java | 16 +- .../processors/igfs/IgfsModesSelfTest.java | 13 +- .../processors/igfs/IgfsProcessorSelfTest.java | 2 +- .../igfs/IgfsProcessorValidationSelfTest.java | 8 +- ...IpcEndpointRegistrationAbstractSelfTest.java | 23 +- ...dpointRegistrationOnLinuxAndMacSelfTest.java | 7 +- ...pcEndpointRegistrationOnWindowsSelfTest.java | 5 +- .../processors/igfs/IgfsSizeSelfTest.java | 24 +- .../processors/igfs/IgfsStreamsSelfTest.java | 2 +- .../processors/igfs/IgfsTaskSelfTest.java | 2 - .../igfs/UniversalFileSystemAdapter.java | 96 + .../internal/processors/igfs/package-info.java | 22 + .../internal/processors/igfs/package.html | 24 - .../IgfsAbstractRecordResolverSelfTest.java | 2 - .../cache/GridCacheCommandHandlerSelfTest.java | 43 +- .../processors/service/DummyService.java | 4 + .../streamer/GridStreamerEvictionSelfTest.java | 164 -- .../streamer/GridStreamerFailoverSelfTest.java | 267 --- .../GridStreamerLifecycleAwareSelfTest.java | 212 -- .../streamer/GridStreamerSelfTest.java | 796 ------- .../processors/streamer/GridTestStage.java | 52 - .../streamer/GridTestStreamerEventRouter.java | 49 - .../ignite/internal/processors/streamer/SC.java | 31 - .../util/IgniteExceptionRegistrySelfTest.java | 51 +- .../util/future/GridCompoundFutureSelfTest.java | 30 +- .../util/future/GridEmbeddedFutureSelfTest.java | 13 +- .../util/future/GridFinishedFutureSelfTest.java | 103 - .../util/future/GridFutureAdapterSelfTest.java | 115 +- .../future/GridFutureListenPerformanceTest.java | 22 +- .../util/future/IgniteFutureImplTest.java | 99 +- .../util/future/nio/GridNioFutureSelfTest.java | 8 +- .../IpcServerEndpointDeserializerSelfTest.java | 160 -- .../ipc/shmem/IpcSharedMemoryNodeStartup.java | 10 +- .../internal/util/nio/GridNioSelfTest.java | 18 +- .../nio/impl/GridNioFilterChainSelfTest.java | 7 +- .../ignite/internal/util/nio/package-info.java | 22 + .../ignite/internal/util/nio/package.html | 24 - .../internal/util/tostring/package-info.java | 22 + .../ignite/internal/util/tostring/package.html | 24 - .../ignite/jvmtest/ConcurrentMapTest.java | 5 +- .../lang/GridFutureListenPerformanceTest.java | 2 +- .../GridImmutableCollectionsPerfomanceTest.java | 120 - .../lang/GridMetadataAwareAdapterSelfTest.java | 80 +- .../org/apache/ignite/lang/package-info.java | 22 + .../java/org/apache/ignite/lang/package.html | 24 - .../lang/utils/GridLeanIdentitySetSelfTest.java | 62 + .../ignite/lang/utils/GridPCollectionsTest.java | 54 - .../ignite/lang/utils/GridTrieMapSelfTest.java | 242 -- .../apache/ignite/lang/utils/package-info.java | 22 + .../org/apache/ignite/lang/utils/package.html | 24 - .../apache/ignite/loadtest/package-info.java | 22 + .../org/apache/ignite/loadtest/package.html | 24 - .../loadtests/GridCacheMultiNodeLoadTest.java | 4 +- .../capacity/spring-capacity-cache.xml | 4 +- .../loadtests/colocation/GridTestMain.java | 6 +- .../loadtests/colocation/spring-colocation.xml | 6 +- .../communication/GridIoManagerBenchmark0.java | 1 - .../GridContinuousOperationsLoadTest.java | 2 +- .../GridCachePartitionedAtomicLongLoadTest.java | 2 +- .../direct/multisplit/package-info.java | 22 + .../loadtests/direct/multisplit/package.html | 24 - .../loadtests/direct/newnodes/package-info.java | 22 + .../loadtests/direct/newnodes/package.html | 24 - .../loadtests/direct/redeploy/package-info.java | 22 + .../loadtests/direct/redeploy/package.html | 24 - .../loadtests/direct/session/package-info.java | 22 + .../loadtests/direct/session/package.html | 24 - .../loadtests/direct/stealing/package-info.java | 22 + .../loadtests/direct/stealing/package.html | 24 - .../loadtests/discovery/GridGcTimeoutTest.java | 2 +- .../ignite/loadtests/dsi/package-info.java | 22 + .../apache/ignite/loadtests/dsi/package.html | 24 - .../loadtests/hashmap/GridCacheTestContext.java | 29 +- .../loadtests/hashmap/GridHashMapLoadTest.java | 10 +- ...GridJobExecutionLoadTestClientSemaphore.java | 2 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 2 +- .../ignite/loadtests/job/package-info.java | 22 + .../apache/ignite/loadtests/job/package.html | 24 - .../mapper/GridContinuousMapperLoadTest1.java | 2 +- .../mapper/GridContinuousMapperLoadTest2.java | 2 +- .../ignite/loadtests/mapper/TestObject.java | 2 +- .../mergesort/GridMergeSortLoadTask.java | 2 +- .../ignite/loadtests/streamer/EventClosure.java | 60 - .../streamer/GridStreamerBenchmark.java | 140 -- .../streamer/GridStreamerIndexLoadTest.java | 179 -- .../loadtests/streamer/GridStreamerLoad.java | 62 - .../ignite/loadtests/streamer/IndexUpdater.java | 46 - .../ignite/loadtests/streamer/QueryClosure.java | 107 - .../loadtests/streamer/average/TestAverage.java | 70 - .../loadtests/streamer/average/TestStage.java | 63 - .../swap/GridSwapEvictAllBenchmark.java | 1 - .../apache/ignite/logger/java/package-info.java | 22 + .../org/apache/ignite/logger/java/package.html | 24 - .../marshaller/GridMarshallerAbstractTest.java | 66 +- .../GridMarshallerPerformanceTest.java | 2 - .../marshaller/MarshallerContextTestImpl.java | 43 + .../jdk/GridJdkMarshallerSelfTest.java | 2 +- .../ignite/marshaller/jdk/package-info.java | 22 + .../apache/ignite/marshaller/jdk/package.html | 24 - .../OptimizedMarshallerEnumSelfTest.java | 4 +- .../OptimizedMarshallerNodeFailoverTest.java | 200 ++ .../optimized/OptimizedMarshallerSelfTest.java | 186 +- ...arshallerSerialPersistentFieldsSelfTest.java | 110 + .../optimized/OptimizedMarshallerTest.java | 102 +- .../OptimizedObjectStreamSelfTest.java | 47 +- .../marshaller/optimized/package-info.java | 22 + .../ignite/marshaller/optimized/package.html | 24 - .../apache/ignite/marshaller/package-info.java | 22 + .../org/apache/ignite/marshaller/package.html | 24 - .../ignite/messaging/GridMessagingSelfTest.java | 15 +- .../GridP2PContinuousDeploymentSelfTest.java | 4 +- .../org/apache/ignite/p2p/package-info.java | 22 + .../java/org/apache/ignite/p2p/package.html | 24 - .../java/org/apache/ignite/package-info.java | 22 + .../test/java/org/apache/ignite/package.html | 24 - .../org/apache/ignite/session/package-info.java | 22 + .../java/org/apache/ignite/session/package.html | 24 - .../spi/GridTcpSpiForwardingSelfTest.java | 1 - .../spi/checkpoint/cache/package-info.java | 22 + .../ignite/spi/checkpoint/cache/package.html | 24 - .../spi/checkpoint/jdbc/package-info.java | 22 + .../ignite/spi/checkpoint/jdbc/package.html | 24 - .../ignite/spi/checkpoint/package-info.java | 22 + .../apache/ignite/spi/checkpoint/package.html | 24 - .../spi/checkpoint/sharedfs/package-info.java | 22 + .../ignite/spi/checkpoint/sharedfs/package.html | 24 - .../spi/collision/fifoqueue/package-info.java | 22 + .../ignite/spi/collision/fifoqueue/package.html | 24 - .../spi/collision/jobstealing/package-info.java | 22 + .../spi/collision/jobstealing/package.html | 24 - .../ignite/spi/collision/package-info.java | 22 + .../apache/ignite/spi/collision/package.html | 24 - .../collision/priorityqueue/package-info.java | 22 + .../spi/collision/priorityqueue/package.html | 24 - .../communication/GridCacheMessageSelfTest.java | 546 +++++ .../ignite/spi/communication/package-info.java | 22 + .../ignite/spi/communication/package.html | 24 - .../tcp/GridCacheDhtLockBackupSelfTest.java | 4 +- .../GridTcpCommunicationSpiAbstractTest.java | 17 +- ...mmunicationSpiConcurrentConnectSelfTest.java | 1 - .../GridTcpCommunicationSpiConfigSelfTest.java | 2 - ...cpCommunicationSpiMultithreadedSelfTest.java | 13 +- ...pCommunicationSpiMultithreadedShmemTest.java | 28 - ...ommunicationSpiMultithreadedTcpSelfTest.java | 28 - ...dTcpCommunicationSpiRecoveryAckSelfTest.java | 1 - ...GridTcpCommunicationSpiRecoverySelfTest.java | 1 - .../GridTcpCommunicationSpiShmemSelfTest.java | 31 - .../tcp/GridTcpCommunicationSpiTcpSelfTest.java | 6 +- .../spi/communication/tcp/package-info.java | 22 + .../ignite/spi/communication/tcp/package.html | 24 - .../spi/deployment/local/package-info.java | 22 + .../ignite/spi/deployment/local/package.html | 24 - .../discovery/AbstractDiscoverySelfTest.java | 1 - .../ignite/spi/discovery/package-info.java | 22 + .../apache/ignite/spi/discovery/package.html | 24 - .../tcp/ipfinder/jdbc/package-info.java | 22 + .../discovery/tcp/ipfinder/jdbc/package.html | 24 - .../discovery/tcp/ipfinder/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/package.html | 24 - .../tcp/ipfinder/sharedfs/package-info.java | 22 + .../tcp/ipfinder/sharedfs/package.html | 24 - .../discovery/tcp/ipfinder/vm/package-info.java | 22 + .../spi/discovery/tcp/ipfinder/vm/package.html | 24 - .../ignite/spi/discovery/tcp/package-info.java | 22 + .../ignite/spi/discovery/tcp/package.html | 24 - .../spi/eventstorage/memory/package-info.java | 22 + .../ignite/spi/eventstorage/memory/package.html | 24 - .../spi/failover/always/package-info.java | 22 + .../ignite/spi/failover/always/package.html | 24 - .../spi/failover/jobstealing/package-info.java | 22 + .../spi/failover/jobstealing/package.html | 24 - .../ignite/spi/failover/never/package-info.java | 22 + .../ignite/spi/failover/never/package.html | 24 - .../ignite/spi/failover/package-info.java | 22 + .../org/apache/ignite/spi/failover/package.html | 24 - .../loadbalancing/adaptive/package-info.java | 22 + .../spi/loadbalancing/adaptive/package.html | 24 - .../ignite/spi/loadbalancing/package-info.java | 22 + .../ignite/spi/loadbalancing/package.html | 24 - .../loadbalancing/roundrobin/package-info.java | 22 + .../spi/loadbalancing/roundrobin/package.html | 24 - .../weightedrandom/package-info.java | 22 + .../loadbalancing/weightedrandom/package.html | 24 - .../org/apache/ignite/spi/package-info.java | 22 + .../java/org/apache/ignite/spi/package.html | 24 - .../ignite/spi/swapspace/package-info.java | 22 + .../apache/ignite/spi/swapspace/package.html | 24 - .../ignite/startup/cmdline/package-info.java | 22 + .../apache/ignite/startup/cmdline/package.html | 24 - .../org/apache/ignite/startup/package-info.java | 22 + .../java/org/apache/ignite/startup/package.html | 24 - .../ignite/startup/servlet/package-info.java | 22 + .../apache/ignite/startup/servlet/package.html | 24 - .../GridCacheStoreValueBytesNode.java | 7 - .../GridCacheStoreValueBytesTest.java | 4 +- .../index/GridStreamerIndexSelfTest.java | 686 ------ .../window/GridStreamerWindowSelfTest.java | 911 -------- .../testframework/GridSpiTestContext.java | 23 - .../ignite/testframework/GridTestUtils.java | 71 +- .../testframework/config/package-info.java | 22 + .../ignite/testframework/config/package.html | 24 - .../ignite/testframework/http/package-info.java | 22 + .../ignite/testframework/http/package.html | 24 - .../testframework/junits/GridAbstractTest.java | 10 +- .../junits/GridTestKernalContext.java | 16 +- .../ignite/testframework/junits/IgniteMock.java | 14 +- .../junits/IgniteTestResources.java | 46 +- .../junits/common/GridCommonAbstractTest.java | 6 +- .../junits/common/package-info.java | 22 + .../testframework/junits/common/package.html | 24 - .../testframework/junits/package-info.java | 22 + .../ignite/testframework/junits/package.html | 24 - .../testframework/junits/spi/package-info.java | 22 + .../testframework/junits/spi/package.html | 24 - .../ignite/testframework/package-info.java | 22 + .../apache/ignite/testframework/package.html | 24 - .../ignite/testsuites/IgniteBasicTestSuite.java | 3 - .../IgniteCacheFullApiSelfTestSuite.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite.java | 27 +- .../ignite/testsuites/IgniteIgfsTestSuite.java | 4 +- .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../testsuites/IgniteLangSelfTestSuite.java | 2 +- .../IgniteMarshallerSelfTestSuite.java | 2 + .../IgniteSpiCommunicationSelfTestSuite.java | 4 +- .../testsuites/IgniteStreamerSelfTestSuite.java | 46 - .../apache/ignite/testsuites/package-info.java | 22 + .../org/apache/ignite/testsuites/package.html | 24 - .../org/apache/ignite/util/package-info.java | 22 + .../java/org/apache/ignite/util/package.html | 24 - .../webapp/META-INF/ignite-webapp-config.xml | 72 +- .../tests/p2p/GridExternalAffinityFunction.java | 8 +- .../apache/ignite/tests/p2p/package-info.java | 22 + .../org/apache/ignite/tests/p2p/package.html | 24 - .../spi/deployment/uri/tasks/package-info.java | 22 + .../spi/deployment/uri/tasks/package.html | 24 - .../query/h2/GridH2IndexingGeoSelfTest.java | 8 +- modules/hadoop/config/core-site.ignite.xml | 90 + modules/hadoop/config/hive-site.ignite.xml | 37 + modules/hadoop/config/mapred-site.ignite.xml | 66 + modules/hadoop/docs/hadoop_readme.md | 135 ++ modules/hadoop/docs/hadoop_readme.pdf | Bin 0 -> 82297 bytes modules/hadoop/pom.xml | 6 + .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 34 +- .../apache/ignite/hadoop/fs/package-info.java | 22 + .../org/apache/ignite/hadoop/fs/package.html | 24 - .../hadoop/fs/v1/IgniteHadoopFileSystem.java | 25 +- .../ignite/hadoop/fs/v1/package-info.java | 22 + .../org/apache/ignite/hadoop/fs/v1/package.html | 24 - .../hadoop/fs/v2/IgniteHadoopFileSystem.java | 8 +- .../ignite/hadoop/fs/v2/package-info.java | 22 + .../org/apache/ignite/hadoop/fs/v2/package.html | 24 - .../IgniteHadoopClientProtocolProvider.java | 7 +- .../ignite/hadoop/mapreduce/package-info.java | 22 + .../apache/ignite/hadoop/mapreduce/package.html | 24 - .../org/apache/ignite/hadoop/package-info.java | 22 + .../java/org/apache/ignite/hadoop/package.html | 24 - .../processors/hadoop/HadoopProcessor.java | 4 +- .../internal/processors/hadoop/HadoopSetup.java | 41 +- .../hadoop/igfs/HadoopIgfsEndpoint.java | 5 +- .../processors/hadoop/igfs/HadoopIgfsEx.java | 4 +- .../hadoop/igfs/HadoopIgfsFuture.java | 7 +- .../hadoop/igfs/HadoopIgfsInProc.java | 9 +- .../hadoop/igfs/HadoopIgfsInputStream.java | 6 +- .../processors/hadoop/igfs/HadoopIgfsIo.java | 6 +- .../processors/hadoop/igfs/HadoopIgfsIpcIo.java | 17 +- .../hadoop/igfs/HadoopIgfsOutProc.java | 50 +- .../processors/hadoop/igfs/HadoopIgfsUtils.java | 10 +- .../hadoop/jobtracker/HadoopJobTracker.java | 20 +- .../hadoop/proto/HadoopClientProtocol.java | 3 - .../proto/HadoopProtocolJobStatusTask.java | 2 +- .../hadoop/shuffle/HadoopShuffle.java | 4 +- .../hadoop/shuffle/HadoopShuffleJob.java | 16 +- .../external/HadoopExternalTaskExecutor.java | 25 +- .../child/HadoopChildProcessRunner.java | 10 +- .../child/HadoopExternalProcessStarter.java | 4 +- .../HadoopExternalCommunication.java | 11 +- .../HadoopTcpNioCommunicationClient.java | 12 +- .../HadoopClientProtocolEmbeddedSelfTest.java | 3 +- .../hadoop/HadoopClientProtocolSelfTest.java | 2 +- .../ignite/igfs/Hadoop1DualAbstractTest.java | 105 + .../igfs/Hadoop1OverIgfsDualAsyncTest.java | 30 + .../igfs/Hadoop1OverIgfsDualSyncTest.java | 30 + ...oopFileSystemUniversalFileSystemAdapter.java | 113 + .../HadoopIgfs20FileSystemAbstractSelfTest.java | 19 +- ...Igfs20FileSystemLoopbackPrimarySelfTest.java | 14 +- ...oopIgfs20FileSystemShmemPrimarySelfTest.java | 14 +- .../igfs/HadoopIgfsDualAbstractSelfTest.java | 28 +- ...oopSecondaryFileSystemConfigurationTest.java | 53 +- .../apache/ignite/igfs/IgfsEventsTestSuite.java | 44 +- .../java/org/apache/ignite/igfs/IgfsLoad.java | 549 ----- .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 11 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 34 +- .../IgniteHadoopFileSystemClientSelfTest.java | 13 +- ...IgniteHadoopFileSystemHandshakeSelfTest.java | 23 +- .../IgniteHadoopFileSystemIpcCacheSelfTest.java | 19 +- ...niteHadoopFileSystemLoggerStateSelfTest.java | 14 +- ...adoopFileSystemLoopbackAbstractSelfTest.java | 12 +- ...teHadoopFileSystemSecondaryModeSelfTest.java | 27 +- ...teHadoopFileSystemShmemAbstractSelfTest.java | 12 +- .../hadoop/HadoopAbstractSelfTest.java | 6 - .../hadoop/HadoopCommandLineTest.java | 16 +- .../HadoopDefaultMapReducePlannerSelfTest.java | 6 +- .../processors/hadoop/HadoopGroupingTest.java | 3 +- .../hadoop/HadoopJobTrackerSelfTest.java | 4 +- .../hadoop/HadoopMapReduceEmbeddedSelfTest.java | 3 +- .../hadoop/HadoopPopularWordsTest.java | 4 +- .../hadoop/HadoopSortingExternalTest.java | 13 +- .../processors/hadoop/HadoopSortingTest.java | 3 +- .../hadoop/HadoopTaskExecutionSelfTest.java | 6 +- .../HadoopExternalTaskExecutionSelfTest.java | 13 +- .../HadoopExternalCommunicationSelfTest.java | 4 +- .../ignite/loadtests/igfs/IgfsNodeStartup.java | 48 - .../igfs/IgfsPerformanceBenchmark.java | 281 --- .../testsuites/IgniteHadoopTestSuite.java | 10 +- .../HibernateAccessStrategyAdapter.java | 1 - .../hibernate/HibernateCollectionRegion.java | 2 +- .../cache/hibernate/HibernateEntityRegion.java | 2 +- .../hibernate/HibernateGeneralDataRegion.java | 2 +- .../hibernate/HibernateNaturalIdRegion.java | 2 +- .../HibernateNonStrictAccessStrategy.java | 2 +- .../hibernate/HibernateQueryResultsRegion.java | 2 +- .../HibernateReadOnlyAccessStrategy.java | 2 +- .../HibernateReadWriteAccessStrategy.java | 34 +- .../ignite/cache/hibernate/HibernateRegion.java | 2 +- .../cache/hibernate/HibernateRegionFactory.java | 6 +- .../hibernate/HibernateTimestampsRegion.java | 2 +- .../HibernateTransactionalAccessStrategy.java | 4 +- .../HibernateTransactionalDataRegion.java | 2 +- .../ignite/cache/hibernate/package-info.java | 24 + .../apache/ignite/cache/hibernate/package.html | 26 - .../cache/store/hibernate/package-info.java | 22 + .../ignite/cache/store/hibernate/package.html | 24 - .../HibernateL2CacheConfigurationSelfTest.java | 2 +- .../hibernate/HibernateL2CacheSelfTest.java | 4 +- .../cache/store/hibernate/package-info.java | 22 + .../ignite/cache/store/hibernate/package.html | 24 - .../processors/query/h2/IgniteH2Indexing.java | 861 +++---- .../query/h2/opt/GridH2AbstractKeyValueRow.java | 11 +- .../query/h2/opt/GridH2RowDescriptor.java | 16 +- .../query/h2/opt/GridLuceneIndex.java | 8 +- .../processors/query/h2/package-info.java | 22 + .../internal/processors/query/h2/package.html | 24 - .../processors/query/h2/sql/GridSqlColumn.java | 6 + .../processors/query/h2/sql/GridSqlElement.java | 54 +- .../query/h2/sql/GridSqlFunction.java | 26 +- .../query/h2/sql/GridSqlFunctionType.java | 3 + .../processors/query/h2/sql/GridSqlJoin.java | 30 +- .../query/h2/sql/GridSqlOperationType.java | 6 +- .../query/h2/sql/GridSqlQueryParser.java | 124 +- .../query/h2/sql/GridSqlQuerySplitter.java | 198 +- .../processors/query/h2/sql/GridSqlSelect.java | 100 +- .../query/h2/sql/GridSqlSortColumn.java | 76 + .../processors/query/h2/sql/GridSqlType.java | 94 + .../query/h2/twostep/GridMapQueryExecutor.java | 436 +++- .../query/h2/twostep/GridMergeIndex.java | 111 +- .../h2/twostep/GridMergeIndexUnsorted.java | 44 +- .../h2/twostep/GridReduceQueryExecutor.java | 420 +++- .../query/h2/twostep/GridResultPage.java | 47 +- .../twostep/messages/GridNextPageRequest.java | 70 - .../twostep/messages/GridNextPageResponse.java | 191 -- .../query/h2/twostep/messages/GridQueryAck.java | 45 - .../twostep/messages/GridQueryFailResponse.java | 57 - .../h2/twostep/messages/GridQueryRequest.java | 72 - .../GridCacheAbstractFieldsQuerySelfTest.java | 46 +- .../cache/GridCacheAbstractQuerySelfTest.java | 2094 ------------------ .../cache/GridCacheCrossCacheQuerySelfTest.java | 159 +- .../GridCacheCrossCacheQuerySelfTestNewApi.java | 411 ---- .../cache/GridCacheOffHeapAndSwapSelfTest.java | 22 +- ...idCacheQueryEvictsMultiThreadedSelfTest.java | 28 - .../GridCacheQueryIndexDisabledSelfTest.java | 257 +++ .../cache/GridCacheQueryLoadSelfTest.java | 387 ---- .../cache/GridCacheQueryMetricsSelfTest.java | 6 - .../GridCacheQueryMultiThreadedSelfTest.java | 869 -------- ...QueryOffheapEvictsMultiThreadedSelfTest.java | 28 - ...dCacheQueryOffheapMultiThreadedSelfTest.java | 28 - .../cache/GridCacheQuerySimpleBenchmark.java | 212 ++ .../cache/GridCacheQueryTestValue.java | 2 +- ...idCacheReduceQueryMultithreadedSelfTest.java | 8 +- .../GridCacheSqlQueryMultiThreadedSelfTest.java | 142 -- .../processors/cache/GridCacheSwapSelfTest.java | 12 +- .../cache/GridIndexingWithNoopSwapSelfTest.java | 17 +- .../IgniteCacheAbstractFieldsQuerySelfTest.java | 778 +++++++ .../cache/IgniteCacheAbstractQuerySelfTest.java | 1550 +++++++++++++ .../IgniteCacheFieldsQueryNoDataSelfTest.java | 84 + ...hePartitionedQueryMultiThreadedSelfTest.java | 311 +++ ...teCacheQueryEvictsMultiThreadedSelfTest.java | 28 + .../cache/IgniteCacheQueryIndexSelfTest.java | 133 ++ .../cache/IgniteCacheQueryLoadSelfTest.java | 339 +++ .../IgniteCacheQueryMultiThreadedSelfTest.java | 747 +++++++ ...QueryOffheapEvictsMultiThreadedSelfTest.java | 28 + ...eCacheQueryOffheapMultiThreadedSelfTest.java | 28 + ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 197 ++ .../GridCacheAtomicFieldsQuerySelfTest.java | 66 - ...cheAtomicNearEnabledFieldsQuerySelfTest.java | 32 - ...GridCacheAtomicNearEnabledQuerySelfTest.java | 38 - .../near/GridCacheAtomicQuerySelfTest.java | 38 - ...CachePartitionedQueryP2PEnabledSelfTest.java | 34 - .../near/GridCachePartitionedQuerySelfTest.java | 479 ---- .../near/GridCacheQueryNodeRestartSelfTest.java | 225 -- .../IgniteCacheAtomicFieldsQuerySelfTest.java | 59 + ...cheAtomicNearEnabledFieldsQuerySelfTest.java | 32 + ...niteCacheAtomicNearEnabledQuerySelfTest.java | 38 + .../near/IgniteCacheAtomicQuerySelfTest.java | 38 + ...rtitionedFieldsQueryP2PDisabledSelfTest.java | 34 + ...niteCachePartitionedFieldsQuerySelfTest.java | 57 + ...achePartitionedQueryP2PDisabledSelfTest.java | 34 + .../IgniteCachePartitionedQuerySelfTest.java | 133 ++ .../IgniteCacheQueryNodeRestartSelfTest.java | 220 ++ .../GridCacheReplicatedFieldsQuerySelfTest.java | 2 +- ...dCacheReplicatedQueryP2PEnabledSelfTest.java | 34 - .../GridCacheReplicatedQuerySelfTest.java | 683 ------ ...eplicatedFieldsQueryP2PDisabledSelfTest.java | 34 + ...gniteCacheReplicatedFieldsQuerySelfTest.java | 79 + ...CacheReplicatedQueryP2PDisabledSelfTest.java | 34 + .../IgniteCacheReplicatedQuerySelfTest.java | 576 +++++ .../GridCacheLocalAtomicQuerySelfTest.java | 32 - .../GridCacheLocalFieldsQuerySelfTest.java | 38 - .../local/GridCacheLocalQuerySelfTest.java | 107 - .../IgniteCacheLocalAtomicQuerySelfTest.java | 32 + .../IgniteCacheLocalFieldsQuerySelfTest.java | 38 + .../local/IgniteCacheLocalQuerySelfTest.java | 85 + ...dCacheAbstractReduceFieldsQuerySelfTest.java | 413 ++++ ...ridCacheReduceFieldsQueryAtomicSelfTest.java | 38 + ...GridCacheReduceFieldsQueryLocalSelfTest.java | 37 + ...cheReduceFieldsQueryPartitionedSelfTest.java | 59 + ...acheReduceFieldsQueryReplicatedSelfTest.java | 37 + .../query/h2/GridH2IndexRebuildTest.java | 8 + .../query/h2/GridH2IndexingOffheapSelfTest.java | 20 +- .../h2/GridIndexingSpiAbstractSelfTest.java | 98 +- .../query/h2/sql/GridQueryParsingTest.java | 72 +- .../tcp/GridOrderedMessageCancelSelfTest.java | 14 +- .../IgniteCacheQuerySelfTestSuite.java | 55 +- .../apache/ignite/logger/jcl/package-info.java | 22 + .../org/apache/ignite/logger/jcl/package.html | 24 - .../apache/ignite/logger/jcl/package-info.java | 22 + .../org/apache/ignite/logger/jcl/package.html | 24 - .../ignite/cache/jta/jndi/package-info.java | 22 + .../apache/ignite/cache/jta/jndi/package.html | 24 - .../apache/ignite/cache/jta/package-info.java | 22 + .../org/apache/ignite/cache/jta/package.html | 24 - .../ignite/cache/jta/reflect/package-info.java | 22 + .../ignite/cache/jta/reflect/package.html | 24 - .../processors/cache/jta/CacheJtaManager.java | 6 +- .../cache/jta/GridCacheXAResource.java | 9 +- .../ignite/logger/log4j/package-info.java | 22 + .../org/apache/ignite/logger/log4j/package.html | 24 - .../ignite/logger/log4j/package-info.java | 22 + .../org/apache/ignite/logger/log4j/package.html | 24 - .../rest/protocols/http/jetty/package-info.java | 22 + .../rest/protocols/http/jetty/package.html | 24 - modules/scalar/pom.xml | 8 + .../scala/org/apache/ignite/scalar/scalar.scala | 16 +- .../scalar/src/test/resources/spring-cache.xml | 67 +- .../tests/ScalarAffinityRoutingSpec.scala | 6 +- .../ignite/scalar/tests/ScalarCacheSpec.scala | 4 +- .../scalar/testsuites/ScalarSelfTestSuite.scala | 6 + .../processors/schedule/ScheduleFutureImpl.java | 216 +- .../schedule/GridScheduleSelfTest.java | 4 +- modules/schema-import/pom.xml | 101 + modules/schema-import/readme.txt | 214 ++ .../main/java/media/data_connection_48x48.png | Bin 0 -> 4443 bytes .../src/main/java/media/error_48x48.png | Bin 0 -> 4349 bytes .../src/main/java/media/ignite_128x128.png | Bin 0 -> 4917 bytes .../src/main/java/media/ignite_16x16.png | Bin 0 -> 608 bytes .../src/main/java/media/ignite_24x24.png | Bin 0 -> 930 bytes .../src/main/java/media/ignite_32x32.png | Bin 0 -> 1203 bytes .../src/main/java/media/ignite_48x48.png | Bin 0 -> 1868 bytes .../src/main/java/media/ignite_64x64.png | Bin 0 -> 2453 bytes .../src/main/java/media/information_48x48.png | Bin 0 -> 4102 bytes .../src/main/java/media/question_48x48.png | Bin 0 -> 3857 bytes .../src/main/java/media/sign_warning_48x48.png | Bin 0 -> 2988 bytes .../schema-import/src/main/java/media/style.css | 134 ++ .../src/main/java/media/text_tree_48x48.png | Bin 0 -> 2567 bytes .../ignite/schema/generator/PojoGenerator.java | 414 ++++ .../schema/generator/SnippetGenerator.java | 144 ++ .../ignite/schema/generator/XmlGenerator.java | 345 +++ .../apache/ignite/schema/model/IndexItem.java | 54 + .../ignite/schema/model/PojoDescriptor.java | 509 +++++ .../apache/ignite/schema/model/PojoField.java | 420 ++++ .../schema/parser/DatabaseMetadataParser.java | 108 + .../apache/ignite/schema/parser/DbColumn.java | 76 + .../apache/ignite/schema/parser/DbTable.java | 105 + .../parser/dialect/DB2MetadataDialect.java | 30 + .../parser/dialect/DatabaseMetadataDialect.java | 78 + .../parser/dialect/JdbcMetadataDialect.java | 141 ++ .../parser/dialect/OracleMetadataDialect.java | 281 +++ .../ignite/schema/ui/ConfirmCallable.java | 81 + .../org/apache/ignite/schema/ui/Controls.java | 643 ++++++ .../org/apache/ignite/schema/ui/GridPaneEx.java | 177 ++ .../org/apache/ignite/schema/ui/MessageBox.java | 260 +++ .../apache/ignite/schema/ui/ModalDialog.java | 50 + .../ignite/schema/ui/SchemaImportApp.java | 1638 ++++++++++++++ .../ignite/schema/ui/TextColumnValidator.java | 32 + .../schema/test/AbstractSchemaImportTest.java | 147 ++ .../test/generator/PojoGeneratorTest.java | 70 + .../schema/test/generator/XmlGeneratorTest.java | 50 + .../apache/ignite/schema/test/model/Ignite.xml | 390 ++++ .../apache/ignite/schema/test/model/Objects.txt | 502 +++++ .../ignite/schema/test/model/ObjectsKey.txt | 96 + .../ignite/schema/test/model/Primitives.txt | 506 +++++ .../ignite/schema/test/model/PrimitivesKey.txt | 96 + .../test/parser/DbMetadataParserTest.java | 118 + .../testsuites/IgniteSchemaImportTestSuite.java | 41 + modules/schema-load/pom.xml | 107 - .../main/java/media/data_connection_48x48.png | Bin 4443 -> 0 bytes .../src/main/java/media/error_48x48.png | Bin 4349 -> 0 bytes .../src/main/java/media/ignite_128x128.png | Bin 4917 -> 0 bytes .../src/main/java/media/ignite_16x16.png | Bin 608 -> 0 bytes .../src/main/java/media/ignite_24x24.png | Bin 930 -> 0 bytes .../src/main/java/media/ignite_32x32.png | Bin 1203 -> 0 bytes .../src/main/java/media/ignite_48x48.png | Bin 1868 -> 0 bytes .../src/main/java/media/ignite_64x64.png | Bin 2453 -> 0 bytes .../src/main/java/media/information_48x48.png | Bin 4102 -> 0 bytes .../src/main/java/media/question_48x48.png | Bin 3857 -> 0 bytes .../src/main/java/media/sign_warning_48x48.png | Bin 2988 -> 0 bytes .../schema-load/src/main/java/media/style.css | 117 - .../src/main/java/media/text_tree_48x48.png | Bin 2567 -> 0 bytes .../ignite/schema/generator/PojoGenerator.java | 414 ---- .../schema/generator/SnippetGenerator.java | 138 -- .../ignite/schema/generator/XmlGenerator.java | 347 --- .../ignite/schema/model/PojoDescriptor.java | 510 ----- .../apache/ignite/schema/model/PojoField.java | 420 ---- .../schema/parser/DatabaseMetadataParser.java | 108 - .../apache/ignite/schema/parser/DbColumn.java | 76 - .../apache/ignite/schema/parser/DbTable.java | 105 - .../parser/dialect/DB2MetadataDialect.java | 30 - .../parser/dialect/DatabaseMetadataDialect.java | 78 - .../parser/dialect/JdbcMetadataDialect.java | 141 -- .../parser/dialect/OracleMetadataDialect.java | 257 --- .../ignite/schema/ui/ConfirmCallable.java | 81 - .../org/apache/ignite/schema/ui/Controls.java | 661 ------ .../org/apache/ignite/schema/ui/GridPaneEx.java | 177 -- .../org/apache/ignite/schema/ui/MessageBox.java | 239 -- .../apache/ignite/schema/ui/ModalDialog.java | 50 - .../apache/ignite/schema/ui/SchemaLoadApp.java | 1615 -------------- .../ignite/schema/ui/TextColumnValidator.java | 32 - .../schema/load/AbstractSchemaLoaderTest.java | 134 -- .../load/generator/PojoGeneratorTest.java | 70 - .../schema/load/generator/XmlGeneratorTest.java | 50 - .../apache/ignite/schema/load/model/Ignite.xml | 390 ---- .../apache/ignite/schema/load/model/Objects.txt | 502 ----- .../ignite/schema/load/model/ObjectsKey.txt | 96 - .../ignite/schema/load/model/Primitives.txt | 506 ----- .../ignite/schema/load/model/PrimitivesKey.txt | 96 - .../load/parser/DbMetadataParserTest.java | 118 - .../testsuites/IgniteSchemaLoadTestSuite.java | 41 - .../ignite/logger/slf4j/package-info.java | 22 + .../org/apache/ignite/logger/slf4j/package.html | 24 - .../org/apache/ignite/IgniteSpringBean.java | 18 +- .../ignite/cache/spring/SpringCacheManager.java | 2 +- .../cache/spring/SpringDynamicCacheManager.java | 40 +- .../ignite/cache/spring/package-info.java | 22 + .../org/apache/ignite/cache/spring/package.html | 24 - .../GridSpringBeanSerializationSelfTest.java | 2 + .../processors/resource/package-info.java | 22 + .../internal/processors/resource/package.html | 24 - .../ignite/spring/GridSpringCacheTestKey.java | 4 +- .../util/nodestart/IgniteNodeCallableImpl.java | 42 +- .../tools/ant/beautifier/package-info.java | 22 + .../ignite/tools/ant/beautifier/package.html | 24 - .../ignite/tools/classgen/ClassesGenerator.java | 214 ++ .../ignite/tools/javadoc/IgniteLinkTaglet.java | 4 +- .../optimized/OptimizedClassNamesGenerator.java | 325 --- .../apache/ignite/util/antgar/package-info.java | 22 + .../org/apache/ignite/util/antgar/package.html | 24 - .../ignite/spi/deployment/uri/package-info.java | 22 + .../ignite/spi/deployment/uri/package.html | 24 - .../uri/scanners/file/package-info.java | 22 + .../deployment/uri/scanners/file/package.html | 24 - .../uri/scanners/ftp/package-info.java | 22 + .../deployment/uri/scanners/ftp/package.html | 24 - .../uri/scanners/http/package-info.java | 22 + .../deployment/uri/scanners/http/package.html | 24 - .../deployment/uri/scanners/package-info.java | 22 + .../spi/deployment/uri/scanners/package.html | 24 - .../ignite/spi/deployment/uri/package-info.java | 22 + .../ignite/spi/deployment/uri/package.html | 24 - .../uri/scanners/file/package-info.java | 22 + .../deployment/uri/scanners/file/package.html | 24 - .../uri/scanners/ftp/package-info.java | 22 + .../deployment/uri/scanners/ftp/package.html | 24 - .../uri/scanners/http/package-info.java | 22 + .../deployment/uri/scanners/http/package.html | 24 - .../org/apache/ignite/tools/package-info.java | 22 + .../java/org/apache/ignite/tools/package.html | 24 - .../ignite/visor/commands/VisorConsole.scala | 64 +- .../visor/commands/ack/VisorAckCommand.scala | 4 +- .../commands/cache/VisorCacheCommand.scala | 96 +- .../cache/VisorCacheCompactCommand.scala | 151 -- .../config/VisorConfigurationCommand.scala | 15 - .../commands/events/VisorEventsCommand.scala | 4 +- .../visor/commands/gc/VisorGcCommand.scala | 2 - .../visor/commands/ping/VisorPingCommand.scala | 2 +- .../commands/top/VisorTopologyCommand.scala | 7 +- .../scala/org/apache/ignite/visor/visor.scala | 44 +- .../commands/cache/VisorCacheCommandSpec.scala | 17 +- .../cache/VisorCacheCompactCommandSpec.scala | 103 - .../commands/tasks/VisorTasksCommandSpec.scala | 5 +- .../testsuites/VisorConsoleSelfTestSuite.scala | 3 +- .../apache/ignite/visor/plugin/VisorPlugin.java | 8 +- .../ignite/visor/plugin/package-info.java | 22 + .../org/apache/ignite/visor/plugin/package.html | 24 - .../ignite/cache/websession/package-info.java | 22 + .../apache/ignite/cache/websession/package.html | 24 - .../ignite/startup/servlet/package-info.java | 22 + .../apache/ignite/startup/servlet/package.html | 24 - .../IgniteWebSessionSelfTestSuite.java | 6 + .../internal/websession/WebSessionSelfTest.java | 2 +- modules/winservice/IgniteService.sln | 22 - .../winservice/IgniteService/IgniteService.cs | 170 -- .../IgniteService/IgniteService.csproj | 90 - modules/winservice/README.md | 3 - modules/yardstick/README.md | 17 + .../config/benchmark-multicast.properties | 2 +- modules/yardstick/config/ignite-base-config.xml | 69 +- .../yardstick/config/ignite-store-config.xml | 28 - modules/yardstick/pom.xml | 8 +- .../cache/IgniteSqlQueryBenchmark.java | 2 +- .../cache/IgniteSqlQueryJoinBenchmark.java | 2 +- pom.xml | 204 +- 2055 files changed, 61371 insertions(+), 85118 deletions(-) ----------------------------------------------------------------------
