ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [50/50] [abbrv] ignite git commit: Merge remote-tracking branch 'remotes/origin/master' into ignite-2407
Date Sun, 03 Apr 2016 19:43:14 GMT
Merge remote-tracking branch 'remotes/origin/master' into ignite-2407


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fc6f56b2
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fc6f56b2
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fc6f56b2

Branch: refs/heads/ignite-2407
Commit: fc6f56b283d2880dd19e3c96ef50db25804f8948
Parents: d842fcf 10603bf
Author: sboikov <sboikov@gridgain.com>
Authored: Sun Apr 3 22:40:32 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Sun Apr 3 22:40:32 2016 +0300

----------------------------------------------------------------------
 .../store/CacheLoadOnlyStoreExample.java        |  171 ++
 examples/src/main/resources/person.csv          |   20 +
 .../ignite/examples/CacheExamplesSelfTest.java  |    8 +
 .../rest/RestBinaryProtocolSelfTest.java        |    4 +-
 .../rest/RestMemcacheProtocolSelfTest.java      |    4 +-
 .../java/org/apache/ignite/IgniteCache.java     |   20 +-
 .../cache/store/jdbc/CacheJdbcPojoStore.java    |    2 +-
 .../configuration/FileSystemConfiguration.java  |   96 +-
 .../configuration/IgniteConfiguration.java      |   25 +
 .../ignite/configuration/OdbcConfiguration.java |  319 +++
 .../igfs/IgfsIpcEndpointConfiguration.java      |   28 +
 .../java/org/apache/ignite/igfs/IgfsPath.java   |   32 +-
 .../internal/GridEventConsumeHandler.java       |    3 +-
 .../ignite/internal/GridKernalContext.java      |    8 +
 .../ignite/internal/GridKernalContextImpl.java  |   12 +
 .../apache/ignite/internal/GridLoggerProxy.java |    3 +-
 .../internal/GridMessageListenHandler.java      |    3 +-
 .../apache/ignite/internal/IgniteKernal.java    |   33 +-
 .../org/apache/ignite/internal/IgnitionEx.java  |   10 +-
 .../ignite/internal/binary/BinaryContext.java   |   43 +
 .../ignite/internal/binary/BinaryUtils.java     |   53 +-
 .../binary/builder/BinaryObjectBuilderImpl.java |  107 +-
 .../internal/direct/DirectMessageReader.java    |    2 +-
 .../internal/direct/DirectMessageWriter.java    |    4 +-
 .../direct/state/DirectMessageState.java        |    7 +-
 .../stream/v2/DirectByteBufferStreamImplV2.java |    2 +-
 .../managers/communication/GridIoManager.java   |   64 +-
 .../managers/communication/GridIoPolicy.java    |    3 +
 .../deployment/GridDeploymentCommunication.java |    3 +-
 .../discovery/GridDiscoveryManager.java         |    4 +-
 .../cache/CacheClusterMetricsMXBeanImpl.java    |  410 +++
 .../cache/CacheEvictableEntryImpl.java          |    2 +-
 .../processors/cache/CacheInvokeEntry.java      |   41 +-
 .../processors/cache/CacheLazyEntry.java        |    9 +-
 .../cache/CacheLocalMetricsMXBeanImpl.java      |  410 +++
 .../cache/CacheMetricsMXBeanImpl.java           |  410 ---
 .../processors/cache/GridCacheAdapter.java      |  312 +--
 .../processors/cache/GridCacheContext.java      |   20 +-
 .../cache/GridCacheEvictionManager.java         |   12 +-
 .../processors/cache/GridCacheLogger.java       |    3 +-
 .../processors/cache/GridCacheMapEntry.java     |   15 +-
 .../GridCachePartitionExchangeManager.java      |   27 +-
 .../processors/cache/GridCacheProcessor.java    |   15 +-
 .../processors/cache/GridCacheProxyImpl.java    |   93 +-
 .../processors/cache/GridCacheSwapManager.java  |   40 +-
 .../processors/cache/GridCacheUtils.java        |   24 +-
 .../processors/cache/IgniteCacheProxy.java      |   39 +-
 .../processors/cache/IgniteInternalCache.java   |  110 +-
 .../GridDistributedTxRemoteAdapter.java         |    3 +-
 .../distributed/dht/GridDhtTxPrepareFuture.java |   12 +-
 .../dht/atomic/GridDhtAtomicCache.java          |  318 ++-
 .../dht/atomic/GridDhtAtomicUpdateFuture.java   |    4 +-
 .../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 +-
 .../continuous/CacheContinuousQueryHandler.java |   88 +-
 .../continuous/CacheContinuousQueryManager.java |   23 +-
 .../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 +-
 .../continuous/GridContinuousHandler.java       |    4 +-
 .../continuous/GridContinuousProcessor.java     |   27 +-
 .../StartRoutineAckDiscoveryMessage.java        |   22 +-
 .../StartRoutineDiscoveryMessage.java           |   22 +-
 .../datastreamer/DataStreamProcessor.java       |    8 +-
 .../datastreamer/DataStreamerImpl.java          |   37 +-
 .../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/IgfsBlockKey.java  |   30 +-
 .../IgfsColocatedMetadataAffinityKeyMapper.java |   47 +
 .../processors/igfs/IgfsDataManager.java        |  132 +-
 .../processors/igfs/IgfsDeleteWorker.java       |   37 +-
 .../processors/igfs/IgfsDirectoryInfo.java      |  284 ++
 .../internal/processors/igfs/IgfsEntryInfo.java |  319 +++
 .../ignite/internal/processors/igfs/IgfsEx.java |   12 -
 .../processors/igfs/IgfsFileAffinityRange.java  |   32 +-
 .../internal/processors/igfs/IgfsFileImpl.java  |   15 +-
 .../internal/processors/igfs/IgfsFileInfo.java  |  535 +---
 .../internal/processors/igfs/IgfsFileMap.java   |   41 +-
 .../processors/igfs/IgfsFileWorkerBatch.java    |   75 +-
 .../IgfsFileWorkerBatchCancelledException.java  |   51 +
 .../igfs/IgfsFragmentizerManager.java           |  185 +-
 .../internal/processors/igfs/IgfsImpl.java      |  126 +-
 .../processors/igfs/IgfsInputStreamAdapter.java |    5 +-
 .../processors/igfs/IgfsInputStreamImpl.java    |   34 +-
 .../processors/igfs/IgfsIpcHandler.java         |   97 +-
 .../processors/igfs/IgfsListingEntry.java       |   37 +-
 .../processors/igfs/IgfsMetaManager.java        | 2580 ++++++------------
 .../processors/igfs/IgfsOutputStreamImpl.java   |   38 +-
 .../internal/processors/igfs/IgfsPathIds.java   |  315 +++
 .../processors/igfs/IgfsPathsCreateResult.java  |   64 +
 .../internal/processors/igfs/IgfsProcessor.java |   50 +-
 .../IgfsSecondaryInputStreamDescriptor.java     |    6 +-
 .../IgfsSecondaryOutputStreamDescriptor.java    |   20 +-
 .../internal/processors/igfs/IgfsServer.java    |    2 +-
 .../internal/processors/igfs/IgfsUtils.java     |  448 ++-
 .../meta/IgfsMetaDirectoryCreateProcessor.java  |  172 ++
 .../IgfsMetaDirectoryListingAddProcessor.java   |  136 +
 ...IgfsMetaDirectoryListingRemoveProcessor.java |  134 +
 ...gfsMetaDirectoryListingReplaceProcessor.java |  130 +
 .../igfs/meta/IgfsMetaFileCreateProcessor.java  |  172 ++
 .../igfs/meta/IgfsMetaFileLockProcessor.java    |  107 +
 .../meta/IgfsMetaFileRangeDeleteProcessor.java  |  111 +
 .../meta/IgfsMetaFileRangeUpdateProcessor.java  |  120 +
 .../meta/IgfsMetaFileReserveSpaceProcessor.java |  120 +
 .../igfs/meta/IgfsMetaFileUnlockProcessor.java  |  103 +
 .../meta/IgfsMetaUpdatePropertiesProcessor.java |  121 +
 .../igfs/meta/IgfsMetaUpdateTimesProcessor.java |  113 +
 .../internal/processors/igfs/package-info.java  |    2 +-
 .../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/cache/PlatformCache.java           |   56 +-
 .../datastreamer/PlatformDataStreamer.java      |    7 +-
 .../platform/services/PlatformServices.java     |  249 +-
 .../platform/utils/PlatformFutureUtils.java     |    2 +-
 .../platform/utils/PlatformUtils.java           |  128 +
 .../processors/plugin/CachePluginManager.java   |   25 +
 .../handlers/cache/GridCacheCommandHandler.java |    2 +-
 .../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       |    6 +-
 .../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 +
 .../internal/util/nio/GridDirectParser.java     |    4 +-
 .../util/nio/GridNioRecoveryDescriptor.java     |   21 +-
 .../ignite/internal/util/nio/GridNioServer.java |   60 +-
 .../util/offheap/unsafe/GridUnsafeMap.java      |    4 +-
 .../ignite/internal/visor/cache/VisorCache.java |    9 +
 .../internal/visor/cache/VisorCacheMetrics.java |   20 +-
 .../visor/cache/VisorCacheResetMetricsTask.java |    2 +-
 .../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  |   38 +-
 .../tcp/TcpCommunicationSpiMBean.java           |    8 +-
 .../ignite/spi/discovery/tcp/ServerImpl.java    |   19 +-
 .../ignite/igfs/IgfsEventsAbstractSelfTest.java |   32 +-
 .../igfs/IgfsFragmentizerAbstractSelfTest.java  |    4 +-
 .../BinaryObjectBuilderAdditionalSelfTest.java  |  144 +-
 ...naryObjectBuilderDefaultMappersSelfTest.java |    2 +-
 .../CacheMetricsForClusterGroupSelfTest.java    |    2 +-
 .../cache/CacheSwapUnswapGetTest.java           |    4 +-
 .../cache/GridCacheAbstractMetricsSelfTest.java |  124 +-
 .../GridCacheOffHeapValuesEvictionSelfTest.java |   18 +-
 ...cheTransactionalAbstractMetricsSelfTest.java |    4 +-
 .../cache/IgniteCacheAbstractTest.java          |    6 +
 .../IgniteCacheEntryListenerAbstractTest.java   |   16 +-
 .../distributed/IgniteCacheCreatePutTest.java   |  137 +-
 .../distributed/IgniteCacheManyClientsTest.java |    6 +
 .../dht/GridCacheColocatedDebugTest.java        |    2 +-
 ...ePartitionedNearDisabledMetricsSelfTest.java |    2 +-
 ...AtomicPartitionedTckMetricsSelfTestImpl.java |   92 +-
 .../near/GridCacheNearMetricsSelfTest.java      |  152 +-
 ...idCachePartitionedHitsAndMissesSelfTest.java |    2 +-
 ...cingDelayedPartitionMapExchangeSelfTest.java |   14 +-
 .../GridCacheRebalancingSyncSelfTest.java       |  186 +-
 ...CacheLocalOffHeapAndSwapMetricsSelfTest.java |  380 +--
 ...dCacheAtomicLocalTckMetricsSelfTestImpl.java |   92 +-
 .../CacheContinuousQueryFactoryFilterTest.java  |    6 +-
 ...ContinuousQueryFailoverAbstractSelfTest.java |   13 +-
 .../CacheContinuousQueryLostPartitionTest.java  |    2 -
 ...acheContinuousQueryRandomOperationsTest.java |  530 +++-
 ...inuousQueryRandomOperationsTwoNodesTest.java |   28 +
 .../GridCacheContinuousQueryConcurrentTest.java |  466 ++++
 .../processors/igfs/IgfsAbstractSelfTest.java   |  159 +-
 ...lockMessageSystemPoolStarvationSelfTest.java |  299 ++
 .../igfs/IgfsDataManagerSelfTest.java           |   55 +-
 .../igfs/IgfsDualAbstractSelfTest.java          |   30 +-
 .../processors/igfs/IgfsFileInfoSelfTest.java   |   31 +-
 .../igfs/IgfsMetaManagerSelfTest.java           |   69 +-
 .../igfs/IgfsPrimaryMultiNodeSelfTest.java      |   28 +
 .../IgfsPrimaryOptimziedMarshallerSelfTest.java |   28 +
 ...maryRelaxedConsistencyMultiNodeSelfTest.java |   28 +
 .../IgfsPrimaryRelaxedConsistencySelfTest.java  |   28 +
 .../processors/igfs/IgfsProcessorSelfTest.java  |   74 +-
 .../igfs/IgfsProcessorValidationSelfTest.java   |   16 +
 .../processors/igfs/IgfsSizeSelfTest.java       |   35 +-
 .../processors/igfs/IgfsStartCacheTest.java     |    9 +-
 .../processors/igfs/IgfsStreamsSelfTest.java    |   27 +-
 .../ignite/jvmtest/ConcurrentMapTest.java       |    3 +-
 .../platform/PlatformAttributeNodeFilter.java   |   31 +
 .../platform/PlatformDeployServiceTask.java     |  360 +++
 .../ignite/testframework/GridTestUtils.java     |    5 +-
 .../junits/common/GridCommonAbstractTest.java   |   53 +-
 .../multijvm/IgniteCacheProcessProxy.java       |    8 +
 .../IgniteCacheDataStructuresSelfTestSuite.java |   10 +-
 .../ignite/testsuites/IgniteIgfsTestSuite.java  |   15 +
 ...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 |   46 +-
 .../hadoop/fs/v1/IgniteHadoopFileSystem.java    |   19 +-
 .../hadoop/fs/v2/IgniteHadoopFileSystem.java    |   21 +-
 .../hadoop/igfs/HadoopIgfsProperties.java       |   11 +-
 .../ignite/igfs/Hadoop1DualAbstractTest.java    |    3 +-
 ...oopFileSystemUniversalFileSystemAdapter.java |    8 +-
 .../igfs/HadoopIgfsDualAbstractSelfTest.java    |   11 +-
 .../apache/ignite/igfs/IgfsEventsTestSuite.java |   10 +-
 .../IgniteHadoopFileSystemLoggerSelfTest.java   |   21 +-
 .../processors/hadoop/HadoopMapReduceTest.java  |    5 +-
 .../testsuites/IgniteHadoopTestSuite.java       |   26 +-
 .../query/h2/sql/GridSqlQuerySplitter.java      |    6 +-
 .../processors/query/h2/sql/GridSqlSelect.java  |    2 +-
 .../IgniteBinaryCacheQueryTestSuite2.java       |   39 +
 .../IgniteBinaryCacheQueryTestSuite3.java       |   39 +
 .../IgniteBinaryCacheQueryTestSuite4.java       |   39 +
 .../IgniteCacheQuerySelfTestSuite.java          |  154 --
 .../IgniteCacheQuerySelfTestSuite2.java         |  109 +
 .../IgniteCacheQuerySelfTestSuite3.java         |   97 +
 .../IgniteCacheQuerySelfTestSuite4.java         |   49 +
 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       |   76 +-
 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 +-
 .../impl/binary/binary_type_updater_impl.cpp    |    2 +
 .../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             |   65 +-
 .../Binary/BinaryBuilderSelfTest.cs             |   60 +-
 .../Binary/BinarySelfTest.cs                    |  113 +
 .../Cache/CacheTestAsyncWrapper.cs              |   12 +
 .../Cache/Query/CacheLinqTest.cs                | 1278 +++++++++
 .../Query/CacheQueriesCodeConfigurationTest.cs  |   16 +-
 .../Cache/Store/CacheStoreTest.cs               |   31 +
 .../Cache/Store/CacheTestStore.cs               |    2 +-
 .../Config/Apache.Ignite.exe.config.test2       |   58 +
 .../Config/Apache.Ignite.exe.config.test3       |   34 +
 .../Config/cache-local-node.xml                 |   65 +
 .../Config/ignite-dotnet-cfg.xml                |   52 +
 .../Dataload/DataStreamerTestTopologyChange.cs  |  104 +
 .../Examples/ExamplesTest.cs                    |    3 +-
 .../Examples/ProjectFilesTest.cs                |    2 +-
 .../Apache.Ignite.Core.Tests/ExecutableTest.cs  |   89 +-
 .../IgniteConfigurationSerializerTest.cs        |    3 +-
 .../Apache.Ignite.Core.Tests/JavaHomeTest.cs    |   69 +
 .../ProjectFilesTest.cs                         |    8 +-
 .../Services/ServiceProxyTest.cs                |    6 +-
 .../Services/ServicesTest.cs                    |  249 +-
 .../Apache.Ignite.Core.Tests/TestRunner.cs      |    2 +-
 .../Apache.Ignite.Core.csproj                   |   38 +-
 .../Apache.Ignite.Core.nuspec                   |   11 +-
 .../Cache/Configuration/QueryEntity.cs          |   13 +-
 .../Cache/Configuration/QueryField.cs           |    2 +-
 .../dotnet/Apache.Ignite.Core/Cache/ICache.cs   |   26 +
 .../Apache.Ignite.Core/IgniteConfiguration.cs   |   10 +-
 .../IgniteConfigurationSection.xsd              |    8 +
 .../dotnet/Apache.Ignite.Core/Ignition.cs       |    2 +-
 .../Impl/Binary/BinaryHandleDictionary.cs       |   32 +-
 .../Impl/Binary/BinaryReader.cs                 |   61 +-
 .../Impl/Binary/BinaryReaderHandleDictionary.cs |    2 +-
 .../Impl/Binary/BinaryReflectiveActions.cs      |   37 +
 .../Impl/Binary/BinarySystemHandlers.cs         |  147 +-
 .../Impl/Binary/BinaryUtils.cs                  |   12 +
 .../Impl/Binary/BinaryWriter.cs                 |   24 +-
 .../Apache.Ignite.Core/Impl/Binary/JavaTypes.cs |   29 +-
 .../Impl/Binary/ReferenceEqualityComparer.cs    |   45 +
 .../Apache.Ignite.Core/Impl/Cache/CacheEntry.cs |    2 +-
 .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs  |   54 +-
 .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs    |    3 +-
 .../Impl/Cache/ICacheInternal.cs                |   40 +
 .../Impl/Cache/Query/FieldsQueryCursor.cs       |   26 +-
 .../Impl/Common/DelegateConverter.cs            |  131 +-
 .../Apache.Ignite.Core/Impl/Common/Logger.cs    |   37 +
 .../Apache.Ignite.Core/Impl/Common/Platform.cs  |   35 +
 .../Impl/Common/TypeCaster.cs                   |   12 +
 .../Impl/Datastream/DataStreamerImpl.cs         |    9 +-
 .../Apache.Ignite.Core/Impl/ExceptionUtils.cs   |    2 +-
 .../Apache.Ignite.Core/Impl/IgniteManager.cs    |    2 +-
 .../Apache.Ignite.Core/Impl/IgniteUtils.cs      |   43 +-
 .../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      |  163 +-
 .../dotnet/Apache.Ignite/Apache.Ignite.csproj   |   35 +-
 .../Config/AppSettingsConfigurator.cs           |   97 +-
 .../Apache.Ignite/Config/ArgsConfigurator.cs    |  145 +-
 .../dotnet/Apache.Ignite/Config/Configurator.cs |  168 ++
 .../Apache.Ignite/Config/IConfigurator.cs       |   34 -
 .../dotnet/Apache.Ignite/IgniteRunner.cs        |   24 +-
 .../Apache.Ignite/Service/IgniteService.cs      |   21 +-
 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                   |    6 +-
 .../Compute/TaskExample.cs                      |    6 +-
 .../Datagrid/ContinuousQueryExample.cs          |   11 +-
 .../Datagrid/DataStreamerExample.cs             |    8 +-
 .../Datagrid/LinqExample.cs                     |  253 ++
 .../Datagrid/PutGetExample.cs                   |    8 +-
 .../Datagrid/QueryExample.cs                    |   22 +-
 .../Datagrid/StoreExample.cs                    |   18 +-
 .../Datagrid/TransactionExample.cs              |   16 +-
 .../Events/EventsExample.cs                     |    6 +-
 .../Messaging/MessagingExample.cs               |    6 +-
 .../Misc/LifecycleExample.cs                    |    4 +-
 .../Services/ServicesExample.cs                 |    6 +-
 .../Apache.Ignite.ExamplesDll.csproj            |   43 +-
 .../Apache.Ignite.ExamplesDll/Binary/Account.cs |    1 -
 .../Apache.Ignite.ExamplesDll/Binary/Address.cs |    5 +-
 .../Binary/Employee.cs                          |    4 +
 .../Binary/EmployeeKey.cs                       |    4 +-
 .../Binary/Organization.cs                      |   11 +-
 .../Binary/OrganizationType.cs                  |    3 -
 .../Datagrid/EmployeeStoreFactory.cs            |   38 +
 .../examples/Config/example-cache-query.xml     |  118 -
 .../examples/Config/example-cache-store.xml     |   59 -
 .../dotnet/examples/Config/example-cache.xml    |   87 -
 .../dotnet/examples/Config/example-compute.xml  |   70 -
 .../dotnet/examples/Config/examples-config.xml  |   98 +
 parent/pom.xml                                  |    6 +
 pom.xml                                         |    1 +
 423 files changed, 23591 insertions(+), 6719 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/fc6f56b2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxPrepareFuture.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/fc6f56b2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteInternalTx.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteInternalTx.java
index 458eb13,cdf2354..e08f9b0
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteInternalTx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteInternalTx.java
@@@ -509,10 -521,14 +508,9 @@@ public interface IgniteInternalTx exten
       @Nullable public GridTuple<CacheObject> peek(
           GridCacheContext ctx,
           boolean failFast,
-          KeyCacheObject key,
-          @Nullable CacheEntryPredicate[] filter) throws GridCacheFilterFailedException;
+          KeyCacheObject key) throws GridCacheFilterFailedException;
  
      /**
 -     * @return Start version.
 -     */
 -    public GridCacheVersion startVersion();
 -
 -    /**
       * @return Transaction version.
       */
      public GridCacheVersion xidVersion();

http://git-wip-us.apache.org/repos/asf/ignite/blob/fc6f56b2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxAdapter.java
----------------------------------------------------------------------


Mime
View raw message