Merge branch 'master' into ignite-1786
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ac8137fd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ac8137fd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ac8137fd Branch: refs/heads/ignite-1786 Commit: ac8137fd27bb4b0fe0f384377382ff956779828b Parents: e190490 b912754 Author: vozerov-gridgain <[email protected]> Authored: Mon Apr 11 17:24:41 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Mon Apr 11 17:24:41 2016 +0300 ---------------------------------------------------------------------- .../ClientAbstractMultiNodeSelfTest.java | 8 +- .../ignite/cache/CacheInterceptorEntry.java | 39 + .../ignite/cache/affinity/AffinityFunction.java | 2 + .../cache/query/CacheQueryEntryEvent.java | 12 +- .../store/jdbc/CacheAbstractJdbcStore.java | 4 + .../configuration/IgniteConfiguration.java | 50 + .../apache/ignite/internal/GridLoggerProxy.java | 3 +- .../apache/ignite/internal/IgniteKernal.java | 33 +- .../ignite/internal/IgniteNodeAttributes.java | 3 + .../ignite/internal/MarshallerContextImpl.java | 7 +- .../internal/binary/BinaryObjectImpl.java | 52 +- .../binary/BinaryObjectOffheapImpl.java | 40 +- .../internal/binary/BinaryReaderExImpl.java | 62 +- .../ignite/internal/binary/BinaryTypeImpl.java | 8 + .../ignite/internal/binary/BinaryUtils.java | 4 +- .../internal/binary/GridBinaryMarshaller.java | 4 +- .../binary/builder/BinaryBuilderReader.java | 11 +- .../communication/GridIoMessageFactory.java | 4 +- .../deployment/GridDeploymentCommunication.java | 3 +- .../discovery/GridDiscoveryManager.java | 72 +- .../affinity/GridAffinityAssignment.java | 64 +- .../affinity/GridAffinityAssignmentCache.java | 312 +- .../affinity/GridAffinityProcessor.java | 2 +- .../processors/affinity/GridAffinityUtils.java | 3 +- .../cache/CacheAffinityChangeMessage.java | 160 ++ .../cache/CacheAffinitySharedManager.java | 1795 ++++++++++++ .../cache/CacheEvictableEntryImpl.java | 2 +- .../processors/cache/CacheLazyEntry.java | 47 +- .../cache/DynamicCacheChangeRequest.java | 17 + .../cache/DynamicCacheDescriptor.java | 49 + .../processors/cache/GridCacheAdapter.java | 529 ++-- .../cache/GridCacheAffinityManager.java | 136 +- .../cache/GridCacheClearAllRunnable.java | 1 - .../processors/cache/GridCacheContext.java | 22 +- .../cache/GridCacheEvictionManager.java | 30 +- .../processors/cache/GridCacheIoManager.java | 29 +- .../processors/cache/GridCacheLogger.java | 3 +- .../processors/cache/GridCacheMapEntry.java | 31 +- .../cache/GridCacheMvccCandidate.java | 16 +- .../GridCachePartitionExchangeManager.java | 181 +- .../processors/cache/GridCachePreloader.java | 18 +- .../cache/GridCachePreloaderAdapter.java | 12 +- .../processors/cache/GridCacheProcessor.java | 216 +- .../processors/cache/GridCacheProxyImpl.java | 65 +- .../cache/GridCacheSharedContext.java | 18 +- .../processors/cache/GridCacheSwapManager.java | 14 +- .../processors/cache/GridCacheUtils.java | 132 +- .../processors/cache/IgniteInternalCache.java | 88 +- .../cache/affinity/GridCacheAffinityImpl.java | 2 +- .../CacheDataStructuresManager.java | 4 +- .../distributed/GridCacheCommittedTxInfo.java | 1 + .../GridDistributedCacheAdapter.java | 2 +- .../GridDistributedLockResponse.java | 8 - .../GridDistributedTxFinishRequest.java | 2 + .../GridDistributedTxRemoteAdapter.java | 12 +- .../dht/CacheDistributedGetFutureAdapter.java | 3 - .../dht/GridClientPartitionTopology.java | 10 +- .../dht/GridDhtAffinityAssignmentResponse.java | 198 +- .../dht/GridDhtAssignmentFetchFuture.java | 80 +- .../distributed/dht/GridDhtCacheAdapter.java | 56 +- .../cache/distributed/dht/GridDhtGetFuture.java | 2 + .../distributed/dht/GridDhtGetSingleFuture.java | 2 + .../distributed/dht/GridDhtLockFuture.java | 7 - .../dht/GridDhtPartitionTopology.java | 10 +- .../dht/GridDhtPartitionTopologyImpl.java | 328 ++- .../dht/GridDhtTransactionalCacheAdapter.java | 5 +- .../distributed/dht/GridDhtTxFinishFuture.java | 29 +- .../cache/distributed/dht/GridDhtTxLocal.java | 210 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 4 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 16 +- .../cache/distributed/dht/GridDhtTxRemote.java | 9 +- .../dht/GridPartitionedGetFuture.java | 8 +- .../dht/GridPartitionedSingleGetFuture.java | 8 +- .../dht/atomic/GridDhtAtomicCache.java | 300 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 2 +- .../dht/colocated/GridDhtColocatedCache.java | 6 +- .../colocated/GridDhtColocatedLockFuture.java | 17 +- .../dht/preloader/GridDhtPartitionDemander.java | 19 +- .../dht/preloader/GridDhtPartitionMap2.java | 4 +- .../dht/preloader/GridDhtPartitionSupplier.java | 29 +- .../GridDhtPartitionsExchangeFuture.java | 1528 +++++----- .../dht/preloader/GridDhtPreloader.java | 103 +- .../distributed/near/GridNearAtomicCache.java | 41 +- .../distributed/near/GridNearCacheAdapter.java | 32 +- .../distributed/near/GridNearCacheEntry.java | 118 +- .../distributed/near/GridNearGetFuture.java | 26 +- .../distributed/near/GridNearLockFuture.java | 10 +- ...arOptimisticSerializableTxPrepareFuture.java | 5 +- .../near/GridNearOptimisticTxPrepareFuture.java | 34 +- ...ridNearOptimisticTxPrepareFutureAdapter.java | 16 +- .../near/GridNearTransactionalCache.java | 7 +- .../near/GridNearTxFinishFuture.java | 123 +- .../near/GridNearTxFinishRequest.java | 46 +- .../cache/distributed/near/GridNearTxLocal.java | 50 +- .../near/GridNearTxPrepareFutureAdapter.java | 4 +- .../distributed/near/GridNearTxRemote.java | 24 +- .../processors/cache/dr/GridCacheDrManager.java | 4 +- .../cache/dr/GridOsCacheDrManager.java | 2 +- .../cache/local/GridLocalCacheEntry.java | 27 - .../cache/local/GridLocalLockFuture.java | 15 - .../local/atomic/GridLocalAtomicCache.java | 117 +- .../cache/query/GridCacheQueryManager.java | 20 +- .../continuous/CacheContinuousQueryHandler.java | 90 +- .../jdbc/GridCacheQueryJdbcValidationTask.java | 3 +- .../store/GridCacheStoreManagerAdapter.java | 4 +- .../cache/transactions/IgniteInternalTx.java | 34 +- .../cache/transactions/IgniteTxAdapter.java | 85 +- .../cache/transactions/IgniteTxEntry.java | 8 +- .../cache/transactions/IgniteTxHandler.java | 33 +- .../IgniteTxImplicitSingleStateImpl.java | 7 +- .../transactions/IgniteTxLocalAdapter.java | 161 +- .../cache/transactions/IgniteTxLocalEx.java | 21 +- .../cache/transactions/IgniteTxManager.java | 95 +- .../IgniteTxRemoteStateAdapter.java | 7 +- .../cache/transactions/IgniteTxState.java | 5 +- .../cache/transactions/IgniteTxStateImpl.java | 28 +- .../cache/version/GridCacheVersion.java | 14 +- .../cache/version/GridCacheVersionEx.java | 9 + .../cache/version/GridCacheVersionManager.java | 21 +- .../closure/GridClosureProcessor.java | 26 +- .../continuous/GridContinuousProcessor.java | 14 +- .../datastructures/DataStructuresProcessor.java | 4 +- .../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/OdbcMessageParser.java | 2 +- .../platform/PlatformContextImpl.java | 1 + .../platform/services/PlatformServices.java | 249 +- .../utils/PlatformConfigurationUtils.java | 78 + .../platform/utils/PlatformUtils.java | 128 + .../handlers/task/GridTaskCommandHandler.java | 2 +- .../service/GridServiceProcessor.java | 67 +- .../processors/service/GridServiceProxy.java | 326 +-- .../internal/util/GridExecutionStatistics.java | 106 - .../ignite/internal/util/GridLeanSet.java | 1 + .../ignite/internal/util/IgniteUtils.java | 30 +- .../internal/util/future/GridFutureAdapter.java | 3 +- .../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 +- .../internal/visor/cache/VisorCacheMetrics.java | 9 - .../visor/igfs/VisorIgfsProfilerTask.java | 20 +- .../apache/ignite/marshaller/Marshaller.java | 6 +- .../jobstealing/JobStealingCollisionSpi.java | 14 +- .../communication/tcp/TcpCommunicationSpi.java | 18 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 2 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 190 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 24 +- .../resources/META-INF/classnames.properties | 102 +- .../GridCacheAffinityBackupsSelfTest.java | 2 +- .../affinity/AffinityClientNodeSelfTest.java | 4 +- .../affinity/AffinityHistoryCleanupTest.java | 414 +++ .../fair/FairAffinityFunctionNodesSelfTest.java | 2 + .../CacheJdbcPojoStoreAbstractSelfTest.java | 28 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 25 +- .../ignite/cache/store/jdbc/model/Person.java | 25 + .../ignite/internal/GridAffinitySelfTest.java | 5 +- .../GridTaskFailoverAffinityRunTest.java | 6 +- .../IgniteClientReconnectAbstractTest.java | 15 +- .../IgniteClientReconnectAtomicsTest.java | 8 +- .../IgniteClientReconnectCollectionsTest.java | 4 +- .../IgniteClientReconnectComputeTest.java | 6 +- .../IgniteClientReconnectFailoverTest.java | 2 + .../IgniteClientReconnectServicesTest.java | 4 +- .../IgniteClientReconnectStreamerTest.java | 2 +- .../internal/TestRecordingCommunicationSpi.java | 65 +- .../BinaryObjectOffHeapUnswapTemporaryTest.java | 362 +++ .../cache/CacheAffinityCallSelfTest.java | 45 +- ...erceptorPartitionCounterLocalSanityTest.java | 687 +++++ ...torPartitionCounterRandomOperationsTest.java | 1054 +++++++ .../processors/cache/CacheNamesSelfTest.java | 16 +- .../CacheNamesWithSpecialCharactersTest.java | 71 + ...cheNearUpdateTopologyChangeAbstractTest.java | 2 + .../cache/CacheReadThroughRestartSelfTest.java | 2 + .../GridCacheAbstractRemoveFailureTest.java | 10 +- .../cache/GridCacheDeploymentSelfTest.java | 2 + .../cache/GridCacheEntryVersionSelfTest.java | 2 +- ...ridCacheStoreManagerDeserializationTest.java | 40 +- ...acheTcpClientDiscoveryMultiThreadedTest.java | 2 +- .../GridCacheVersionTopologyChangeTest.java | 246 ++ .../IgniteCacheEntryProcessorNodeJoinTest.java | 147 +- .../cache/IgniteCacheIncrementTxTest.java | 299 ++ .../IgniteCacheInterceptorSelfTestSuite.java | 2 + .../cache/IgniteCacheNearLockValueSelfTest.java | 2 +- .../IgniteCacheP2pUnmarshallingErrorTest.java | 1 - ...CacheP2pUnmarshallingRebalanceErrorTest.java | 36 +- .../IgniteCacheP2pUnmarshallingTxErrorTest.java | 2 + ...ReadThroughEvictionOffheapTiredSelfTest.java | 30 + .../IgniteCacheReadThroughEvictionSelfTest.java | 359 +++ .../IgniteClientAffinityAssignmentSelfTest.java | 2 +- ...niteDynamicCacheStartStopConcurrentTest.java | 6 +- .../cache/IgniteTxReentryAbstractSelfTest.java | 2 +- .../MarshallerCacheJobRunNodeRestartTest.java | 307 ++ .../GridCacheBinaryObjectsAbstractSelfTest.java | 181 +- ...eAbstractDataStructuresFailoverSelfTest.java | 12 +- .../CacheGetInsideLockChangingTopologyTest.java | 6 + ...eLateAffinityAssignmentFairAffinityTest.java | 32 + ...ffinityAssignmentNodeJoinValidationTest.java | 134 + .../CacheLateAffinityAssignmentTest.java | 2688 ++++++++++++++++++ .../GridCacheAbstractJobExecutionTest.java | 6 +- .../GridCacheTransformEventSelfTest.java | 2 +- ...niteCacheClientNodeChangingTopologyTest.java | 28 +- ...teCacheClientNodePartitionsExchangeTest.java | 85 +- .../IgniteCacheClientReconnectTest.java | 2 + .../distributed/IgniteCacheGetRestartTest.java | 4 + .../IgniteCacheNearRestartRollbackSelfTest.java | 28 +- .../distributed/IgniteCachePrimarySyncTest.java | 45 +- .../IgniteCacheReadFromBackupTest.java | 12 +- .../IgniteCacheSingleGetMessageTest.java | 8 +- .../IgniteTxCachePrimarySyncTest.java | 1114 ++++++++ ...teSynchronizationModesMultithreadedTest.java | 422 +++ .../GridCacheDhtPreloadMessageCountTest.java | 6 +- ...idCachePartitionedPreloadEventsSelfTest.java | 11 + ...ridCachePartitionedUnloadEventsSelfTest.java | 2 + .../dht/GridCacheTxNodeFailureSelfTest.java | 10 +- .../IgniteCachePutRetryAbstractSelfTest.java | 4 +- ...imaryWriteOrderMultiNodeFullApiSelfTest.java | 35 + .../near/GridCacheNearJobExecutionSelfTest.java | 2 - .../near/GridCacheNearMultiNodeSelfTest.java | 4 +- .../near/GridCacheNearReadersSelfTest.java | 2 + .../near/GridCacheNearTxForceKeyTest.java | 6 +- ...LateAffDisabledMultiNodeFullApiSelfTest.java | 34 + ...achePartitionedMultiNodeCounterSelfTest.java | 43 +- ...achePartitionedMultiNodeFullApiSelfTest.java | 2 + ...idCacheRendezvousAffinityClientSelfTest.java | 2 + .../GridCacheRebalancingSyncSelfTest.java | 83 +- .../GridCacheReplicatedJobExecutionTest.java | 2 - ...acheContinuousQueryExecuteInPrimaryTest.java | 306 ++ ...ContinuousQueryFailoverAbstractSelfTest.java | 36 +- ...BehindStorePartitionedMultiNodeSelfTest.java | 11 +- .../processors/igfs/IgfsAbstractSelfTest.java | 14 +- .../ignite/jvmtest/ConcurrentMapTest.java | 3 +- .../loadtests/hashmap/GridCacheTestContext.java | 2 + .../platform/PlatformDeployServiceTask.java | 360 +++ .../tcp/TcpClientDiscoverySpiSelfTest.java | 8 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 39 +- .../TcpDiscoverySpiFailureTimeoutSelfTest.java | 23 +- .../spi/discovery/tcp/TestTcpDiscoverySpi.java | 5 +- .../ignite/testframework/GridTestUtils.java | 5 +- .../testframework/junits/GridAbstractTest.java | 3 +- .../junits/common/GridCommonAbstractTest.java | 116 +- .../IgniteBinaryObjectsTestSuite.java | 8 +- .../IgniteCacheDataStructuresSelfTestSuite.java | 2 + .../IgniteCacheFullApiSelfTestSuite.java | 6 + .../ignite/testsuites/IgniteCacheTestSuite.java | 4 + .../testsuites/IgniteCacheTestSuite2.java | 4 + .../testsuites/IgniteCacheTestSuite3.java | 2 + .../testsuites/IgniteCacheTestSuite4.java | 9 + .../testsuites/IgniteCacheTestSuite5.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 +- .../processors/hadoop/HadoopContext.java | 3 +- .../hadoop/jobtracker/HadoopJobTracker.java | 8 +- .../child/HadoopChildProcessRunner.java | 2 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 2 + .../IgniteHadoopFileSystemAbstractSelfTest.java | 2 + .../testsuites/IgniteHadoopTestSuite.java | 4 +- .../query/h2/sql/GridSqlQuerySplitter.java | 6 +- .../processors/query/h2/sql/GridSqlSelect.java | 2 +- .../h2/twostep/GridReduceQueryExecutor.java | 4 +- .../cache/IgniteClientReconnectQueriesTest.java | 4 +- .../IgniteCacheQueryNodeRestartSelfTest2.java | 3 + .../IgniteCacheQuerySelfTestSuite3.java | 2 + modules/kafka/README.txt | 10 +- .../stream/kafka/connect/IgniteSourceTask.java | 15 +- modules/platforms/cpp/common/src/java.cpp | 2 +- .../Apache.Ignite.Benchmarks.csproj | 36 +- .../Apache.Ignite.Core.Tests.NuGet.csproj | 43 +- .../Apache.Ignite.Core.Tests.NuGet.sln | 6 + .../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 | 109 +- .../Binary/BinaryBuilderSelfTest.cs | 8 +- .../Cache/Query/CacheLinqTest.cs | 1272 +++++++++ .../Continuous/ContinuousQueryAbstractTest.cs | 25 +- .../Config/Apache.Ignite.exe.config.test2 | 2 +- .../Config/Cache/Store/cache-store-session.xml | 3 +- .../Config/Compute/compute-grid1.xml | 3 +- .../Config/Compute/compute-grid2.xml | 3 +- .../Config/Compute/compute-grid3.xml | 5 +- .../Config/Compute/compute-standalone.xml | 4 +- .../Config/Dynamic/dynamic-client.xml | 3 +- .../Config/Dynamic/dynamic-data-no-cfg.xml | 3 +- .../Config/Dynamic/dynamic-data.xml | 3 +- .../Config/Lifecycle/lifecycle-beans.xml | 3 +- .../Config/Lifecycle/lifecycle-no-beans.xml | 3 +- .../Config/cache-binarizables.xml | 3 +- .../Config/cache-local-node.xml | 3 +- .../Config/cache-query-continuous.xml | 3 +- .../Config/cache-query.xml | 3 +- .../Config/ignite-dotnet-cfg.xml | 2 +- .../Config/marshaller-default.xml | 3 +- .../Config/marshaller-explicit.xml | 3 +- .../Config/marshaller-invalid.xml | 3 +- .../native-client-test-cache-affinity.xml | 3 +- .../native-client-test-cache-parallel-store.xml | 3 +- .../Config/native-client-test-cache-store.xml | 3 +- .../Config/native-client-test-cache.xml | 3 +- .../Config/reconnect-test.xml | 43 + .../Config/start-test-grid1.xml | 3 +- .../Config/start-test-grid2.xml | 3 +- .../Config/start-test-grid3.xml | 3 +- .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 5 + .../IgniteConfigurationSerializerTest.cs | 48 +- .../IgniteConfigurationTest.cs | 36 +- .../ProjectFilesTest.cs | 8 +- .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 5 +- .../Services/ServiceProxyTest.cs | 6 +- .../Services/ServicesTest.cs | 249 +- .../Apache.Ignite.Core.Tests/TestRunner.cs | 2 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 5 +- .../dotnet/Apache.Ignite.Core.Tests/app.config | 4 +- .../Apache.Ignite.Core.csproj | 44 +- .../Apache.Ignite.Core.nuspec | 11 +- .../Cache/Configuration/QueryEntity.cs | 4 +- .../Cache/Configuration/QueryField.cs | 2 +- .../Configuration/AtomicConfiguration.cs | 58 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 114 +- .../IgniteConfigurationSection.xsd | 24 + .../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/Cluster/ClusterNodeImpl.cs | 2 +- .../Impl/Common/DelegateConverter.cs | 127 +- .../Common/IgniteConfigurationXmlSerializer.cs | 67 +- .../Apache.Ignite.Core/Impl/Common/Logger.cs | 37 + .../Impl/Common/ObjectStringConverter.cs | 104 + .../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 | 8 +- .../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 +- .../Transactions/ITransaction.cs | 3 +- .../Transactions/TransactionConfiguration.cs | 76 + .../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 | 208 ++ .../Apache.Ignite.Linq/ICacheQueryable.cs | 53 + .../Apache.Ignite.Linq/Impl/AliasDictionary.cs | 102 + .../Impl/CacheFieldsQueryExecutor.cs | 223 ++ .../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 +- .../Compute/ClosureExample.cs | 8 +- .../Compute/TaskExample.cs | 11 +- .../Datagrid/ContinuousQueryExample.cs | 8 +- .../Datagrid/DataStreamerExample.cs | 12 +- .../Datagrid/LinqExample.cs | 247 ++ .../Datagrid/PutGetExample.cs | 11 +- .../Datagrid/QueryExample.cs | 13 +- .../Datagrid/StoreExample.cs | 13 +- .../Datagrid/TransactionExample.cs | 14 +- .../Events/EventsExample.cs | 12 +- .../Messaging/MessagingExample.cs | 9 +- .../Misc/LifecycleExample.cs | 1 - .../Services/ServicesExample.cs | 9 +- .../Apache.Ignite.ExamplesDll.csproj | 42 +- .../dotnet/examples/Config/examples-config.xml | 2 +- .../ignite/schema/generator/CodeGenerator.java | 96 +- .../commands/cache/VisorCacheCommand.scala | 12 +- parent/pom.xml | 4 + pom.xml | 1 + 425 files changed, 24530 insertions(+), 4924 deletions(-) ----------------------------------------------------------------------
