Merge branch 'master' into ignite-2004
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/09b56444 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/09b56444 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/09b56444 Branch: refs/heads/ignite-2004 Commit: 09b56444d06afda032b9a55201cda0a485215ec9 Parents: 94e301d 00a3937 Author: Tikhonov Nikolay <[email protected]> Authored: Mon Apr 4 19:23:44 2016 +0300 Committer: Tikhonov Nikolay <[email protected]> Committed: Mon Apr 4 19:23:44 2016 +0300 ---------------------------------------------------------------------- .../configuration/IgniteConfiguration.java | 25 + .../ignite/configuration/OdbcConfiguration.java | 319 +++++ .../ignite/internal/GridKernalContext.java | 8 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../apache/ignite/internal/GridLoggerProxy.java | 3 +- .../apache/ignite/internal/IgniteKernal.java | 33 +- .../deployment/GridDeploymentCommunication.java | 3 +- .../discovery/GridDiscoveryManager.java | 2 +- .../cache/CacheEvictableEntryImpl.java | 2 +- .../processors/cache/CacheInvokeEntry.java | 41 +- .../processors/cache/CacheLazyEntry.java | 9 +- .../processors/cache/GridCacheAdapter.java | 277 +--- .../processors/cache/GridCacheContext.java | 20 +- .../cache/GridCacheEvictionManager.java | 12 +- .../processors/cache/GridCacheLogger.java | 3 +- .../processors/cache/GridCacheMapEntry.java | 13 +- .../GridCachePartitionExchangeManager.java | 22 +- .../processors/cache/GridCacheProxyImpl.java | 48 - .../processors/cache/GridCacheSwapManager.java | 40 +- .../processors/cache/GridCacheUtils.java | 10 + .../processors/cache/IgniteInternalCache.java | 79 -- .../GridDistributedTxRemoteAdapter.java | 3 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 12 +- .../dht/atomic/GridDhtAtomicCache.java | 301 +++-- .../GridDhtPartitionsExchangeFuture.java | 27 +- .../distributed/near/GridNearAtomicCache.java | 37 +- .../distributed/near/GridNearCacheAdapter.java | 30 +- .../near/GridNearTxPrepareFutureAdapter.java | 2 +- .../local/atomic/GridLocalAtomicCache.java | 121 +- .../cache/query/GridCacheQueryManager.java | 5 +- .../jdbc/GridCacheQueryJdbcValidationTask.java | 3 +- .../store/GridCacheStoreManagerAdapter.java | 4 +- .../cache/transactions/IgniteInternalTx.java | 4 +- .../cache/transactions/IgniteTxAdapter.java | 11 +- .../cache/transactions/IgniteTxEntry.java | 4 +- .../transactions/IgniteTxLocalAdapter.java | 67 +- .../cache/transactions/IgniteTxLocalEx.java | 8 +- .../cache/transactions/IgniteTxManager.java | 2 +- .../closure/GridClosureProcessor.java | 26 +- .../datastructures/GridCacheAtomicLongImpl.java | 3 +- .../GridCacheAtomicReferenceImpl.java | 2 +- .../GridCacheAtomicSequenceImpl.java | 3 +- .../GridCacheAtomicStampedImpl.java | 3 +- .../GridCacheCountDownLatchImpl.java | 3 +- .../datastructures/GridCacheQueueProxy.java | 3 +- .../datastructures/GridCacheSemaphoreImpl.java | 3 +- .../datastructures/GridCacheSetProxy.java | 3 +- .../internal/processors/igfs/IgfsImpl.java | 4 +- .../processors/igfs/IgfsMetaManager.java | 315 +++-- .../internal/processors/igfs/IgfsProcessor.java | 10 +- .../processors/job/GridJobProcessor.java | 20 +- .../processors/odbc/OdbcBufferedParser.java | 81 ++ .../processors/odbc/OdbcColumnMeta.java | 110 ++ .../processors/odbc/OdbcHandshakeRequest.java | 49 + .../processors/odbc/OdbcHandshakeResult.java | 66 + .../processors/odbc/OdbcMessageParser.java | 277 ++++ .../processors/odbc/OdbcNioListener.java | 171 +++ .../processors/odbc/OdbcNioServerBuffer.java | 114 ++ .../internal/processors/odbc/OdbcProcessor.java | 116 ++ .../processors/odbc/OdbcQueryCloseRequest.java | 49 + .../processors/odbc/OdbcQueryCloseResult.java | 40 + .../odbc/OdbcQueryExecuteRequest.java | 78 ++ .../processors/odbc/OdbcQueryExecuteResult.java | 54 + .../processors/odbc/OdbcQueryFetchRequest.java | 61 + .../processors/odbc/OdbcQueryFetchResult.java | 66 + .../odbc/OdbcQueryGetColumnsMetaRequest.java | 74 + .../odbc/OdbcQueryGetColumnsMetaResult.java | 42 + .../odbc/OdbcQueryGetTablesMetaRequest.java | 85 ++ .../odbc/OdbcQueryGetTablesMetaResult.java | 42 + .../internal/processors/odbc/OdbcRequest.java | 58 + .../processors/odbc/OdbcRequestHandler.java | 362 +++++ .../internal/processors/odbc/OdbcResponse.java | 96 ++ .../internal/processors/odbc/OdbcTableMeta.java | 85 ++ .../internal/processors/odbc/OdbcUtils.java | 56 + .../platform/services/PlatformServices.java | 249 +++- .../platform/utils/PlatformUtils.java | 128 ++ .../processors/plugin/CachePluginManager.java | 25 + .../handlers/task/GridTaskCommandHandler.java | 2 +- .../service/GridServiceProcessor.java | 3 +- .../processors/service/GridServiceProxy.java | 326 ++--- .../internal/util/GridExecutionStatistics.java | 106 -- .../ignite/internal/util/GridLeanSet.java | 1 + .../ignite/internal/util/IgniteUtils.java | 14 +- .../shmem/IpcSharedMemoryServerEndpoint.java | 6 +- .../ignite/internal/util/lang/GridFunc.java | 92 +- .../ignite/internal/util/lang/GridTuple.java | 2 - .../ignite/internal/util/lang/GridTuple3.java | 2 - .../ignite/internal/util/lang/GridTuple4.java | 2 - .../ignite/internal/util/lang/GridTuple5.java | 2 - .../ignite/internal/util/lang/GridTuple6.java | 2 - .../ignite/internal/util/lang/GridTupleV.java | 1 + .../ignite/internal/util/nio/GridNioServer.java | 3 +- .../ignite/internal/visor/cache/VisorCache.java | 9 + .../internal/visor/cache/VisorCacheMetrics.java | 9 + .../internal/visor/cache/VisorCacheV3.java | 108 ++ .../visor/igfs/VisorIgfsProfilerTask.java | 20 +- .../visor/node/VisorNodeDataCollectorJob.java | 31 +- .../ignite/plugin/CachePluginProvider.java | 11 + .../jobstealing/JobStealingCollisionSpi.java | 14 +- .../communication/tcp/TcpCommunicationSpi.java | 18 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 19 +- .../resources/META-INF/classnames.properties | 102 +- .../CacheNamesWithSpecialCharactersTest.java | 71 + ...cingDelayedPartitionMapExchangeSelfTest.java | 14 +- .../GridCacheRebalancingSyncSelfTest.java | 186 ++- .../processors/igfs/IgfsAbstractSelfTest.java | 14 +- .../ignite/jvmtest/ConcurrentMapTest.java | 3 +- .../platform/PlatformDeployServiceTask.java | 360 +++++ .../ignite/testframework/GridTestUtils.java | 5 +- .../junits/common/GridCommonAbstractTest.java | 53 +- .../IgniteCacheDataStructuresSelfTestSuite.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite.java | 2 + ...CacheDeploymentCachePluginConfiguration.java | 7 + modules/flink/README.txt | 33 + modules/flink/licenses/apache-2.0.txt | 202 +++ modules/flink/pom.xml | 167 +++ .../apache/ignite/sink/flink/IgniteSink.java | 204 +++ .../apache/ignite/sink/flink/package-info.java | 22 + .../sink/flink/FlinkIgniteSinkSelfTest.java | 188 +++ .../flink/FlinkIgniteSinkSelfTestSuite.java | 38 + .../flink/src/test/resources/example-ignite.xml | 70 + .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 10 +- .../query/h2/sql/GridSqlQuerySplitter.java | 6 +- .../processors/query/h2/sql/GridSqlSelect.java | 2 +- modules/kafka/README.txt | 85 +- .../kafka/connect/IgniteSourceConnector.java | 81 ++ .../kafka/connect/IgniteSourceConstants.java | 44 + .../stream/kafka/connect/IgniteSourceTask.java | 335 +++++ .../serialization/CacheEventConverter.java | 66 + .../serialization/CacheEventDeserializer.java | 54 + .../serialization/CacheEventSerializer.java | 54 + .../kafka/IgniteKafkaStreamerSelfTestSuite.java | 4 +- .../kafka/KafkaIgniteStreamerSelfTest.java | 11 +- .../ignite/stream/kafka/TestKafkaBroker.java | 27 +- .../kafka/connect/IgniteSinkConnectorTest.java | 13 +- .../connect/IgniteSourceConnectorMock.java | 31 + .../connect/IgniteSourceConnectorTest.java | 327 +++++ .../kafka/connect/IgniteSourceTaskMock.java | 31 + .../kafka/connect/TestCacheEventFilter.java | 31 + .../kafka/src/test/resources/example-ignite.xml | 4 +- modules/platforms/cpp/common/src/java.cpp | 2 +- modules/platforms/cpp/core-test/Makefile.am | 1 + .../cpp/core-test/project/vs/core-test.vcxproj | 1 + .../project/vs/core-test.vcxproj.filters | 3 + .../cpp/core-test/src/ignite_error_test.cpp | 45 + .../cpp/core/include/ignite/ignite_error.h | 15 +- modules/platforms/cpp/core/src/ignite_error.cpp | 7 +- .../Apache.Ignite.Benchmarks.csproj | 36 +- .../Apache.Ignite.Core.Tests.NuGet.csproj | 25 +- .../Apache.Ignite.Core.Tests.NuGet/CacheTest.cs | 37 +- .../Apache.Ignite.Core.Tests.NuGet/NuGet.config | 5 +- .../install-package.cmd | 10 - .../install-package.ps1 | 25 + .../packages.config | 24 + .../Apache.Ignite.Core.Tests.TestDll.csproj | 32 +- .../Apache.Ignite.Core.Tests.csproj | 50 +- .../Cache/Query/CacheLinqTest.cs | 1278 ++++++++++++++++++ .../Examples/ProjectFilesTest.cs | 2 +- .../ProjectFilesTest.cs | 8 +- .../Services/ServiceProxyTest.cs | 6 +- .../Services/ServicesTest.cs | 249 +++- .../Apache.Ignite.Core.Tests/TestRunner.cs | 2 +- .../Apache.Ignite.Core.csproj | 37 +- .../Apache.Ignite.Core.nuspec | 11 +- .../Cache/Configuration/QueryEntity.cs | 4 +- .../Cache/Configuration/QueryField.cs | 2 +- .../dotnet/Apache.Ignite.Core/Ignition.cs | 2 +- .../Impl/Binary/BinaryReflectiveActions.cs | 37 + .../Impl/Binary/BinarySystemHandlers.cs | 21 +- .../Apache.Ignite.Core/Impl/Binary/JavaTypes.cs | 29 +- .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs | 2 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 37 +- .../Impl/Cache/ICacheInternal.cs | 40 + .../Impl/Cache/Query/FieldsQueryCursor.cs | 26 +- .../Impl/Common/DelegateConverter.cs | 127 +- .../Apache.Ignite.Core/Impl/Common/Logger.cs | 37 + .../Apache.Ignite.Core/Impl/Common/Platform.cs | 35 + .../Impl/Common/TypeCaster.cs | 12 + .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 2 +- .../Apache.Ignite.Core/Impl/IgniteManager.cs | 2 +- .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 11 +- .../Impl/Services/ServiceDescriptor.cs | 7 +- .../Impl/Services/ServiceProxyInvoker.cs | 29 +- .../Impl/Services/ServiceProxySerializer.cs | 63 +- .../Impl/Services/Services.cs | 13 +- .../Impl/Unmanaged/UnmanagedUtils.cs | 6 +- .../NuGet/LINQPad/ComputeExample.linq | 6 +- .../NuGet/LINQPad/PutGetExample.linq | 6 +- .../NuGet/LINQPad/QueryExample.linq | 6 +- .../dotnet/Apache.Ignite.Core/build-common.ps1 | 64 + .../powershell.exe.activation_config | 29 + modules/platforms/dotnet/Apache.Ignite.FxCop | 4 +- .../Apache.Ignite.Linq.csproj | 93 ++ .../Apache.Ignite.Linq.nuspec | 63 + .../Apache.Ignite.Linq/Apache.Ignite.Linq.snk | Bin 0 -> 596 bytes .../Apache.Ignite.Linq/CacheExtensions.cs | 98 ++ .../dotnet/Apache.Ignite.Linq/CompiledQuery.cs | 206 +++ .../Apache.Ignite.Linq/ICacheQueryable.cs | 53 + .../Apache.Ignite.Linq/Impl/AliasDictionary.cs | 102 ++ .../Impl/CacheFieldsQueryExecutor.cs | 225 +++ .../Impl/CacheFieldsQueryProvider.cs | 239 ++++ .../Impl/CacheFieldsQueryable.cs | 40 + .../Impl/CacheQueryExpressionVisitor.cs | 506 +++++++ .../Impl/CacheQueryModelVisitor.cs | 509 +++++++ .../Apache.Ignite.Linq/Impl/CacheQueryParser.cs | 56 + .../Apache.Ignite.Linq/Impl/CacheQueryable.cs | 43 + .../Impl/CacheQueryableBase.cs | 122 ++ .../Apache.Ignite.Linq/Impl/ExpressionWalker.cs | 172 +++ .../Apache.Ignite.Linq/Impl/ICacheQueryProxy.cs | 40 + .../Impl/ICacheQueryableInternal.cs | 54 + .../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 250 ++++ .../dotnet/Apache.Ignite.Linq/Impl/QueryData.cs | 92 ++ .../dotnet/Apache.Ignite.Linq/Impl/SqlTypes.cs | 63 + .../NuGet/LINQPad/QueryExample.linq | 111 ++ .../Properties/AssemblyInfo.cs | 40 + .../dotnet/Apache.Ignite.Linq/packages.config | 22 + modules/platforms/dotnet/Apache.Ignite.sln | 158 ++- .../dotnet/Apache.Ignite/Apache.Ignite.csproj | 33 +- modules/platforms/dotnet/DEVNOTES.txt | 7 +- modules/platforms/dotnet/build.bat | 94 -- .../dotnet/examples/Apache.Ignite.Examples.sln | 24 +- .../Apache.Ignite.Examples.csproj | 49 +- .../Datagrid/LinqExample.cs | 253 ++++ .../Apache.Ignite.ExamplesDll.csproj | 42 +- .../ignite/schema/generator/CodeGenerator.java | 96 +- parent/pom.xml | 4 + pom.xml | 1 + 227 files changed, 13131 insertions(+), 1815 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/configuration/IgniteConfiguration.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/09b56444/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ----------------------------------------------------------------------
