ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject [50/50] [abbrv] ignite git commit: Merge branch 'master' into ignite-2630
Date Wed, 06 Apr 2016 07:55:55 GMT
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 <tikhonovnicolay@gmail.com>
Authored: Wed Apr 6 10:53:34 2016 +0300
Committer: Tikhonov Nikolay <tikhonovnicolay@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
----------------------------------------------------------------------


Mime
View raw message