You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2016/04/06 09:55:55 UTC
[50/50] [abbrv] ignite git commit: Merge branch 'master' into
ignite-2630
Merge branch 'master' into ignite-2630
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3bf13dd0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3bf13dd0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3bf13dd0
Branch: refs/heads/ignite-2630
Commit: 3bf13dd064cb2f9405f25ba0bb8578bc2d375fc5
Parents: 2586dbb fcfbf2c
Author: Tikhonov Nikolay <ti...@gmail.com>
Authored: Wed Apr 6 10:53:34 2016 +0300
Committer: Tikhonov Nikolay <ti...@gmail.com>
Committed: Wed Apr 6 10:53:34 2016 +0300
----------------------------------------------------------------------
.../ClientAbstractMultiNodeSelfTest.java | 8 +-
.../ignite/cache/affinity/AffinityFunction.java | 2 +
.../configuration/IgniteConfiguration.java | 75 +
.../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 | 35 +-
.../ignite/internal/IgniteNodeAttributes.java | 3 +
.../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 | 49 +-
.../affinity/GridAffinityAssignmentCache.java | 246 +-
.../affinity/GridAffinityProcessor.java | 2 +-
.../processors/affinity/GridAffinityUtils.java | 3 +-
.../cache/CacheAffinityChangeMessage.java | 160 ++
.../cache/CacheAffinitySharedManager.java | 1805 ++++++++++++
.../cache/CacheEvictableEntryImpl.java | 2 +-
.../processors/cache/CacheInvokeEntry.java | 41 +-
.../processors/cache/CacheLazyEntry.java | 9 +-
.../cache/DynamicCacheChangeRequest.java | 17 +
.../cache/DynamicCacheDescriptor.java | 49 +
.../processors/cache/GridCacheAdapter.java | 527 ++--
.../cache/GridCacheAffinityManager.java | 125 +-
.../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 | 14 +-
.../cache/GridCacheMvccCandidate.java | 16 +-
.../GridCachePartitionExchangeManager.java | 183 +-
.../processors/cache/GridCachePreloader.java | 18 +-
.../cache/GridCachePreloaderAdapter.java | 12 +-
.../processors/cache/GridCacheProcessor.java | 216 +-
.../processors/cache/GridCacheProxyImpl.java | 61 +-
.../cache/GridCacheSharedContext.java | 18 +-
.../processors/cache/GridCacheSwapManager.java | 40 +-
.../processors/cache/GridCacheUtils.java | 132 +-
.../processors/cache/IgniteInternalCache.java | 84 +-
.../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 | 28 +-
.../cache/distributed/dht/GridDhtTxRemote.java | 9 +-
.../dht/GridPartitionedGetFuture.java | 8 +-
.../dht/GridPartitionedSingleGetFuture.java | 8 +-
.../dht/atomic/GridDhtAtomicCache.java | 302 +-
.../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 | 1526 +++++-----
.../dht/preloader/GridDhtPreloader.java | 103 +-
.../distributed/near/GridNearAtomicCache.java | 37 +-
.../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 | 121 +-
.../cache/query/GridCacheQueryManager.java | 20 +-
.../continuous/CacheContinuousQueryHandler.java | 3 +-
.../jdbc/GridCacheQueryJdbcValidationTask.java | 3 +-
.../store/GridCacheStoreManagerAdapter.java | 4 +-
.../cache/transactions/IgniteInternalTx.java | 34 +-
.../cache/transactions/IgniteTxAdapter.java | 93 +-
.../cache/transactions/IgniteTxEntry.java | 12 +-
.../cache/transactions/IgniteTxHandler.java | 33 +-
.../IgniteTxImplicitSingleStateImpl.java | 7 +-
.../transactions/IgniteTxLocalAdapter.java | 164 +-
.../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 | 1 -
.../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/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/PlatformContextImpl.java | 1 +
.../platform/services/PlatformServices.java | 249 +-
.../platform/utils/PlatformUtils.java | 128 +
.../processors/plugin/CachePluginManager.java | 25 +
.../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 +-
.../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 +-
.../apache/ignite/marshaller/Marshaller.java | 6 +-
.../ignite/plugin/CachePluginProvider.java | 11 +
.../jobstealing/JobStealingCollisionSpi.java | 14 +-
.../communication/tcp/TcpCommunicationSpi.java | 18 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 146 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 1 +
.../resources/META-INF/classnames.properties | 102 +-
.../GridCacheAffinityBackupsSelfTest.java | 2 +-
.../affinity/AffinityClientNodeSelfTest.java | 4 +-
.../fair/FairAffinityFunctionNodesSelfTest.java | 2 +
.../ignite/internal/GridAffinitySelfTest.java | 5 +-
.../GridTaskFailoverAffinityRunTest.java | 6 +-
.../IgniteClientReconnectAbstractTest.java | 8 +-
.../IgniteClientReconnectAtomicsTest.java | 8 +-
.../IgniteClientReconnectCollectionsTest.java | 4 +-
.../IgniteClientReconnectComputeTest.java | 6 +-
.../IgniteClientReconnectFailoverTest.java | 2 +
.../IgniteClientReconnectServicesTest.java | 4 +-
.../IgniteClientReconnectStreamerTest.java | 2 +-
.../internal/TestRecordingCommunicationSpi.java | 65 +-
.../cache/CacheAffinityCallSelfTest.java | 45 +-
.../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 ++
.../cache/IgniteCacheNearLockValueSelfTest.java | 2 +-
.../IgniteCacheP2pUnmarshallingErrorTest.java | 1 -
...CacheP2pUnmarshallingRebalanceErrorTest.java | 36 +-
.../IgniteCacheP2pUnmarshallingTxErrorTest.java | 2 +
.../IgniteCacheReadThroughEvictionSelfTest.java | 352 +++
.../IgniteClientAffinityAssignmentSelfTest.java | 2 +-
...niteDynamicCacheStartStopConcurrentTest.java | 6 +-
.../cache/IgniteTxReentryAbstractSelfTest.java | 2 +-
...eAbstractDataStructuresFailoverSelfTest.java | 12 +-
.../CacheGetInsideLockChangingTopologyTest.java | 6 +
...eLateAffinityAssignmentFairAffinityTest.java | 32 +
.../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 +
...cingDelayedPartitionMapExchangeSelfTest.java | 14 +-
.../GridCacheRebalancingSyncSelfTest.java | 245 +-
.../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 +++
.../ignite/testframework/GridTestUtils.java | 5 +-
.../testframework/junits/GridAbstractTest.java | 3 +-
.../junits/common/GridCommonAbstractTest.java | 169 +-
.../IgniteCacheDataStructuresSelfTestSuite.java | 2 +
.../IgniteCacheFullApiSelfTestSuite.java | 6 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 2 +
.../testsuites/IgniteCacheTestSuite2.java | 4 +
.../testsuites/IgniteCacheTestSuite3.java | 2 +
.../testsuites/IgniteCacheTestSuite4.java | 6 +
.../testsuites/IgniteCacheTestSuite5.java | 5 +
...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 +-
.../processors/hadoop/HadoopContext.java | 3 +-
.../child/HadoopChildProcessRunner.java | 2 +-
.../HadoopIgfs20FileSystemAbstractSelfTest.java | 2 +
.../IgniteHadoopFileSystemAbstractSelfTest.java | 2 +
.../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 | 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 +++++++++
.../Continuous/ContinuousQueryAbstractTest.cs | 25 +-
.../Examples/ProjectFilesTest.cs | 2 +-
.../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 5 +
.../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 +
398 files changed, 24564 insertions(+), 4533 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/3bf13dd0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java
index b7db62d,c1fcb77..c641322
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheLazyEntry.java
@@@ -164,21 -136,14 +164,28 @@@ public class CacheLazyEntry<K, V> exten
return key;
}
+ /**
+ * @return Keep binary flag.
+ */
+ public boolean keepBinary() {
+ return keepBinary;
+ }
+
/** {@inheritDoc} */
+ @Override public long getPartitionUpdateCounter() {
+ return updateCntr == null ? 0L : updateCntr;
+ }
+
+ /**
+ * Sets update counter.
+ *
+ * @param updateCntr Update counter.
+ */
+ public void updateCounter(Long updateCntr) {
+ this.updateCntr = updateCntr;
+ }
+
+ /** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Override public <T> T unwrap(Class<T> cls) {
if (cls.isAssignableFrom(Ignite.class))
http://git-wip-us.apache.org/repos/asf/ignite/blob/3bf13dd0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java
----------------------------------------------------------------------