This is an automated email from the ASF dual-hosted git repository. gvvinblade pushed a change to branch ignite-12248 in repository https://gitbox.apache.org/repos/asf/ignite.git.
from c7bdc11 IGNITE-12871: Calcite integration. Broadcast to hash conversion without exchange. This closes #7638 add c0f3708 IGNITE-12863 Initialize PojoField accessor after deserialization - Fixes #7624. add 7f4914f IGNITE-12841: @Override must be on the same line as a method (#7578) add 826aad8 IGNITE-12726 Long keys support for metastorage. (#7606) add f57509e IGNITE-12828 Fixes NPE during CQ registration with failed deployment. (#7620) add b816729 IGNITE-12805 Fixed NullPointerException when memory restore is in progress. Fixes #7562 add b2added IGNITE-12877 "restorePartitionStates" writes only modified pages in WAL now. (#7644) add d3a1350 IGNITE-12874 Fixed possible NullPointerException in GridDiscoveryManager#cacheGroupAffinityNode. Fixes #7641 add 7113758 IGNITE-12870 Fix test JdbcThinTransactionsLeaksMvccTest after connection manager refactoring (#7632) add 022b79d IGNITE-12760 Prevent AssertionError on message unmarshalling when received from a dead node - Fixes #7538. add 6e0b1f6 IGNITE-7609 .NET: Expose field types in FieldsQueryCursor add e0a846c IGNITE-12882 .NET: Use platform Near Cache for local ScanQuery add dc2b2ca IGNITE-11494 Make log message more verbose if merge table size is too low (#7629) add f441fac IGNITE-12872: Tests to check correct work of explicit security permissions. (#7651) add 2f51d24 IGNITE-12875 EVT_CLUSTER_STATE_CHANGE_STARTED event type implemented - Fixes #7642. add 60ebc23 IGNITE-12848 fix H2Connection leaks on INSERT (#7649) add 88b2356 IGNITE-12856 Stabilize flaky tests. - Fixes #7612. add 00cb1ad IGNITE-12764: Thin JDBC streaming fails BatchUpdateException if function is used (#7615) add 0f55d76 IGNITE-12883 .NET: Rename PlatformNearCache to PlatformCache, mark as Experimental add 1d4db11 IGNITE-12358 Migrate ZeroMQ module to ignite-extensions - Fixes #7240. add 3ac680f IGNITE-12361 Migrate Flume module to ignite-extensions - Fixes #7227. add f64fe2c IGNITE-12739 Optimistic serializable transactions may fail infinitely when read-through is enabled. (#7575) add 6b6d82a IGNITE-1328 Remove sufficiently tested OS check add 38f658f Updating outdated readme file that now matches content of the website. add 8a9f8bd Fixed misprints in the README add 54e3aa4 IGNITE-12821 Added check-sizes parameter to validate_indexes cmd add 6c01d3e IGNITE-12893: Add support for SimplifyBooleanExpression checkstyle rule (#7670) add c165e64 IGNITE-12884 Extended debug output of restoring partition states. Fixes #7657 add 23a392a IGNITE-12873 Do not send hostnames when IP is used in localHost - Fixes #7640. add 143f7e3 IGNITE-12844: Too many caches can block discovery. This closes #7582 new 7b367b5 Merge branch 'master' into ignite-12248 new f23fadb IGNITE-12864: Calcite integration. UNION support. This closes #7673 The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: README.md | 75 +-- checkstyle/checkstyle.xml | 6 + .../examples/datagrid/SpatialQueryExample.java | 2 +- .../hibernate/HibernateL2CacheExample.java | 2 + .../examples/misc/schedule/package-info.java | 2 +- .../apache/ignite/gridify/hierarchy/Target.java | 4 +- .../test/gridify/ExternalNonSpringAopSelfTest.java | 2 +- .../query/calcite/exec/ExecutionServiceImpl.java | 1 + .../query/calcite/exec/LogicalRelImplementor.java | 9 + .../query/calcite/exec/PhysicalRelImplementor.java | 10 + .../query/calcite/exec/rel/UnionAllNode.java | 98 ++++ .../metadata/IgniteMdDerivedDistribution.java | 85 ++- .../calcite/metadata/IgniteMdDistribution.java | 73 +-- .../calcite/metadata/IgniteMdFragmentInfo.java | 27 + .../processors/query/calcite/prepare/Cloner.java | 11 +- .../query/calcite/prepare/FragmentSplitter.java | 319 ++++++----- .../query/calcite/prepare/PlannerPhase.java | 8 +- .../processors/query/calcite/prepare/Splitter.java | 8 +- .../query/calcite/rel/IgniteReceiver.java | 9 +- .../query/calcite/rel/IgniteReduceAggregate.java | 5 +- .../query/calcite/rel/IgniteRelVisitor.java | 5 + .../processors/query/calcite/rel/IgniteSender.java | 14 +- .../{IgniteReceiver.java => IgniteUnionAll.java} | 47 +- .../rule/AggregateTraitsPropagationRule.java | 6 +- .../processors/query/calcite/rule/RuleUtils.java | 36 +- .../query/calcite/rule/UnionConverterRule.java | 64 +++ .../rule/UnionTraitsTraitsPropagationRule.java | 69 +++ .../calcite/serialize/PhysicalRelVisitor.java | 5 + .../calcite/serialize/RelToPhysicalConverter.java | 13 + .../calcite/serialize/UnionAllPhysicalRel.java | 67 +++ .../query/calcite/trait/DistributionTrait.java | 38 +- .../query/calcite/trait/IgniteDistributions.java | 313 ++++------- .../processors/query/calcite/util/Commons.java | 27 + .../query/calcite/CalciteQueryProcessorTest.java | 95 ++++ .../processors/query/calcite/PlannerTest.java | 282 ++++++++++ .../query/calcite/exec/rel/ExecutionTest.java | 44 ++ .../persistence/KeyPersistenceSettings.java | 35 +- .../persistence/KeyValuePersistenceSettings.java | 15 +- .../persistence/PersistenceController.java | 8 +- .../cassandra/persistence/PersistenceSettings.java | 72 ++- .../store/cassandra/persistence/PojoField.java | 14 +- .../store/cassandra/persistence/PojoKeyField.java | 14 +- .../cassandra/persistence/PojoValueField.java | 16 + .../persistence/ValuePersistenceSettings.java | 26 +- .../ignite/tests/CassandraSessionImplTest.java | 30 +- .../ignite/tests/IgnitePersistentStoreTest.java | 109 +++- .../ignite/jdbc/thin/JdbcThinAbstractSelfTest.java | 7 +- .../ignite/jdbc/thin/JdbcThinBatchSelfTest.java | 45 +- ...onAwarenessReconnectionAndFailoverSelfTest.java | 6 +- .../thin/JdbcThinStreamingAbstractSelfTest.java | 49 ++ .../thin/JdbcThinTransactionsLeaksMvccTest.java | 17 +- .../DiskPageCompressionIntegrationTest.java | 3 +- .../WalPageCompressionIntegrationTest.java | 3 +- .../org/apache/ignite/IgniteSystemProperties.java | 15 +- .../ignite/configuration/CacheConfiguration.java | 25 +- ...ration.java => PlatformCacheConfiguration.java} | 18 +- .../ignite/events/ClusterActivationEvent.java | 2 +- ...nt.java => ClusterStateChangeStartedEvent.java} | 61 ++- .../java/org/apache/ignite/events/EventType.java | 12 + .../org/apache/ignite/internal/GridDiagnostic.java | 11 - .../ignite/internal/GridEventConsumeHandler.java | 44 +- .../org/apache/ignite/internal/IgnitionEx.java | 3 +- .../ignite/internal/MarshallerContextImpl.java | 4 +- .../commandline/cache/CacheValidateIndexes.java | 137 +++-- .../cache/argument/ValidateIndexesCommandArg.java | 9 +- .../internal/dto/IgniteDataTransferObject.java | 3 + .../managers/deployment/GridDeploymentManager.java | 25 +- .../deployment/GridDeploymentMetadata.java | 4 +- .../managers/discovery/GridDiscoveryManager.java | 6 + .../processors/cache/ClusterCachesInfo.java | 3 +- .../processors/cache/GridCacheContext.java | 8 +- .../cache/GridCacheDeploymentManager.java | 33 +- .../processors/cache/GridCacheIoManager.java | 30 +- .../processors/cache/GridCacheMapEntry.java | 34 +- .../IgnitePeerToPeerClassLoadingException.java} | 19 +- .../LongRunningTxTimeDumpSettingsClosure.java | 3 +- .../cache/ValidationOnNodeJoinUtils.java | 14 +- .../cache/distributed/dht/GridDhtCacheEntry.java | 2 +- .../distributed/dht/GridPartitionedGetFuture.java | 2 +- .../dht/GridPartitionedSingleGetFuture.java | 3 +- .../preloader/GridDhtPartitionsExchangeFuture.java | 2 +- .../PartitionDefferedDeleteQueueCleanupTask.java | 3 +- .../cache/distributed/near/GridNearCacheEntry.java | 6 +- .../cache/distributed/near/GridNearGetFuture.java | 3 +- .../near/GridNearTransactionalCache.java | 4 +- .../cache/distributed/near/GridNearTxLocal.java | 5 +- .../cache/persistence/GridCacheOffheapManager.java | 40 +- .../cache/persistence/metastorage/MetaStorage.java | 82 ++- .../metastorage/MetastorageBPlusIO.java | 65 +++ .../metastorage/MetastorageDataRow.java | 48 +- .../metastorage/MetastorageInnerIO.java | 84 +++ .../persistence/metastorage/MetastorageLeafIO.java | 82 +++ .../metastorage/MetastoragePageIOUtils.java | 135 +++++ .../persistence/metastorage/MetastorageRow.java} | 27 +- .../metastorage/MetastorageRowStore.java | 20 +- ...hRowImpl.java => MetastorageRowStoreEntry.java} | 41 +- .../metastorage/MetastorageSearchRow.java | 32 +- .../persistence/metastorage/MetastorageTree.java | 198 +------ .../snapshot/IgniteCacheSnapshotManager.java | 2 +- .../cache/persistence/tree/io/PageIO.java | 6 +- .../persistence/tree/io/PagePartitionMetaIO.java | 10 + .../persistence/tree/io/PagePartitionMetaIOV2.java | 2 + .../wal/reader/IgniteWalIteratorFactory.java | 3 +- .../continuous/CacheContinuousQueryHandler.java | 26 +- .../cluster/GridClusterStateProcessor.java | 31 +- .../DistributedConfigurationProcessor.java | 8 +- .../continuous/GridContinuousProcessor.java | 2 +- .../processors/igfs/IgfsInputStreamImpl.java | 3 +- .../processors/platform/PlatformContext.java | 18 +- .../processors/platform/PlatformContextImpl.java | 24 +- .../processors/platform/PlatformProcessorImpl.java | 16 +- .../processors/platform/cache/PlatformCache.java | 56 +- .../cache/PlatformCacheEntryFilterImpl.java | 20 +- .../cache/query/PlatformFieldsQueryCursor.java | 21 +- .../platform/callback/PlatformCallbackGateway.java | 12 +- .../platform/callback/PlatformCallbackOp.java | 4 +- .../platform/utils/PlatformConfigurationUtils.java | 34 +- .../processors/platform/utils/PlatformUtils.java | 3 +- .../processors/query/GridQueryIndexing.java | 5 +- .../processors/query/GridQueryProcessor.java | 12 +- .../query/schema/SchemaIndexCacheVisitorImpl.java | 12 +- .../rest/client/message/GridClientCacheBean.java | 9 +- .../handlers/cache/GridCacheCommandHandler.java | 3 +- .../redis/key/GridRedisExpireCommandHandler.java | 2 +- .../redis/server/GridRedisFlushCommandHandler.java | 2 +- .../handlers/top/GridTopologyCommandHandler.java | 3 +- .../apache/ignite/internal/util/IgniteUtils.java | 20 +- .../internal/util/collection/ImmutableIntSet.java | 15 +- .../ignite/internal/util/io/GridFilenameUtils.java | 7 +- .../internal/util/test/GridTestPrintStream.java | 2 +- .../baseline/VisorBaselineAutoAdjustSettings.java | 4 +- .../verify/ValidateIndexesCheckSizeIssue.java | 107 ++++ .../verify/ValidateIndexesCheckSizeResult.java | 101 ++++ .../verify/VisorValidateIndexesJobResult.java | 78 ++- .../visor/verify/VisorValidateIndexesTaskArg.java | 81 +-- .../java/org/apache/ignite/lang/IgniteBiTuple.java | 3 +- .../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 3 +- .../spi/communication/tcp/TcpCommunicationSpi.java | 17 +- .../spi/deployment/DeploymentResourceAdapter.java | 4 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 80 ++- .../ignite/spi/discovery/tcp/ServerImpl.java | 76 +-- .../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 54 ++ .../java/org/jsr166/ConcurrentLinkedDeque8.java | 3 +- .../main/resources/META-INF/classnames.properties | 2 + .../store/jdbc/model/TestJdbcPojoDataSource.java | 194 +++---- .../events/ClusterActivationStartedEventTest.java | 241 +++++++++ .../internal/IgniteComputeResultExceptionTest.java | 4 +- ...tadataRegistrationInsideEntryProcessorTest.java | 4 +- .../CacheStoreUsageMultinodeAbstractTest.java | 3 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 29 +- ...PartitionEvictionDuringReadThroughSelfTest.java | 3 +- .../dht/GridCacheDhtEvictionsDisabledSelfTest.java | 2 +- .../GridCachePartitionedUnloadEventsSelfTest.java | 3 +- .../dht/IgniteCacheLockFailoverSelfTest.java | 3 +- .../PartitionsEvictManagerAbstractTest.java | 7 +- .../IgniteCacheExpireWhileRebalanceTest.java | 6 +- .../persistence/db/wal/WalOnNodeStartTest.java | 131 +++++ .../metastorage/IgniteMetaStorageBasicTest.java | 44 +- ...eContinuousQueryFilterDeploymentFailedTest.java | 118 ++++ .../cache/transactions/TxDeadlockCauseTest.java | 6 +- .../transactions/TxOptimisticReadThroughTest.java | 216 ++++++++ .../processors/database/BPlusTreeSelfTest.java | 5 +- .../datastreamer/DataStreamProcessorSelfTest.java | 3 +- .../processors/igfs/IgfsAbstractSelfTest.java | 15 +- .../processors/igfs/IgfsProcessorSelfTest.java | 3 +- .../DistributedMetaStoragePersistentTest.java | 28 + .../client/ThinClientPermissionCheckTest.java | 112 +++- .../ignite/internal/util/IgniteUtilsSelfTest.java | 4 +- .../p2p/ClassLoadingProblemExceptionTest.java | 330 ++++++++++++ .../ignite/p2p/GridP2PRecursionTaskSelfTest.java | 2 +- .../platform/PlatformIsPartitionReservedTask.java | 96 ++++ ...sionSetFutureAttributeWaitListenerSelfTest.java | 2 +- ...SessionSetJobAttributeWaitListenerSelfTest.java | 2 +- .../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 133 +++++ .../tcp/TcpDiscoveryMetricsWarnLogTest.java | 133 +++++ .../startup/servlet/GridServletLoaderTest.java | 4 +- .../apache/ignite/testframework/GridTestNode.java | 3 +- .../apache/ignite/testframework/GridTestUtils.java | 18 +- .../cache/GridAbstractCacheStoreSelfTest.java | 3 +- .../junits/common/GridCommonAbstractTest.java | 34 ++ .../junits/multijvm/IgniteProcessProxy.java | 6 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite6.java | 4 + .../ignite/testsuites/IgniteCacheTestSuite6.java | 3 + .../IgniteSpiDiscoverySelfTestSuite.java | 2 + .../util/GridCommandHandlerAbstractTest.java | 19 +- .../ignite/util/mbeans/GridMBeanSelfTest.java | 16 +- ...mandHandlerClusterByClassTest_cache_help.output | 3 +- ...dlerClusterByClassWithSSLTest_cache_help.output | 3 +- .../apache/ignite/tests/p2p/P2PTestPredicate.java} | 51 +- modules/flume/README.txt | 48 -- modules/flume/licenses/apache-2.0.txt | 202 ------- modules/flume/pom.xml | 88 --- .../org/apache/ignite/stream/flume/IgniteSink.java | 196 ------- .../ignite/stream/flume/IgniteSinkConstants.java | 35 -- .../apache/ignite/stream/flume/package-info.java | 22 - .../apache/ignite/stream/flume/IgniteSinkTest.java | 139 ----- .../ignite/stream/flume/TestEventTransformer.java | 66 --- .../apache/ignite/stream/flume/package-info.java | 22 - .../flume/src/test/resources/example-ignite.xml | 71 --- .../hadoop/impl/v2/HadoopV2TaskContext.java | 3 +- .../external/HadoopExternalTaskExecutor.java | 5 +- .../HadoopIgfs20FileSystemAbstractSelfTest.java | 6 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 9 +- .../CacheHibernateStoreFactorySelfTest.java | 42 +- .../query/h2/DmlStatementsProcessor.java | 2 +- .../processors/query/h2/IgniteH2Indexing.java | 76 ++- .../query/h2/opt/GridLuceneInputStream.java | 4 +- .../query/h2/twostep/AbstractReducer.java | 3 +- .../processors/query/h2/twostep/ReduceIndex.java | 3 +- .../visor/verify/ValidateIndexesClosure.java | 524 ++++++++++++++---- .../visor/verify/VisorValidateIndexesTask.java | 3 +- .../cache/GridCacheFullTextQuerySelfTest.java | 3 +- .../cache/IgniteCacheQueryLoadSelfTest.java | 6 +- .../cache/index/AbstractIndexingCommonTest.java | 41 ++ .../cache/index/H2ConnectionLeaksSelfTest.java | 79 +-- .../db/IgniteCacheGroupsWithRestartsTest.java | 66 +++ ...xingMultithreadedLoadContinuousRestartTest.java | 2 +- .../db/LongDestroyDurableBackgroundTaskTest.java | 2 +- .../persistence/db/wal/IgniteWalRecoveryTest.java | 6 +- .../processors/database/RebuildIndexTest.java | 2 +- .../RebuildIndexWithHistoricalRebalanceTest.java | 2 +- .../query/h2/GridIndexFullRebuildTest.java | 2 +- .../h2/twostep/RetryCauseMessageSelfTest.java | 16 +- .../testsuites/IgniteCacheQuerySelfTestSuite6.java | 2 + ...teCacheWithIndexingAndPersistenceTestSuite.java | 2 + .../IgnitePdsWithIndexingCoreTestSuite.java | 2 + .../GridCommandHandlerIndexingCheckSizeTest.java | 547 +++++++++++++++++++ ...idCommandHandlerIndexingClusterByClassTest.java | 128 +---- .../util/GridCommandHandlerIndexingTest.java | 9 + .../util/GridCommandHandlerIndexingUtils.java | 297 ++++++++-- .../apache/ignite/logger/jcl/JclLoggerTest.java | 2 +- .../apache/ignite/stream/jms11/JmsStreamer.java | 9 +- .../ignite/stream/jms11/TestTransformers.java | 10 +- .../logger/log4j/GridLog4jLoggingFileTest.java | 2 +- .../Apache.Ignite.Benchmarks.csproj | 4 +- .../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 2 +- .../Apache.Ignite.Benchmarks/Config/benchmark.xml | 20 +- ...nchmark.cs => GetWithPlatformCacheBenchmark.cs} | 8 +- ...nchmark.cs => PutWithPlatformCacheBenchmark.cs} | 8 +- .../Interop/ScanQueryBenchmark.cs | 12 +- .../Apache.Ignite.Core.Tests.DotNetCore.csproj | 41 +- .../Apache.Ignite.Core.Tests.csproj | 17 +- .../Cache/NearCacheTest.cs | 179 ++++++ .../Cache/{Near => Platform}/FailingCacheStore.cs | 2 +- .../Cache/{Near => Platform}/Foo.cs | 2 +- .../PlatformCacheTest.cs} | 600 ++++++++++++++------- .../PlatformCacheTestCreateDestroy.cs} | 168 +----- .../PlatformCacheTopologyChangeTest.cs} | 124 ++--- .../ScanQueryNoPlatformCacheFilter.cs} | 10 +- .../ScanQueryPlatformCacheFilter.cs} | 28 +- .../StoreNoPlatformCacheFilter.cs} | 12 +- .../Cache/Query/CacheQueriesTest.cs | 70 +++ .../Config/full-config.xml | 2 +- .../IgniteConfigurationSerializerTest.cs | 10 +- .../Apache.Ignite.Core.Tests/IgniteUtilsTest.cs | 16 +- .../Log/CustomLoggerTest.cs | 9 + .../Services/ServiceProxyTest.cs | 2 +- .../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 15 +- .../Apache.Ignite.Core/Cache/CachePeekMode.cs | 8 +- .../Cache/Configuration/CacheConfiguration.cs | 23 +- ...figuration.cs => PlatformCacheConfiguration.cs} | 36 +- .../Cache/Query/IFieldsQueryCursor.cs | 5 + .../Cache/Query/IQueryCursorField.cs} | 41 +- .../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs | 28 +- .../IgniteConfigurationSection.xsd | 6 +- .../Impl/Binary/BinaryReaderExtensions.cs | 2 +- .../Apache.Ignite.Core/Impl/Binary/JavaTypes.cs | 3 +- .../Impl/Cache/CacheEntryFilterHolder.cs | 16 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 275 ++++++---- .../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 4 +- .../INearCache.cs => Platform/IPlatformCache.cs} | 15 +- .../NearCache.cs => Platform/PlatformCache.cs} | 45 +- .../PlatformCacheEntry.cs} | 10 +- .../PlatformCacheManager.cs} | 88 +-- .../Impl/Cache/Query/FieldsQueryCursor.cs | 29 +- .../Impl/Cache/Query/PlatformCacheQueryCursor.cs | 166 ++++++ .../Impl/Cache/Query/QueryCursorField.cs} | 41 +- .../Impl/Client/Cache/CacheClient.cs | 2 +- .../Client/Cache/Query/ClientFieldsQueryCursor.cs | 9 + .../Apache.Ignite.Core/Impl/Client/IgniteClient.cs | 4 +- .../Impl/Common/{Platform.cs => PlatformType.cs} | 2 +- .../Apache.Ignite.Core/Impl/IIgniteInternal.cs | 6 +- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 34 +- .../dotnet/Apache.Ignite.Core/Impl/IgniteUtils.cs | 12 +- .../Impl/Services/ServiceDescriptor.cs | 4 +- .../Impl/Services/ServiceProxySerializer.cs | 6 +- .../Apache.Ignite.Core/Impl/Services/Services.cs | 10 +- .../Impl/Unmanaged/UnmanagedCallbackOp.cs | 4 +- .../Impl/Unmanaged/UnmanagedCallbacks.cs | 20 +- .../Datagrid/NearCacheExample.cs | 10 +- .../apache/ignite/stream/storm/StormStreamer.java | 15 +- .../apache/ignite/stream/storm/TestStormSpout.java | 27 +- modules/tools/pom.xml | 5 + .../OverrideAnnotationOnTheSameLineCheck.java | 100 ++++ .../ignite/stream/twitter/TwitterStreamer.java | 3 +- .../deployment/uri/GridUriDeploymentDiscovery.java | 4 +- .../uri/GridUriDeploymentJarVerifier.java | 10 +- .../deployment/uri/GridUriDeploymentUriParser.java | 2 +- .../testsuites/IgniteUriDeploymentTestSuite.java | 4 +- modules/zeromq/README.txt | 37 -- modules/zeromq/licenses/apache-2.0.txt | 202 ------- modules/zeromq/pom.xml | 75 --- .../ignite/stream/zeromq/IgniteZeroMqStreamer.java | 151 ------ .../apache/ignite/stream/zeromq/package-info.java | 21 - .../stream/zeromq/IgniteZeroMqStreamerTest.java | 262 --------- .../zeromq/ZeroMqStringSingleTupleExtractor.java | 46 -- .../apache/ignite/stream/zeromq/package-info.java | 21 - parent/pom.xml | 8 +- pom.xml | 2 - 310 files changed, 8125 insertions(+), 4820 deletions(-) create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/UnionAllNode.java copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/{IgniteReceiver.java => IgniteUnionAll.java} (52%) create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionTraitsTraitsPropagationRule.java create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/serialize/UnionAllPhysicalRel.java rename modules/core/src/main/java/org/apache/ignite/configuration/{PlatformNearCacheConfiguration.java => PlatformCacheConfiguration.java} (81%) copy modules/core/src/main/java/org/apache/ignite/events/{ClusterActivationEvent.java => ClusterStateChangeStartedEvent.java} (71%) rename modules/{flume/src/test/java/org/apache/ignite/stream/flume/IgniteSinkTestSuite.java => core/src/main/java/org/apache/ignite/internal/processors/cache/IgnitePeerToPeerClassLoadingException.java} (64%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/MetastorageBPlusIO.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/MetastorageInnerIO.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/MetastorageLeafIO.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/MetastoragePageIOUtils.java rename modules/{zeromq/src/test/java/org/apache/ignite/stream/zeromq/IgniteZeroMqStreamerTestSuite.java => core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/MetastorageRow.java} (65%) rename modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/{MetsatorageSearchRowImpl.java => MetastorageRowStoreEntry.java} (56%) create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/ValidateIndexesCheckSizeIssue.java create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/verify/ValidateIndexesCheckSizeResult.java create mode 100644 modules/core/src/test/java/org/apache/ignite/events/ClusterActivationStartedEventTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/WalOnNodeStartTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFilterDeploymentFailedTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxOptimisticReadThroughTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/p2p/ClassLoadingProblemExceptionTest.java create mode 100644 modules/core/src/test/java/org/apache/ignite/platform/PlatformIsPartitionReservedTask.java create mode 100644 modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMetricsWarnLogTest.java rename modules/{zeromq/src/main/java/org/apache/ignite/stream/zeromq/ZeroMqTypeSocket.java => extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/P2PTestPredicate.java} (50%) delete mode 100644 modules/flume/README.txt delete mode 100644 modules/flume/licenses/apache-2.0.txt delete mode 100644 modules/flume/pom.xml delete mode 100644 modules/flume/src/main/java/org/apache/ignite/stream/flume/IgniteSink.java delete mode 100644 modules/flume/src/main/java/org/apache/ignite/stream/flume/IgniteSinkConstants.java delete mode 100644 modules/flume/src/main/java/org/apache/ignite/stream/flume/package-info.java delete mode 100644 modules/flume/src/test/java/org/apache/ignite/stream/flume/IgniteSinkTest.java delete mode 100644 modules/flume/src/test/java/org/apache/ignite/stream/flume/TestEventTransformer.java delete mode 100644 modules/flume/src/test/java/org/apache/ignite/stream/flume/package-info.java delete mode 100644 modules/flume/src/test/resources/example-ignite.xml create mode 100644 modules/indexing/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingCheckSizeTest.java rename modules/platforms/dotnet/Apache.Ignite.Benchmarks/Interop/{GetNearBenchmark.cs => GetWithPlatformCacheBenchmark.cs} (86%) rename modules/platforms/dotnet/Apache.Ignite.Benchmarks/Interop/{PutNearBenchmark.cs => PutWithPlatformCacheBenchmark.cs} (85%) create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/NearCacheTest.cs rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near => Platform}/FailingCacheStore.cs (97%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near => Platform}/Foo.cs (97%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/CacheNearTest.cs => Platform/PlatformCacheTest.cs} (70%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/CacheNearCreateDestroy.cs => Platform/PlatformCacheTestCreateDestroy.cs} (57%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/CacheNearTopologyChangeTest.cs => Platform/PlatformCacheTopologyChangeTest.cs} (86%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/ScanQueryNoNearCacheFilter.cs => Platform/ScanQueryNoPlatformCacheFilter.cs} (79%) rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/ScanQueryNearCacheFilter.cs => Platform/ScanQueryPlatformCacheFilter.cs} (58%) copy modules/platforms/dotnet/Apache.Ignite.Core.Tests/Cache/{Near/StoreNoNearCacheFilter.cs => Platform/StoreNoPlatformCacheFilter.cs} (81%) rename modules/platforms/dotnet/Apache.Ignite.Core/Cache/Configuration/{PlatformNearCacheConfiguration.cs => PlatformCacheConfiguration.cs} (55%) rename modules/{flume/src/main/java/org/apache/ignite/stream/flume/EventTransformer.java => platforms/dotnet/Apache.Ignite.Core/Cache/Query/IQueryCursorField.cs} (56%) rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/{Near/INearCache.cs => Platform/IPlatformCache.cs} (84%) rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/{Near/NearCache.cs => Platform/PlatformCache.cs} (82%) rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/{Near/NearCacheEntry.cs => Platform/PlatformCacheEntry.cs} (90%) rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/{Near/NearCacheManager.cs => Platform/PlatformCacheManager.cs} (63%) create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Cache/Query/PlatformCacheQueryCursor.cs rename modules/platforms/dotnet/{Apache.Ignite.Core.Tests/Cache/Near/StoreNoNearCacheFilter.cs => Apache.Ignite.Core/Impl/Cache/Query/QueryCursorField.cs} (50%) rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Common/{Platform.cs => PlatformType.cs} (97%) create mode 100644 modules/tools/src/main/java/org/apache/ignite/tools/checkstyle/OverrideAnnotationOnTheSameLineCheck.java delete mode 100644 modules/zeromq/README.txt delete mode 100644 modules/zeromq/licenses/apache-2.0.txt delete mode 100644 modules/zeromq/pom.xml delete mode 100644 modules/zeromq/src/main/java/org/apache/ignite/stream/zeromq/IgniteZeroMqStreamer.java delete mode 100644 modules/zeromq/src/main/java/org/apache/ignite/stream/zeromq/package-info.java delete mode 100644 modules/zeromq/src/test/java/org/apache/ignite/stream/zeromq/IgniteZeroMqStreamerTest.java delete mode 100644 modules/zeromq/src/test/java/org/apache/ignite/stream/zeromq/ZeroMqStringSingleTupleExtractor.java delete mode 100644 modules/zeromq/src/test/java/org/apache/ignite/stream/zeromq/package-info.java