Merge branch 'ignite-1.7' into ignite-3553
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7d05b650 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7d05b650 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7d05b650 Branch: refs/heads/ignite-3553 Commit: 7d05b6500c2310a54d589429911a2c1756746a12 Parents: b77bee0 8386dd8 Author: vozerov-gridgain <[email protected]> Authored: Thu Jul 28 14:06:00 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Thu Jul 28 14:06:00 2016 +0300 ---------------------------------------------------------------------- .gitignore | 1 + RELEASE_NOTES.txt | 17 + assembly/libs/README.txt | 39 +- .../examples/datagrid/CacheQueryExample.java | 78 +- .../jdbc2/JdbcDistributedJoinsQueryTest.java | 319 ++++ .../JettyRestProcessorAbstractSelfTest.java | 178 +- .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 2 + .../ignite/codegen/MessageCodeGenerator.java | 6 + modules/core/pom.xml | 6 + .../src/main/java/org/apache/ignite/Ignite.java | 4 +- .../org/apache/ignite/IgniteFileSystem.java | 9 + .../org/apache/ignite/IgniteJdbcDriver.java | 14 +- .../org/apache/ignite/cache/QueryEntity.java | 18 + .../ignite/cache/query/SqlFieldsQuery.java | 53 + .../org/apache/ignite/cache/query/SqlQuery.java | 28 + .../store/jdbc/CacheAbstractJdbcStore.java | 101 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 7 +- .../store/jdbc/CacheJdbcPojoStoreFactory.java | 26 + .../store/jdbc/JdbcTypesDefaultTransformer.java | 117 ++ .../cache/store/jdbc/JdbcTypesTransformer.java | 39 + .../configuration/IgniteConfiguration.java | 42 +- .../internal/cluster/ClusterGroupAdapter.java | 18 +- .../ignite/internal/jdbc2/JdbcConnection.java | 12 + .../ignite/internal/jdbc2/JdbcQueryTask.java | 9 +- .../ignite/internal/jdbc2/JdbcResultSet.java | 4 +- .../ignite/internal/jdbc2/JdbcStatement.java | 2 +- .../managers/communication/GridIoManager.java | 34 +- .../communication/GridIoMessageFactory.java | 2 +- .../managers/communication/GridIoPolicy.java | 5 +- .../GridAffinityFunctionContextImpl.java | 2 +- .../cache/GridCacheAffinityManager.java | 2 +- .../processors/cache/GridCacheContext.java | 19 + .../GridCacheDefaultAffinityKeyMapper.java | 19 + .../processors/cache/GridCacheIoManager.java | 21 +- .../processors/cache/IgniteCacheProxy.java | 8 + .../binary/CacheObjectBinaryProcessorImpl.java | 8 + .../distributed/GridCacheTxRecoveryFuture.java | 7 + .../distributed/GridCacheTxRecoveryRequest.java | 1 - .../GridCacheTxRecoveryResponse.java | 23 +- .../GridDistributedTxFinishRequest.java | 19 +- .../GridDistributedTxFinishResponse.java | 1 - .../GridDistributedTxPrepareRequest.java | 26 +- .../GridDistributedTxPrepareResponse.java | 20 +- .../dht/GridCachePartitionedConcurrentMap.java | 142 +- .../dht/GridDhtPartitionTopology.java | 2 +- .../dht/GridDhtPartitionTopologyImpl.java | 176 +- .../dht/GridDhtPartitionsReservation.java | 3 +- .../near/GridNearTxPrepareFutureAdapter.java | 7 + .../cache/query/GridCacheQueryManager.java | 110 +- .../cache/query/GridCacheQueryMarshallable.java | 37 + .../cache/query/GridCacheSqlQuery.java | 33 +- .../cache/query/GridCacheTwoStepQuery.java | 123 +- .../cache/transactions/IgniteTxHandler.java | 55 +- .../IgniteTxImplicitSingleStateImpl.java | 13 + .../IgniteTxRemoteSingleStateImpl.java | 13 + .../transactions/IgniteTxRemoteStateImpl.java | 38 +- .../cache/transactions/IgniteTxState.java | 6 + .../cache/transactions/IgniteTxStateAware.java | 34 + .../cache/transactions/IgniteTxStateImpl.java | 12 + .../cacheobject/IgniteCacheObjectProcessor.java | 6 + .../IgniteCacheObjectProcessorImpl.java | 5 + .../processors/closure/GridClosurePolicy.java | 51 - .../closure/GridClosureProcessor.java | 52 +- .../datastructures/GridCacheSemaphoreImpl.java | 108 +- .../internal/processors/igfs/IgfsAsyncImpl.java | 6 + .../internal/processors/igfs/IgfsImpl.java | 7 + .../platform/PlatformAbstractBootstrap.java | 5 + .../processors/platform/PlatformBootstrap.java | 6 + .../processors/platform/PlatformIgnition.java | 7 +- .../platform/PlatformProcessorImpl.java | 35 +- .../platform/cache/PlatformCache.java | 12 +- .../affinity/PlatformAffinityFunction.java | 27 + .../cache/affinity/PlatformAffinityUtils.java | 2 + .../callback/PlatformCallbackGateway.java | 13 +- .../callback/PlatformCallbackUtils.java | 8 + .../platform/cluster/PlatformClusterGroup.java | 7 + .../platform/compute/PlatformAbstractTask.java | 1 + .../dotnet/PlatformDotNetBootstrap.java | 12 + .../dotnet/PlatformDotNetCacheStore.java | 27 +- .../PlatformDotNetConfigurationClosure.java | 58 +- .../dotnet/PlatformDotNetConsoleStream.java | 54 + .../services/PlatformAbstractService.java | 3 +- .../utils/PlatformConfigurationUtils.java | 106 +- .../platform/utils/PlatformFutureUtils.java | 2 + .../platform/utils/PlatformUtils.java | 12 + .../processors/query/GridQueryIndexing.java | 51 +- .../processors/query/GridQueryProcessor.java | 194 +-- .../query/GridQueryTypeDescriptor.java | 7 + .../messages/GridQueryCancelRequest.java | 2 +- .../twostep/messages/GridQueryFailResponse.java | 2 +- .../messages/GridQueryNextPageRequest.java | 2 +- .../messages/GridQueryNextPageResponse.java | 12 +- .../h2/twostep/messages/GridQueryRequest.java | 28 +- .../handlers/cache/GridCacheCommandHandler.java | 100 +- .../handlers/query/QueryCommandHandler.java | 4 + .../rest/request/RestQueryRequest.java | 17 + .../ignite/internal/util/IgniteUtils.java | 47 +- .../internal/util/PartitionedReadOnlySet.java | 71 - .../ignite/internal/util/lang/GridFunc.java | 20 + .../offheap/unsafe/GridOffHeapSnapTreeMap.java | 91 +- .../internal/visor/query/VisorQueryArgV2.java | 49 + .../internal/visor/query/VisorQueryJob.java | 1 + .../dotnet/PlatformDotNetAffinityFunction.java | 15 + .../SpringApplicationContextResource.java | 4 +- .../apache/ignite/resources/SpringResource.java | 15 +- .../ignite/scheduler/SchedulerFuture.java | 5 +- .../java/org/jetbrains/annotations/NotNull.java | 38 - .../org/jetbrains/annotations/Nullable.java | 33 - .../org/jetbrains/annotations/package-info.java | 27 - .../ignite/internal/ClusterGroupSelfTest.java | 30 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 127 +- .../IgniteTxExceptionAbstractSelfTest.java | 45 +- .../IgniteSemaphoreAbstractSelfTest.java | 25 +- .../dht/IgniteCacheConcurrentPutGetRemove.java | 201 +++ .../IgniteCacheSyncRebalanceModeSelfTest.java | 2 + .../internal/processors/igfs/IgfsMock.java | 8 + .../processors/igfs/IgfsStreamsSelfTest.java | 5 +- ...niteMessagingConfigVariationFullApiTest.java | 484 ++++++ .../GridCacheAtomicCommandHandlerSelfTest.java | 39 + .../cache/GridCacheCommandHandlerSelfTest.java | 20 +- .../ignite/platform/PlatformStringTestTask.java | 67 + .../jdbc/TcpDiscoveryJdbcIpFinderSelfTest.java | 2 +- .../junits/common/GridCommonAbstractTest.java | 39 +- ...essagingConfigVariationFullApiTestSuite.java | 72 + .../testsuites/IgniteRestHandlerTestSuite.java | 2 + modules/docker/1.6.0/Dockerfile | 44 + modules/docker/1.6.0/run.sh | 51 + modules/docker/Dockerfile | 24 +- .../query/h2/opt/GridH2SpatialIndex.java | 74 +- .../collections/HadoopHashMapSelfTest.java | 68 +- .../processors/query/h2/IgniteH2Indexing.java | 726 ++++++-- .../query/h2/opt/GridH2AbstractKeyValueRow.java | 72 +- .../query/h2/opt/GridH2CollocationModel.java | 783 +++++++++ .../processors/query/h2/opt/GridH2Cursor.java | 36 +- .../query/h2/opt/GridH2DefaultTableEngine.java | 38 + .../query/h2/opt/GridH2IndexBase.java | 1392 ++++++++++++++- .../query/h2/opt/GridH2MetaTable.java | 383 ++++ .../query/h2/opt/GridH2QueryContext.java | 612 +++++++ .../query/h2/opt/GridH2QueryType.java | 49 + .../query/h2/opt/GridH2RetryException.java | 32 + .../processors/query/h2/opt/GridH2Row.java | 86 +- .../query/h2/opt/GridH2RowDescriptor.java | 28 +- .../query/h2/opt/GridH2RowFactory.java | 179 ++ .../processors/query/h2/opt/GridH2Table.java | 372 ++-- .../query/h2/opt/GridH2TreeIndex.java | 142 +- .../processors/query/h2/opt/GridH2Utils.java | 133 -- .../query/h2/opt/GridH2ValueCacheObject.java | 3 +- .../query/h2/opt/GridLuceneIndex.java | 7 +- .../processors/query/h2/sql/GridSqlAlias.java | 12 + .../processors/query/h2/sql/GridSqlColumn.java | 22 +- .../processors/query/h2/sql/GridSqlElement.java | 11 + .../query/h2/sql/GridSqlOperation.java | 2 +- .../query/h2/sql/GridSqlOperationType.java | 8 +- .../query/h2/sql/GridSqlQueryParser.java | 97 +- .../query/h2/sql/GridSqlQuerySplitter.java | 293 +++- .../processors/query/h2/sql/GridSqlSelect.java | 9 +- .../processors/query/h2/sql/GridSqlTable.java | 70 + .../query/h2/twostep/GridMapQueryExecutor.java | 415 +++-- .../query/h2/twostep/GridMergeIndex.java | 75 +- .../h2/twostep/GridMergeIndexUnsorted.java | 6 +- .../query/h2/twostep/GridMergeTable.java | 4 +- .../h2/twostep/GridReduceQueryExecutor.java | 338 ++-- .../query/h2/twostep/GridThreadLocalTable.java | 68 +- .../query/h2/twostep/msg/GridH2Array.java | 9 +- .../query/h2/twostep/msg/GridH2Boolean.java | 10 +- .../query/h2/twostep/msg/GridH2Byte.java | 9 +- .../query/h2/twostep/msg/GridH2Bytes.java | 11 +- .../query/h2/twostep/msg/GridH2CacheObject.java | 9 +- .../query/h2/twostep/msg/GridH2Date.java | 9 +- .../query/h2/twostep/msg/GridH2Decimal.java | 11 +- .../query/h2/twostep/msg/GridH2Double.java | 9 +- .../query/h2/twostep/msg/GridH2Float.java | 9 +- .../query/h2/twostep/msg/GridH2Geometry.java | 11 +- .../h2/twostep/msg/GridH2IndexRangeRequest.java | 208 +++ .../twostep/msg/GridH2IndexRangeResponse.java | 279 +++ .../query/h2/twostep/msg/GridH2Integer.java | 20 +- .../query/h2/twostep/msg/GridH2JavaObject.java | 11 +- .../query/h2/twostep/msg/GridH2Long.java | 9 +- .../query/h2/twostep/msg/GridH2Null.java | 15 +- .../h2/twostep/msg/GridH2QueryRequest.java | 401 +++++ .../query/h2/twostep/msg/GridH2RowMessage.java | 116 ++ .../query/h2/twostep/msg/GridH2RowRange.java | 181 ++ .../h2/twostep/msg/GridH2RowRangeBounds.java | 188 ++ .../query/h2/twostep/msg/GridH2Short.java | 9 +- .../query/h2/twostep/msg/GridH2String.java | 9 +- .../query/h2/twostep/msg/GridH2Time.java | 9 +- .../query/h2/twostep/msg/GridH2Timestamp.java | 11 +- .../query/h2/twostep/msg/GridH2Uuid.java | 9 +- .../h2/twostep/msg/GridH2ValueMessage.java | 2 +- .../twostep/msg/GridH2ValueMessageFactory.java | 22 +- .../cache/CacheIndexingOffheapCleanupTest.java | 178 ++ ...idCacheReduceQueryMultithreadedSelfTest.java | 168 -- .../cache/IgniteCacheAbstractQuerySelfTest.java | 30 +- .../IgniteCacheCrossCacheJoinRandomTest.java | 442 +++++ ...acheDistributedJoinCollocatedAndNotTest.java | 365 ++++ ...acheDistributedJoinCustomAffinityMapper.java | 262 +++ .../IgniteCacheDistributedJoinNoIndexTest.java | 299 ++++ ...ributedJoinPartitionedAndReplicatedTest.java | 487 ++++++ ...CacheDistributedJoinQueryConditionsTest.java | 624 +++++++ .../cache/IgniteCacheDistributedJoinTest.java | 316 ++++ ...PartitionedAndReplicatedCollocationTest.java | 399 +++++ ...teCacheJoinPartitionedAndReplicatedTest.java | 316 ++++ ...IgniteCacheJoinQueryWithAffinityKeyTest.java | 646 +++++++ ...IgniteCachePrimitiveFieldsQuerySelfTest.java | 134 ++ .../cache/IgniteCacheQueryLoadSelfTest.java | 12 +- .../cache/IgniteCacheUnionDuplicatesTest.java | 151 ++ .../cache/IgniteCrossCachesJoinsQueryTest.java | 1641 ++++++++++++++++++ ...QueryNodeRestartDistributedJoinSelfTest.java | 476 +++++ ...dCacheAbstractReduceFieldsQuerySelfTest.java | 420 ----- ...ridCacheReduceFieldsQueryAtomicSelfTest.java | 38 - ...GridCacheReduceFieldsQueryLocalSelfTest.java | 37 - ...cheReduceFieldsQueryPartitionedSelfTest.java | 59 - ...acheReduceFieldsQueryReplicatedSelfTest.java | 37 - .../query/IgniteSqlSchemaIndexingTest.java | 5 +- .../query/IgniteSqlSplitterSelfTest.java | 833 ++++++++- .../h2/GridIndexingSpiAbstractSelfTest.java | 145 +- .../query/h2/opt/GridH2TableSelfTest.java | 10 +- .../h2/sql/AbstractH2CompareQueryTest.java | 165 +- .../query/h2/sql/GridQueryParsingTest.java | 28 +- .../H2CompareBigQueryDistributedJoinsTest.java | 28 + .../query/h2/sql/H2CompareBigQueryTest.java | 119 +- .../IgniteCacheQuerySelfTestSuite.java | 27 +- .../IgniteCacheQuerySelfTestSuite2.java | 10 - .../IgniteCacheWithIndexingTestSuite.java | 2 + .../ignite/stream/kafka/KafkaStreamer.java | 4 +- .../connect/IgniteSourceConnectorTest.java | 58 +- .../cpp/common/include/ignite/common/utils.h | 18 + modules/platforms/cpp/core-test/Makefile.am | 1 + .../cpp/core-test/config/cache-query.xml | 42 +- .../cpp/core-test/project/vs/core-test.vcxproj | 3 +- .../project/vs/core-test.vcxproj.filters | 5 +- .../cpp/core-test/src/cache_query_test.cpp | 443 ++++- .../cpp/core-test/src/interop_test.cpp | 148 ++ .../core/include/ignite/cache/query/query_sql.h | 61 +- .../ignite/cache/query/query_sql_fields.h | 111 +- modules/platforms/cpp/examples/README.txt | 1 + .../cpp/jni/include/ignite/jni/exports.h | 4 + .../platforms/cpp/jni/include/ignite/jni/java.h | 17 +- modules/platforms/cpp/jni/project/vs/module.def | 4 + modules/platforms/cpp/jni/src/exports.cpp | 12 + modules/platforms/cpp/jni/src/java.cpp | 120 +- .../cpp/odbc-test/config/queries-test.xml | 9 +- .../cpp/odbc-test/src/configuration_test.cpp | 110 +- .../cpp/odbc-test/src/queries_test.cpp | 91 +- .../include/ignite/odbc/config/configuration.h | 121 +- .../cpp/odbc/include/ignite/odbc/connection.h | 38 +- .../cpp/odbc/src/config/configuration.cpp | 227 ++- modules/platforms/cpp/odbc/src/connection.cpp | 47 +- modules/platforms/cpp/odbc/src/odbc.cpp | 27 +- .../Apache.Ignite.AspNet.csproj | 73 + .../Apache.Ignite.AspNet.nuspec | 57 + .../Apache.Ignite.AspNet.ruleset | 9 + .../Apache.Ignite.AspNet.snk | Bin 0 -> 596 bytes .../IgniteOutputCacheProvider.cs | 220 +++ .../Apache.Ignite.AspNet/IgniteWebUtils.cs | 44 + .../dotnet/Apache.Ignite.AspNet/Package-Info.cs | 26 + .../Properties/AssemblyInfo.cs | 39 + .../Properties/AssemblyInfo.cs | 2 +- .../Apache.Ignite.Core.Tests.NuGet.csproj | 14 + .../AspNetTest.cs | 73 + .../Properties/AssemblyInfo.cs | 2 +- .../SchemaTest.cs | 62 + .../install-package.ps1 | 21 +- .../packages.config | 2 + .../Properties/AssemblyInfo.cs | 2 +- .../Apache.Ignite.Core.Tests.csproj | 18 +- .../AspNet/IgniteOutputCacheProviderTest.cs | 172 ++ .../Binary/BinarySelfTest.cs | 164 +- .../Binary/BinaryStringTest.cs | 120 ++ .../Cache/Affinity/AffinityFieldTest.cs | 199 +++ .../Affinity/AffinityFunctionSpringTest.cs | 2 +- .../Cache/Affinity/AffinityFunctionTest.cs | 485 ++++++ .../Cache/Affinity/AffinityTest.cs | 138 ++ .../Cache/CacheAffinityFieldTest.cs | 199 --- .../Cache/CacheAffinityTest.cs | 139 -- .../Cache/CacheConfigurationTest.cs | 134 +- .../Cache/Query/CacheLinqTest.cs | 84 +- .../Cache/Query/CacheQueriesTest.cs | 257 +-- .../Continuous/ContinuousQueryAbstractTest.cs | 18 +- .../Cache/Store/CacheStoreTest.cs | 11 +- .../Compute/AbstractTaskTest.cs | 9 + .../Compute/BinarizableTaskTest.cs | 13 +- .../Compute/ComputeApiTest.cs | 110 +- .../Compute/FailoverTaskSelfTest.cs | 2 +- .../Compute/IgniteExceptionTaskSelfTest.cs | 18 +- .../Compute/ResourceTaskTest.cs | 8 +- .../Compute/TaskAdapterTest.cs | 16 +- .../Compute/TaskResultTest.cs | 10 +- .../Config/Cache/Affinity/affinity-function.xml | 4 +- .../Config/cache-query-continuous.xml | 1 + .../native-client-test-cache-affinity.xml | 2 +- .../ConsoleRedirectTest.cs | 177 ++ .../Apache.Ignite.Core.Tests/EventsTest.cs | 4 +- .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 81 +- .../IgniteConfigurationSectionTest.cs | 32 + .../IgniteConfigurationSerializerTest.cs | 21 + .../IgniteConfigurationTest.cs | 12 +- .../IgniteStartStopTest.cs | 3 +- .../Apache.Ignite.Core.Tests/LifecycleTest.cs | 9 + .../Properties/AssemblyInfo.cs | 2 +- .../Apache.Ignite.Core.Tests/ReconnectTest.cs | 13 + .../Services/ServiceProxyTest.cs | 6 +- .../Services/ServicesTest.cs | 26 +- .../Apache.Ignite.Core.Tests/TestRunner.cs | 46 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 15 +- .../dotnet/Apache.Ignite.Core.Tests/app.config | 2 +- .../Apache.Ignite.Core.Tests/custom_app.config | 34 + .../Apache.Ignite.Core.Schema.nuspec | 53 + .../Apache.Ignite.Core.csproj | 19 +- .../Apache.Ignite.Core.nuspec | 2 +- .../Binary/BinaryReflectiveSerializer.cs | 193 +- .../Cache/Configuration/CacheConfiguration.cs | 18 +- .../Cache/Query/SqlFieldsQuery.cs | 27 +- .../Apache.Ignite.Core/Cache/Query/SqlQuery.cs | 13 + .../Apache.Ignite.Core/Cluster/IClusterGroup.cs | 6 + .../Apache.Ignite.Core/Common/JavaException.cs | 65 + .../Configuration/AtomicConfiguration.cs | 9 + .../Configuration/Package-Info.cs | 26 + .../Discovery/Package-Info.cs | 26 + .../Discovery/Tcp/Multicast/Package-Info.cs | 26 + .../Discovery/Tcp/Package-Info.cs | 26 + .../Discovery/Tcp/Static/Package-Info.cs | 26 + .../Apache.Ignite.Core/Events/EventBase.cs | 2 +- .../dotnet/Apache.Ignite.Core/IIgnite.cs | 25 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 2 + .../IgniteConfigurationSection.xsd | 9 +- .../dotnet/Apache.Ignite.Core/Ignition.cs | 82 +- .../Impl/Binary/BinarizableSerializer.cs | 22 +- .../Impl/Binary/BinaryFullTypeDescriptor.cs | 8 +- .../Impl/Binary/BinaryReader.cs | 38 +- .../Impl/Binary/BinaryReaderExtensions.cs | 2 +- .../Impl/Binary/BinaryReflectiveActions.cs | 10 +- .../BinaryReflectiveSerializerInternal.cs | 169 ++ .../Binary/BinarySurrogateTypeDescriptor.cs | 4 +- .../Impl/Binary/BinarySystemTypeSerializer.cs | 20 +- .../Impl/Binary/BinaryUtils.cs | 180 +- .../Impl/Binary/BinaryWriter.cs | 2 +- .../Impl/Binary/DateTimeSerializer.cs | 48 + .../Impl/Binary/IBinarySerializerInternal.cs | 42 + .../Impl/Binary/IBinarySystemTypeSerializer.cs | 34 - .../Impl/Binary/IBinaryTypeDescriptor.cs | 2 +- .../Impl/Binary/Io/BinaryHeapStream.cs | 2 +- .../Impl/Binary/Io/BinaryStreamBase.cs | 14 - .../Impl/Binary/Marshaller.cs | 77 +- .../Impl/Binary/SerializableSerializer.cs | 48 + .../Impl/Binary/UserSerializerProxy.cs | 68 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 6 +- .../Impl/Cache/Store/CacheStore.cs | 4 +- .../Impl/Cluster/ClusterGroupImpl.cs | 6 + .../Impl/Common/DelegateConverter.cs | 44 + .../Impl/Compute/ComputeTaskHolder.cs | 3 +- .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 31 +- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 48 +- .../Apache.Ignite.Core/Impl/IgniteProxy.cs | 43 +- .../Apache.Ignite.Core/Impl/IgniteUtils.cs | 47 +- .../Impl/LifecycleBeanHolder.cs | 2 +- .../Impl/Memory/PlatformMemoryStream.cs | 3 +- .../Apache.Ignite.Core/Impl/NativeMethods.cs | 6 + .../Impl/Services/ServiceProxyInvoker.cs | 14 +- .../Impl/Services/Services.cs | 17 +- .../Impl/Unmanaged/IgniteJniNativeMethods.cs | 9 + .../Impl/Unmanaged/UnmanagedCallbacks.cs | 94 +- .../Impl/Unmanaged/UnmanagedUtils.cs | 23 + .../Apache.Ignite.Core/Interop/Package-Info.cs | 26 + .../Lifecycle/ClientReconnectEventArgs.cs | 47 + .../Properties/AssemblyInfo.cs | 4 +- .../Transactions/TransactionConfiguration.cs | 12 + .../Apache.Ignite.Linq.csproj | 2 + .../Apache.Ignite.Linq.nuspec | 6 +- .../Apache.Ignite.Linq/CacheExtensions.cs | 24 +- .../Apache.Ignite.Linq/Impl/AliasDictionary.cs | 74 +- .../Impl/CacheFieldsQueryExecutor.cs | 63 +- .../Impl/CacheQueryExpressionVisitor.cs | 4 +- .../Impl/CacheQueryModelVisitor.cs | 6 +- .../Apache.Ignite.Linq/Impl/CacheQueryable.cs | 10 +- .../Impl/CacheQueryableBase.cs | 7 +- .../Apache.Ignite.Linq/Impl/ExpressionWalker.cs | 34 +- .../dotnet/Apache.Ignite.Linq/Package-Info.cs | 26 + .../Properties/AssemblyInfo.cs | 2 +- .../dotnet/Apache.Ignite.Linq/QueryOptions.cs | 91 + modules/platforms/dotnet/Apache.Ignite.dxg | 4 +- modules/platforms/dotnet/Apache.Ignite.sln | 14 + .../dotnet/Apache.Ignite.sln.DotSettings | 7 +- .../dotnet/Apache.Ignite/Config/Configurator.cs | 11 +- .../Apache.Ignite/Properties/AssemblyInfo.cs | 2 +- .../Properties/AssemblyInfo.cs | 2 +- .../Properties/AssemblyInfo.cs | 2 +- .../http/jetty/GridJettyRestHandler.java | 5 + .../processors/schedule/ScheduleFutureImpl.java | 7 +- .../schedule/GridScheduleSelfTest.java | 33 +- .../apache/ignite/logger/slf4j/Slf4jLogger.java | 2 +- .../org/apache/ignite/spark/IgniteContext.scala | 8 +- .../org/apache/ignite/spark/IgniteRDD.scala | 10 +- .../apache/ignite/spark/JavaIgniteContext.scala | 2 +- .../org/apache/ignite/spark/JavaIgniteRDD.scala | 12 +- .../ignite/spark/impl/IgniteAbstractRDD.scala | 2 +- .../apache/ignite/spark/impl/IgniteSqlRDD.scala | 2 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 19 +- .../org/apache/ignite/spark/IgniteRDDSpec.scala | 38 +- modules/spring/pom.xml | 7 - .../org/apache/ignite/IgniteSpringBean.java | 143 +- .../GridResourceSpringBeanInjector.java | 39 +- .../ignite/internal/IgniteSpringBeanTest.java | 55 + .../GridSpringResourceInjectionSelfTest.java | 311 +++- .../spring-resource-with-duplicate-beans.xml | 30 + .../processors/resource/spring-resource.xml | 2 +- .../org/apache/ignite/spring-injection-test.xml | 2 +- .../testsuites/IgniteSpringTestSuite.java | 2 + .../cache/websession/WebSessionFilter.java | 11 +- .../ignite/cache/websession/WebSessionV2.java | 10 +- .../internal/websession/WebSessionSelfTest.java | 8 +- modules/yardstick/config/queries.sql | 1 + .../ignite/yardstick/IgniteBenchmarkUtils.java | 45 + .../IgniteSqlQueryDistributedJoinBenchmark.java | 184 ++ ...lQueryDistributedJoinBroadcastBenchmark.java | 28 + .../IgniteCacheRandomOperationBenchmark.java | 71 +- parent/pom.xml | 25 +- 417 files changed, 25610 insertions(+), 5087 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7d05b650/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java ----------------------------------------------------------------------
