This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-19499
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 0e4ff15d27 Use sync service instead of configuration.
omit cb5d1b2c45 Plug SchemaSyncService in.
add c87284c92a IGNITE-20219 Fix the typo of user name to username (#2451)
add 40d611dea0 IGNITE-20230
ItRebalanceDistributedTest#testDestroyPartitionStoragesOnEvictNode fixed.
(#2477)
add b191cf8c42 IGNITE-19983 C++: Support BOOLEAN datatype (#2481)
add 4a5b7357d6 IGNITE-19995
PendingComparableValuesTrackerTest#testMultithreadedWaitFor fails with
ConcurrentModificationException (#2482)
add d15b975b97 IGNITE-19542 .NET: Add BinaryTupleIgniteTupleAdapter (#2479)
add b43f754626 Merge branch 'main' into catalog-feature
add 18d79f347d IGNITE-20246 Sql. Decouple distribution trait and function
(#2463)
add 393f6700bc Merge branch 'main' into catalog-feature
add d748e48ed4 IGNITE-19951 Enable checks of using NotNull annotation.
(#2468)
add 6404013215 IGNITE-20104 Sql. Improve error messages from Sql parser
(#2460)
add 19f158ceff IGNITE-20185 Sql. Fix missed casting rules (#2431)
add df5734462d IGNITE-19992 Sql. Rework execution of 2-phase set operators
(#2443)
add fe84f76259 IGNITE-20270 Improve RocksDB iterator performance (#2487)
add f9bfb52907 IGNITE-19570 Write intent resolution for RW transactions
(#2475)
add 73150f1b45 IGNITE-20155 Validate BinaryTuple coming from client (#2491)
add 18f67c8fe2 IGNITE-20271 Error in CLI on SQL repl command (#2486)
add 0f92a9a12c IGNITE-20276: Include tests into run PMD configuration
(#2492)
add 5af9efd7a1 Merge branch 'main' into catalog-feature
add 1641950030 IGNITE-20265 Check and slightly refactor the validation of
tables and indexes in the catalog (#2485)
add 7516682142 IGNITE-20086 Add Arch Test to validate Mockito resources
are cleaned up (#2378)
add 6666f36614 Merge branch 'main' into catalog-feature
add 2465c3b1da Resolve conflicts after merge with main.
new f3f59234ce Plug SchemaSyncService in.
new f034d2cad9 Use sync service instead of configuration.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0e4ff15d27)
\
N -- N -- N refs/heads/ignite-19499 (f034d2cad9)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
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:
.run/PMD [pmdMain].run.xml | 5 +-
buildscripts/java-core.gradle | 2 +-
buildscripts/sql-parser-generator.gradle | 2 +-
check-rules/pmd-rules.xml | 19 ++
gradle/libs.versions.toml | 4 +-
.../affinity/RendezvousAffinityFunctionTest.java | 2 -
.../main/java/org/apache/ignite/sql/Statement.java | 19 +-
.../java/org/apache/ignite/table/KeyValueView.java | 77 +++--
.../java/org/apache/ignite/table/RecordView.java | 57 ++--
.../main/java/org/apache/ignite/table/Table.java | 3 +-
.../main/java/org/apache/ignite/table/Tuple.java | 29 +-
.../java/org/apache/ignite/table/TupleImpl.java | 31 +-
.../org/apache/ignite/table/mapper/Mapper.java | 17 +-
.../apache/ignite/table/mapper/MapperBuilder.java | 17 +-
.../ignite/table/mapper/OneColumnMapperImpl.java | 3 +-
.../org/apache/ignite/table/mapper/PojoMapper.java | 5 +-
.../apache/ignite/table/mapper/PojoMapperImpl.java | 7 +-
modules/arch-test/build.gradle | 2 +
.../internal/TestClassHierarchyArchTest.java | 62 ++++
.../apache/ignite/lang/IgniteTestImportOption.java | 8 +-
.../internal/catalog/CatalogManagerImpl.java | 103 +++----
.../catalog/CatalogParamsValidationUtils.java | 67 +++-
....java => AbstractCreateIndexCommandParams.java} | 94 ++----
.../commands/AbstractIndexCommandParams.java | 88 ++----
.../catalog/commands/CreateHashIndexParams.java | 36 +--
.../catalog/commands/CreateSortedIndexParams.java | 43 +--
.../internal/catalog/commands/DropIndexParams.java | 71 +----
.../internal/catalog/CatalogManagerSelfTest.java | 185 ++++++-----
.../catalog/CatalogManagerValidationTest.java | 103 +++++++
.../catalog/storage/UpdateLogImplTest.java | 3 +-
.../internal/catalog/BaseCatalogManagerTest.java | 68 ++++
modules/cli/build.gradle | 1 +
...tConnectWithBasicAuthenticationCommandTest.java | 8 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 5 +
.../handler/IgniteCliApiExceptionHandler.java | 2 -
.../cli/config/ini/IniConfigManagerTest.java | 2 +-
.../handler/IgniteCliApiExceptionHandlerTest.java | 3 +-
.../table/MutableTupleBinaryTupleAdapter.java | 35 +--
.../proto/ClientMessagePackerUnpackerTest.java | 3 +-
.../client/handler/ItClientHandlerMetricsTest.java | 3 +-
.../ignite/client/handler/ItClientHandlerTest.java | 3 +-
.../client/handler/ItSslClientHandlerTest.java | 3 +-
.../ignite/client/handler/ClientResource.java | 3 +-
.../handler/requests/table/ClientTableCommon.java | 2 -
.../client/handler/requests/table/ClientTuple.java | 5 +-
.../ignite/internal/client/sql/ClientSqlRow.java | 7 +-
.../internal/client/sql/ClientStatement.java | 7 +-
.../client/sql/ClientStatementBuilder.java | 13 +-
.../internal/client/table/ClientDataStreamer.java | 2 -
.../client/table/ClientKeyValueBinaryView.java | 77 +++--
.../internal/client/table/ClientKeyValueView.java | 81 +++--
.../client/table/ClientRecordBinaryView.java | 57 ++--
.../client/table/ClientRecordSerializer.java | 5 +-
.../internal/client/table/ClientRecordView.java | 57 ++--
.../ignite/internal/client/table/ClientSchema.java | 5 +-
.../ignite/internal/client/table/ClientTable.java | 3 +-
.../ignite/internal/client/table/ClientTuple.java | 5 +-
.../client/table/ClientTupleSerializer.java | 19 +-
.../internal/client/tx/ClientTransaction.java | 3 +-
.../internal/client/tx/ClientTransactions.java | 2 -
.../java/org/apache/ignite/client/CustomTuple.java | 30 +-
.../client/ObservableTimestampPropagationTest.java | 3 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 2 -
.../ignite/client/fakes/FakeIgniteTables.java | 2 -
.../ignite/client/fakes/FakeSchemaRegistry.java | 2 -
.../org/apache/ignite/client/fakes/FakeSqlRow.java | 32 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 3 +-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../AbstractClusterStateStorageManagerTest.java | 2 +-
.../ignite/internal/deployunit/UnitContent.java | 2 -
.../metastore/DeploymentUnitStoreImplTest.java | 3 +-
.../deployunit/DeploymentUnitAccessorImplTest.java | 3 +-
.../DeploymentUnitAcquiredWaiterTest.java | 5 +-
.../compute/JobExecutionContextImplTest.java | 3 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 3 +-
.../compute/loader/JobClassLoaderTest.java | 3 +-
.../configuration/asm/DirectProxyAsmGenerator.java | 2 -
.../configuration/hocon/HoconConverter.java | 3 +-
.../configuration/util/ConfigurationFlattener.java | 3 +-
.../testframework/ConfigurationExtensionTest.java | 3 +-
.../tree/ConverterToMapVisitorTest.java | 3 +-
.../configuration/util/ConfigurationUtilTest.java | 2 -
.../validation/ConfigurationValidatorImplTest.java | 3 +-
.../validation/OneOfValidatorTest.java | 3 +-
.../validation/PowerOfTwoValidatorTest.java | 3 +-
.../validation/RangeValidatorTest.java | 3 +-
.../storage/TestConfigurationStorage.java | 3 +-
.../ignite/internal/logger/IgniteLogger.java | 3 +-
.../ignite/internal/manager/EventListener.java | 5 +-
.../thread/AbstractStripedThreadPoolExecutor.java | 7 -
.../internal/tostring/IgniteToStringBuilder.java | 3 +-
.../ignite/internal/util/FilteringIterator.java | 5 +-
.../apache/ignite/internal/util/GridUnsafe.java | 10 +-
.../PendingIndependentComparableValuesTracker.java | 4 +-
.../apache/ignite/internal/HybridClockTest.java | 3 +-
.../causality/CompletableVersionedValueTest.java | 3 +-
.../causality/IncrementalVersionedValueTest.java | 3 +-
.../ignite/internal/manager/ProducerTest.java | 5 +-
.../apache/ignite/internal/util/CursorTest.java | 3 +-
.../ignite/internal/util/IgniteUtilsTest.java | 7 +-
.../util/PendingComparableValuesTrackerTest.java | 3 -
.../internal/util/RefCountedObjectPoolTest.java | 2 +-
.../subscription/TransformingPublisherTest.java | 3 +-
.../distributionzones/rebalance/RebalanceUtil.java | 3 +-
.../DistributionZoneMockTest.java | 3 +-
.../DistributionZoneCausalityDataNodesTest.java | 3 -
.../internal/network/file/ItFileTransferTest.java | 3 +-
.../internal/network/file/FileSenderTest.java | 3 +-
.../network/file/FileTransferServiceImplTest.java | 3 +-
.../ignite/internal/index/IndexManagerTest.java | 3 +-
modules/jdbc/build.gradle | 1 +
.../apache/ignite/jdbc/ItJdbcErrorsSelfTest.java | 6 +-
.../internal/jdbc/ConnectionPropertiesImpl.java | 2 -
.../internal/jdbc/PreparedStatementParamsTest.java | 3 +-
.../ignite/internal/marshaller/Marshaller.java | 7 +-
.../TestObjectWithNoDefaultConstructor.java | 4 +
modules/metastorage/build.gradle | 1 +
.../server/AbstractCompoundCondition.java | 3 +-
.../server/AbstractSimpleCondition.java | 11 +-
.../metastorage/server/ExistenceCondition.java | 6 +-
.../metastorage/server/RevisionCondition.java | 6 +-
.../metastorage/server/TombstoneCondition.java | 5 +-
.../ignite/internal/metastorage/server/Value.java | 4 +-
.../metastorage/server/ValueCondition.java | 7 +-
.../impl/MetaStorageManagerRecoveryTest.java | 3 +-
.../metastorage/impl/MetaStorageRangeTest.java | 3 +-
.../metastorage/server/OrConditionTest.java | 3 +-
.../metastorage/server/time/ClusterTimeTest.java | 3 +-
.../server/AbstractKeyValueStorageTest.java | 3 +-
modules/metrics/build.gradle | 1 +
.../metrics/exporters/ItJvmMetricSourceTest.java | 3 +-
.../exporters/ItMetricExportersLoadingTest.java | 3 +-
.../ignite/internal/metrics/MetricManager.java | 2 -
.../ignite/internal/metrics/MetricRegistry.java | 8 +-
.../ignite/internal/metrics/JmxExporterTest.java | 3 +-
.../internal/metrics/MetricConfigurationTest.java | 3 +-
modules/network-annotation-processor/build.gradle | 1 +
.../network/processor/tests/GenerationTest.java | 3 +-
.../network/netty/ItConnectionManagerTest.java | 3 +-
.../network/scalecube/ItClusterServiceTest.java | 3 +-
.../network/netty/InboundRecoveryHandler.java | 3 +-
.../serialization/marshal/BuiltInMarshalling.java | 2 -
.../SslConfigurationValidatorImplTest.java | 3 +-
.../netty/IoExceptionSuppressingHandlerTest.java | 3 +-
.../network/processor/InheritedMessageTest.java | 3 +-
.../network/processor/SerializationOrderTest.java | 3 +-
...TransferableObjectProcessorIncrementalTest.java | 3 +-
.../network/recovery/VaultStateIdsTest.java | 3 +-
.../serialization/ClassDescriptorMergerTest.java | 3 +-
.../network/serialization/MarshallableTest.java | 3 +-
.../marshal/BestEffortInstantiationTest.java | 3 +-
.../marshal/DefaultSchemaMismatchHandlerTest.java | 3 +-
.../DefaultUserObjectMarshallerCommonTest.java | 2 +-
...erObjectMarshallerWithArbitraryObjectsTest.java | 3 -
...ltUserObjectMarshallerWithSchemaChangeTest.java | 3 +-
...ltUserObjectMarshallerWithSerializableTest.java | 14 -
.../marshal/SerializableInstantiationTest.java | 3 +-
.../network/ssl/SslContextProviderTest.java | 3 +-
.../network/AbstractMessagingServiceTest.java | 3 +-
.../network/DefaultMessagingServiceTest.java | 3 +-
.../MessageSerializationRegistryImplTest.java | 3 +-
.../persistence/PartitionMetaManagerTest.java | 3 +-
.../AwaitTasksCompletionExecutorTest.java | 3 +-
.../checkpoint/CheckpointDirtyPagesTest.java | 3 +-
.../checkpoint/CheckpointManagerTest.java | 3 +-
.../checkpoint/CheckpointPagesWriterTest.java | 3 +-
.../persistence/checkpoint/CheckpointTest.java | 3 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 7 +-
.../checkpoint/CheckpointWorkflowTest.java | 7 +-
.../persistence/checkpoint/CheckpointerTest.java | 3 +-
.../ReentrantReadWriteLockWithTrackingTest.java | 6 +-
.../persistence/compaction/CompactorTest.java | 7 +-
.../store/AbstractFilePageStoreIoTest.java | 3 +-
.../store/FilePageStoreManagerTest.java | 3 +-
.../persistence/store/FilePageStoreTest.java | 3 +-
.../persistence/store/GroupPageStoresMapTest.java | 3 +-
.../pagememory/util/GradualTaskExecutorTest.java | 3 +-
.../placementdriver/PlacementDriverTest.java | 3 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 6 +
modules/platforms/cpp/ignite/protocol/utils.cpp | 4 +-
.../cpp/tests/client-test/all_fields_type.h | 3 +
.../client-test/key_value_binary_view_test.cpp | 1 +
.../cpp/tests/client-test/key_value_view_test.cpp | 2 +
.../tests/client-test/record_binary_view_test.cpp | 1 +
.../cpp/tests/client-test/record_view_test.cpp | 2 +
.../platforms/cpp/tests/client-test/sql_test.cpp | 11 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 2 +-
.../cpp/tests/odbc-test/odbc_connection.h | 2 +-
.../platforms/cpp/tests/odbc-test/queries_test.cpp | 22 +-
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 4 +-
.../SerializerHandlerReadBenchmarks.cs | 55 ++--
.../Linq/LinqSqlGenerationTests.cs | 4 +-
.../Linq/LinqTests.Aggregate.cs | 22 +-
.../Apache.Ignite.Tests/Linq/LinqTests.GroupBy.cs | 22 +-
.../Apache.Ignite.Tests/Linq/LinqTests.KvView.cs | 22 +-
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 2 +-
.../Sql/IgniteDbDataReaderTests.cs | 4 +-
.../Table/BinaryTupleIgniteTupleAdapterTests.cs | 111 +++++++
.../Apache.Ignite.Tests/Table/IgniteTupleTests.cs | 36 ++-
.../Apache.Ignite.Tests/Table/PocoAllColumnsSql.cs | 10 +-
.../Table/PocoAllColumnsSqlNullable.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/ToStringTests.cs | 3 +-
.../BinaryTuple/BinaryTupleIgniteTupleAdapter.cs | 143 +++++++++
.../IgniteTupleCommon.cs} | 32 +-
.../Table/Serialization/TupleSerializerHandler.cs | 41 ++-
.../dotnet/Apache.Ignite/Table/IIgniteTuple.cs | 18 ++
.../dotnet/Apache.Ignite/Table/IgniteTuple.cs | 53 +---
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 3 +-
.../ignite/raft/jraft/core/ItCliServiceTest.java | 3 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 125 ++++----
.../raft/server/ItJraftCounterServerTest.java | 2 -
.../raft/jraft/disruptor/DisruptorBuilder.java | 1 -
.../ignite/raft/jraft/option/NodeOptions.java | 7 +-
.../raft/jraft/util/StorageOptionsFactory.java | 2 -
.../raft/JraftGroupEventsListenerTest.java | 3 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 2 -
.../impl/RocksDbSharedLogStorageAdvancedTest.java | 3 +-
.../raft/jraft/conf/ConfigurationEntryTest.java | 3 +-
.../raft/jraft/conf/ConfigurationManagerTest.java | 3 +-
.../ignite/raft/jraft/core/BallotBoxTest.java | 3 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 3 +-
.../ignite/raft/jraft/core/IteratorImplTest.java | 3 +-
.../ignite/raft/jraft/core/IteratorTest.java | 3 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 3 +-
.../raft/jraft/core/ReplicatorGroupTest.java | 14 +-
.../ignite/raft/jraft/core/ReplicatorTest.java | 3 +-
.../entity/codec/BaseLogEntryCodecFactoryTest.java | 12 +-
.../raft/jraft/rpc/AbstractClientServiceTest.java | 3 +-
.../jraft/rpc/impl/PingRequestProcessorTest.java | 3 +-
.../impl/cli/AbstractCliRequestProcessorTest.java | 3 +-
.../rpc/impl/cli/BaseCliRequestProcessorTest.java | 5 +-
.../impl/core/BaseNodeRequestProcessorTest.java | 3 +-
.../rpc/impl/core/NodeRequestProcessorTest.java | 3 +-
.../ignite/raft/jraft/storage/BaseStorageTest.java | 3 +-
.../ignite/raft/jraft/storage/FileServiceTest.java | 9 +-
.../impl/VolatileLogStorageSpecificsTest.java | 3 +-
.../storage/snapshot/remote/CopySessionTest.java | 3 +-
.../snapshot/remote/RemoteFileCopierTest.java | 3 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 3 +-
.../client/TopologyAwareRaftGroupServiceTest.java | 3 -
modules/rest-api/build.gradle | 1 +
.../handler/IgniteExceptionHandlerTest.java | 3 +-
.../ConfigurationControllerBaseTest.java | 2 -
modules/rocksdb-common/build.gradle | 1 +
.../ignite/internal/rocksdb/ColumnFamily.java | 11 +-
.../ignite/internal/rocksdb/RocksUtilsTest.java | 3 +-
modules/runner/README.md | 2 +-
.../ItDistributedConfigurationPropertiesTest.java | 3 +-
.../ItDistributedConfigurationStorageTest.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 25 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 12 +-
.../rest/authentication/ItAuthenticationTest.java | 3 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 49 +++
.../runner/app/PlatformTestNodeRunner.java | 12 +-
.../app/client/ItThinClientMarshallingTest.java | 49 +++
.../ignite/internal/sql/api/ItCommonApiTest.java | 6 -
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 4 +-
.../internal/sql/engine/ItDataTypesTest.java | 2 -
.../ignite/internal/sql/engine/ItIntervalTest.java | 36 +--
.../ignite/internal/sql/engine/ItSetOpTest.java | 123 ++++++--
.../internal/sql/engine/ItSqlOperatorsTest.java | 6 +-
.../sql/engine/datatypes/DataTypeTestSpecs.java | 10 +-
.../datatypes/tests/BaseDmlDataTypeTest.java | 21 ++
.../tests/BaseExpressionDataTypeTest.java | 11 +
.../datatypes/tests/BaseQueryDataTypeTest.java | 6 +
.../engine/datatypes/tests/TestTypeArguments.java | 2 +
.../varbinary/ItVarBinaryExpressionTest.java | 12 -
.../apache/ignite/internal/sqllogic/Script.java | 2 -
.../sql/aggregate/having/test_having.test | 6 +-
.../integrationTest/sql/subquery/test_neumann.test | 6 +-
.../integrationTest/sql/types/blob/test_blob.test | 34 +-
.../sql/types/blob/test_blob_cast.test | 20 +-
.../sql/types/blob/test_blob_function.test | 27 +-
.../sql/types/blob/test_blob_operator.test | 45 +--
.../sql/types/blob/test_blob_string.test | 2 +-
.../types/timestamp/test_incorrect_timestamp.test | 30 +-
.../sql/types/timestamp/test_timestamp.test | 26 +-
.../internal/configuration/CompoundModuleTest.java | 3 +-
.../configuration/ConfigurationModulesTest.java | 3 +-
.../DistributedConfigurationUpdaterTest.java | 3 +-
.../ignite/internal/sql/engine/util/VarBinary.java | 3 +-
.../org/apache/ignite/internal/schema/Column.java | 3 +-
.../apache/ignite/internal/schema/NativeType.java | 3 +-
.../ignite/internal/schema/NativeTypeSpec.java | 2 +-
.../apache/ignite/internal/schema/NativeTypes.java | 3 +-
.../ignite/internal/schema/SchemaDescriptor.java | 3 +-
.../internal/schema/mapping/ColumnMapper.java | 3 +-
.../internal/schema/mapping/ColumnMapperImpl.java | 3 +-
.../internal/schema/mapping/ColumnMapping.java | 3 +-
.../internal/schema/marshaller/KvMarshaller.java | 9 +-
.../internal/schema/marshaller/MarshallerUtil.java | 3 +-
.../schema/marshaller/RecordMarshaller.java | 7 +-
.../marshaller/reflection/ColumnBinding.java | 8 +-
.../marshaller/reflection/KvMarshallerImpl.java | 12 +-
.../schema/marshaller/reflection/Marshaller.java | 7 +-
.../reflection/RecordMarshallerImpl.java | 10 +-
.../reflection/ReflectionMarshallerFactory.java | 5 +-
.../schema/AbstractSchemaConverterTest.java | 3 +-
.../internal/schema/CatalogSchemaManagerTest.java | 3 +-
.../configuration/TableValidatorImplTest.java | 3 +-
.../index/IndexValidatorImplTest.java | 3 +-
.../schema/marshaller/KvMarshallerTest.java | 2 +-
.../schema/registry/UpgradingRowAdapterTest.java | 3 +-
.../AuthenticationConfigurationValidatorTest.java | 3 +-
.../AuthenticationProvidersValidatorTest.java | 3 +-
.../AuthenticationManagerImplTest.java | 3 +-
modules/sql-engine/src/main/codegen/config.fmpp | 109 -------
.../src/main/codegen/includes/parserImpls.ftl | 8 +-
.../internal/sql/api/AsyncResultSetImpl.java | 31 +-
.../internal/sql/api/StatementBuilderImpl.java | 13 +-
.../ignite/internal/sql/api/StatementImpl.java | 7 +-
.../sql/engine/exec/DestinationFactory.java | 110 +++++++
.../internal/sql/engine/exec/ExecutableTable.java | 6 +
.../engine/exec/ExecutableTableRegistryImpl.java | 6 +
.../engine/exec/ExecutionDependencyResolver.java | 3 +-
.../exec/ExecutionDependencyResolverImpl.java | 37 ++-
.../sql/engine/exec/ExecutionServiceImpl.java | 12 +-
.../sql/engine/exec/LogicalRelImplementor.java | 45 ++-
.../sql/engine/exec/ResolvedDependencies.java | 9 +
.../internal/sql/engine/exec/RuntimeHashIndex.java | 2 -
.../sql/engine/exec/TableFunctionScan.java | 2 -
.../exec/ddl/DdlToCatalogCommandConverter.java | 4 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 4 -
.../sql/engine/exec/rel/AbstractSetOpNode.java | 170 ++++++----
.../sql/engine/exec/rel/IntersectNode.java | 97 +++++-
.../sql/engine/exec/rel/MergeJoinNode.java | 2 -
.../internal/sql/engine/exec/rel/MinusNode.java | 94 +++++-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 2 -
.../internal/sql/engine/exec/rel/SingleNode.java | 5 +-
.../internal/sql/engine/exec/row/BaseTypeSpec.java | 2 +-
.../internal/sql/engine/externalize/RelJson.java | 24 +-
.../sql/engine/metadata/ColocationGroup.java | 2 -
.../sql/engine/metadata/FragmentMapping.java | 3 +-
.../sql/engine/prepare/PlanningContext.java | 5 +-
.../engine/rel/set/IgniteColocatedIntersect.java | 9 +
.../sql/engine/rel/set/IgniteColocatedMinus.java | 9 +
.../sql/engine/rel/set/IgniteMapIntersect.java | 17 +-
.../sql/engine/rel/set/IgniteMapMinus.java | 12 +-
.../sql/engine/rel/set/IgniteMapSetOp.java | 32 +-
.../internal/sql/engine/rel/set/IgniteMinus.java | 10 +-
.../sql/engine/rel/set/IgniteMinusBase.java | 104 -------
.../sql/engine/rel/set/IgniteReduceIntersect.java | 18 +-
.../sql/engine/rel/set/IgniteReduceMinus.java | 12 +-
.../sql/engine/rule/SetOpConverterRule.java | 3 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 103 ++++++-
.../sql/engine/trait/DistributionFunction.java | 73 -----
.../sql/engine/trait/DistributionTrait.java | 8 -
.../sql/engine/trait/IgniteDistribution.java | 11 -
.../ignite/internal/sql/engine/util/Commons.java | 9 +-
.../sql/engine/util/HashFunctionFactory.java | 6 +-
.../sql/engine/util/HashFunctionFactoryImpl.java | 14 +-
.../engine/util/IgniteCustomAssigmentsRules.java | 104 ++++---
.../internal/sql/engine/util/IgniteResource.java | 14 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 9 +-
.../apache/ignite/internal/sql/engine/TestRow.java | 2 -
.../exec/ExecutableTableRegistrySelfTest.java | 3 +-
.../exec/ExecutionDependencyResolverSelfTest.java | 7 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 15 +-
.../engine/exec/TestExecutableTableRegistry.java | 6 +
.../sql/engine/exec/rel/AbstractExecutionTest.java | 2 -
.../exec/rel/AbstractSetOpExecutionTest.java | 20 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 3 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 2 +-
.../engine/exec/rel/IntersectExecutionTest.java | 4 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 4 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 3 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 3 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 3 +-
.../sql/engine/framework/NoOpTransaction.java | 3 +-
.../sql/engine/framework/TestBuilders.java | 7 +-
.../sql/engine/framework/TestClusterTest.java | 3 +-
.../internal/sql/engine/framework/TestNode.java | 3 +-
.../sql/engine/planner/CastResolutionTest.java | 311 ++++++++++++++-----
.../sql/engine/planner/DmlPlannerTest.java | 14 +-
.../sql/engine/planner/DynamicParametersTest.java | 10 +-
.../engine/schema/CatalogSqlSchemaManagerTest.java | 3 +-
.../engine/sql/IgniteSqlDecimalLiteralTest.java | 10 -
.../sql/engine/sql/IgniteSqlParserTest.java | 61 +++-
.../sql/engine/sql/SqlReservedWordsTest.java | 117 ++++++-
.../internal/sql/engine/util/TypeUtilsTest.java | 3 +-
modules/sql-engine/src/test/resources/tpch/q11.sql | 4 +-
.../internal/storage/DataStorageManagerTest.java | 3 +-
.../internal/storage/DataStorageModulesTest.java | 3 +-
.../internal/storage/util/LockHolderTest.java | 4 +-
.../storage/util/MvPartitionStoragesTest.java | 3 +-
.../internal/storage/BaseMvStoragesTest.java | 3 +-
.../storage/index/AbstractIndexStorageTest.java | 7 +-
.../PersistentPageMemoryDataRegionTest.java | 3 +-
.../PageMemoryDataRegionValidatorImplTest.java | 3 +-
.../storage/pagememory/index/InlineUtilsTest.java | 3 +-
.../storage/pagememory/mv/BlobStorageTest.java | 3 +-
.../storage/rocksdb/PartitionDataHelper.java | 4 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 23 +-
.../instance/SharedRocksDbInstanceCreator.java | 12 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 3 +-
.../RocksDbDataRegionValidatorImplTest.java | 3 +-
.../schema/marshaller/TupleMarshaller.java | 7 +-
.../schema/marshaller/TupleMarshallerImpl.java | 35 ++-
.../internal/table/AbstractRowTupleAdapter.java | 29 +-
.../apache/ignite/internal/table/DataStreamer.java | 2 -
.../internal/table/KeyValueBinaryViewImpl.java | 85 +++--
.../ignite/internal/table/KeyValueViewImpl.java | 81 +++--
.../internal/table/MutableRowTupleAdapter.java | 33 +-
.../internal/table/RecordBinaryViewImpl.java | 59 ++--
.../ignite/internal/table/RecordViewImpl.java | 59 ++--
.../org/apache/ignite/internal/table/TableRow.java | 13 +-
.../internal/table/distributed/TableManager.java | 5 +-
.../table/distributed/raft/PartitionListener.java | 2 +-
.../replicator/PartitionReplicaListener.java | 343 ++++++++++-----------
.../table/ColocationHashCalculationTest.java | 3 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 2 -
.../internal/table/KeyValueViewOperationsTest.java | 6 +-
.../internal/table/MutableRowTupleAdapterTest.java | 2 -
.../table/RecordBinaryViewOperationsTest.java | 2 -
.../internal/table/RecordViewOperationsTest.java | 3 -
.../RepeatedFinishReadWriteTransactionTest.java | 3 +-
.../distributed/ConfiguredTablesCacheTest.java | 3 +-
.../table/distributed/LowWatermarkTest.java | 3 +-
.../table/distributed/PartitionMoverTest.java | 3 +-
.../distributed/StorageUpdateHandlerTest.java | 3 +-
.../table/distributed/TableManagerTest.java | 2 +-
.../internal/table/distributed/gc/MvGcTest.java | 3 +-
.../distributed/index/IndexUpdateHandlerTest.java | 3 +-
.../raft/PartitionCommandListenerTest.java | 3 +-
.../raft/snapshot/PartitionAccessImplTest.java | 3 +-
.../PartitionSnapshotStorageFactoryTest.java | 3 +-
.../snapshot/PartitionSnapshotStorageTest.java | 3 +-
.../incoming/IncomingSnapshotCopierTest.java | 3 +-
.../incoming/IncomingSnapshotReaderTest.java | 3 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 3 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 3 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 3 +-
.../SnapshotAwarePartitionDataStorageTest.java | 3 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 3 +-
.../replication/PartitionReplicaListenerTest.java | 3 -
.../distributed/schema/FullTableSchemaTest.java | 3 -
.../schema/SchemaSyncServiceImplTest.java | 3 +-
.../distributed/storage/InternalTableImplTest.java | 3 +-
.../table/type/NumericTypesSerializerTest.java | 2 -
.../table/impl/DummyInternalTableImpl.java | 3 +-
.../table/impl/DummySchemaManagerImpl.java | 3 +-
.../internal/table/impl/TestTupleBuilder.java | 30 +-
.../ignite/internal/tx/InternalTransaction.java | 3 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 3 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 5 +-
.../tx/impl/IgniteAbstractTransactionImpl.java | 4 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 3 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 3 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 3 +-
452 files changed, 3880 insertions(+), 2888 deletions(-)
create mode 100644
modules/arch-test/src/test/java/org/apache/ignite/internal/TestClassHierarchyArchTest.java
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{AbstractIndexCommandParams.java
=> AbstractCreateIndexCommandParams.java} (51%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/BinaryTupleIgniteTupleAdapterTests.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Proto/BinaryTuple/BinaryTupleIgniteTupleAdapter.cs
copy modules/platforms/dotnet/Apache.Ignite/Internal/{Proto/PreferredNode.cs
=> Table/IgniteTupleCommon.cs} (59%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/DestinationFactory.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/set/IgniteMinusBase.java
