This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch IGNITE-22149
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 8f7556fb05 Fix comments
add 348f68b10b IGNITE-22137 Rename "rocksDb" storage engine to "rocksdb"
(#3733)
add cf85b69c35 IGNITE-22191 Fixed case null MvPartitionStorage in
IndexBuildController (#3739)
add 92bfcfd5a2 IGNITE-22206 Unmute disabled
ItTxResourcesVacuumTest#testRecoveryAfterPersistentStateVacuumized (#3738)
add 09565a1025 IGNITE-19082: Catalog. Cleanup dead code (#3669)
add aba72be1b1 IGNITE-21950 Sql. Cover SQL T351(Bracketed SQL comments
(/*...*/ comments)) feature by tests (#3727)
add 26bd72f9e1 IGNITE-21947: Cover SQL T121(WITH (excluding RECURSIVE) in
query expression) feature by tests (#3730)
add 6871bba01b IGNITE-21568 Java thin: Pass client time zone to server
(#3737)
add db949749e9 IGNITE-21949: Cover SQL T122(WITH (excluding RECURSIVE) in
subquery) feature by tests (#3741)
add 39556b6c60 IGNITE-21801 Add missing Schema Sync integration tests
(#3740)
add c6a270e59b IGNITE-22210 Close DBOptions in
SharedRocksDbInstance#stop() (#3743)
add 7028e1ed7b IGNITE-21604 .NET: Pass client time zone to server (#3742)
add c25c060763 IGNITE-22130 Fix retries logic.
add f46d40b444 IGNITE-21941 Cover SQL F391(Long identifiers) feature by
tests (#3734)
add 47808639c9 IGNITE-22220 Rename
`RocksDbStorageEngineExtensionConfigurationSchema#rocksDb` field (#3748)
add 6dc1021e3e IGNITE-22205 Reuse SQL API classes from embedded mode in
client (#3747)
add 479a7375a7 IGNITE-21304 Add internal API for restarting partitions
(#3715)
add 185e568d45 IGNITE-22031 .NET: Remove
DataStreamer.PartitionAssignmentUpdateFrequency (#3749)
add 38d13fcd5f IGNITE-21836: KeyValueView. Throws correct error for
GetNullable for a PoJo when field / column nullability do not match (#3714)
add 87211743d1 IGNITE-21605 C++ Client: Pass client time zone to server
(#3753)
add 755a840355 IGNITE-21946: Cover SQL F863(Nested <result offset clause>
in <query expression>) feature by tests (#3732)
add 562a742f06 IGNITE-21881 Deal with retry send metastorage raft commands
after a timeout (#3725)
add a338a2ec31 IGNITE-22188 Add metrics for debugging ItSqlLogicTest
(#3720)
add cfc1711ee3 IGNITE-21951 Sql. Cover SQL T501(Enhanced EXISTS predicate)
(#3752)
add 3cb6be93ca IGNITE-20294 Sql. Using UDF as a place for system_range
function (#3729)
add e8da242462 Bump mockito from 5.11.0 to 5.12.0 (#3745)
add eab1c58007 IGNITE-16520 Refactor IgniteCliInterfaceTest (#3762)
add db5b04ad93 IGNITE-18492 SQL. Inconsistent behavior of LENGTH limit for
CHAR and VARCHAR data types (#1651)
add bd4574da15 IGNITE-22208 Deduplicate DEFAULT_SCHEMA_NAME (#3758)
add 281a0bc582 IGNITE-22235 Remove eviction-related leftovers of AI2
(#3754)
add dc741be3b6 IGNITE-21942 Cover SQL F393(Unicode escapes in literals)
feature by tests (#3746)
add 97c531227e IGNITE-19234 Enable and fix group reentry logic for
volatile storages (#3763)
add c25f9fdac1 IGNITE-22245 Force switch write intents (#3765)
add 0125fdc1ab IGNITE-21465 Add system views for partition states (#3760)
add 0edec7a349 IGNITE-21944: Cover SQL F851(<order by clause> in
subqueries) feature by tests (#3773)
add b78fab2d05 IGNITE-22256: remove incorrect tests in
ItKvKeyColumnPositionTest. (#3778)
add dea9e4068f IGNITE-22254 Cluster initialization fails when event log is
configured (#3775)
add b60fed3ff2 IGNITE-21812 Add automatic product version resolve (#3776)
add 4a5a498502 IGNITE-22257 Move IgniteUtils#copyStateTo to
CompletableFutures (#3781)
add 7198bf0226 IGNITE-21979: Extend test coverage for SQL
F781(Self-referencing operations) (#3759)
add 426b355d6c IGNITE-22268 Add checkstyle rule for package names (#3783)
add 3a7dadbec7 IGNITE-19065: add test to implicit insert null into not
null column (#3777)
add 62e8494fda IGNITE-22050 Fix incorrect partId in reused pages (#3789)
add 4c6d0f7658 Bump com.google.guava:guava from 33.1.0-jre to 33.2.0-jre
(#3697)
add 7ae9ab763e Bump jackson from 2.17.0 to 2.17.1 (#3706)
add 044ac6deca IGNITE-19670: Improve CatalogService test coverage. (#3751)
add c56f077040 IGNITE-22124 Java thin: Implement Compute MapReduce API
(#3744)
add 066332182d Bump io.swagger.core.v3:swagger-annotations from 2.2.20 to
2.2.22 (#3770)
add 6345f00919 IGNITE-22094 Add removeAll method to tx state storage
(#3779)
add 812d11ae47 IGNITE-21984 Sql. Extend test coverage for SQL
T621(Enhanced numeric functions) (#3774)
add 32295284ee IGNITE-22278 Sql. Refactor base and planning contexts
(#3787)
add 6c5fadcaa1 IGNITE-22166 CLI for disaster recovery:
reset-lost-partitions (#3788)
add a73f5af297 Merge branch 'main' into IGNITE-22149
add ee6758f4e6 Fix comments
No new revisions were added by this update.
Summary of changes:
.idea/inspectionProfiles/Project_Default.xml | 7 +-
check-rules/checkstyle-rules.xml | 16 +-
.../config/storage/rocksdb.adoc | 4 +-
.../config/storage/volatile.adoc | 2 -
docs/_docs/general-tips.adoc | 6 +-
examples/config/ignite-config.conf | 2 +-
.../example/storage/RocksDbStorageExample.java | 2 +-
gradle/libs.versions.toml | 8 +-
.../ignite/internal/affinity/Assignments.java | 16 +
.../src/main/java/org/apache/ignite/Ignite.java | 4 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 2 +-
.../java/org/apache/ignite/table/KeyValueView.java | 5 +-
.../internal/catalog/CatalogManagerImpl.java | 99 +-
.../ignite/internal/catalog/CatalogService.java | 8 +-
.../commands/AbstractCreateIndexCommand.java | 2 +-
.../commands/AlterTableAddColumnCommand.java | 2 +-
.../commands/AlterTableAlterColumnCommand.java | 2 +-
.../commands/AlterTableDropColumnCommand.java | 2 +-
.../catalog/commands/CreateSchemaCommand.java | 96 +
.../commands/CreateSchemaCommandBuilder.java} | 19 +-
.../catalog/commands/CreateSystemViewCommand.java | 4 +-
.../catalog/commands/CreateTableCommand.java | 4 +-
.../catalog/commands/DropIndexCommand.java | 2 +-
.../catalog/commands/DropTableCommand.java | 2 +-
.../descriptors/CatalogColumnCollation.java | 2 +-
.../descriptors/CatalogIndexDescriptor.java | 13 +-
.../descriptors/CatalogSystemViewDescriptor.java | 47 +-
.../descriptors/CatalogTableDescriptor.java | 22 +-
.../events/StoppingIndexEventParameters.java | 11 +-
.../storage/AbstractChangeIndexStatusEntry.java | 18 +-
.../internal/catalog/storage/AlterColumnEntry.java | 30 +-
.../internal/catalog/storage/DropColumnsEntry.java | 28 +-
.../internal/catalog/storage/DropIndexEntry.java | 20 +-
.../internal/catalog/storage/DropTableEntry.java | 16 +-
.../internal/catalog/storage/NewColumnsEntry.java | 27 +-
.../internal/catalog/storage/NewIndexEntry.java | 17 +-
.../internal/catalog/storage/NewSchemaEntry.java | 88 +
.../catalog/storage/NewSystemViewEntry.java | 13 +-
.../internal/catalog/storage/NewTableEntry.java | 14 +-
.../internal/catalog/storage/RenameTableEntry.java | 18 +-
.../CatalogEntrySerializerProvider.java | 2 +
.../serialization/MarshallableEntryType.java | 3 +-
.../ignite/internal/catalog/CatalogIndexTest.java | 872 ++++++
...CatalogManagerDescriptorCausalityTokenTest.java | 15 +-
.../internal/catalog/CatalogManagerSelfTest.java | 2766 ++------------------
.../ignite/internal/catalog/CatalogSchemaTest.java | 49 +
.../internal/catalog/CatalogSystemViewTest.java | 5 +-
.../ignite/internal/catalog/CatalogTableTest.java | 1168 +++++++++
.../ignite/internal/catalog/CatalogZoneTest.java | 503 ++++
.../catalog/commands/CatalogUtilsTest.java | 18 +-
.../CreateSchemaCommandValidationTest.java | 63 +
.../CatalogSystemViewDescriptorTest.java | 2 +
.../storage/CatalogEntrySerializationTest.java | 45 +-
.../internal/catalog/BaseCatalogManagerTest.java | 60 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 16 +-
.../ignite/internal/cli/CliIntegrationTest.java | 9 +-
.../cli/commands/ItClusterCommandTest.java | 220 --
.../internal/cli/commands/ItNodeNameTest.java | 1 -
.../commands/cluster/init/ItClusterInitTest.java | 15 +-
.../configuration/ItConfigCommandTest.java | 4 -
.../cli/commands/connect/ItConnectCommandTest.java | 1 -
...tConnectWithBasicAuthenticationCommandTest.java | 6 -
.../commands/questions/ItConnectToClusterTest.java | 2 -
.../recovery/ItPartitionStatesCommandTest.java | 5 +-
...Test.java => ItResetPartitionsCommandTest.java} | 11 +-
.../ItResetPartitionsReplCommandTest.java} | 18 +-
.../commands/recovery/ItResetPartitionsTest.java | 118 +
.../cli/commands/sql/ItSqlConnectSslTest.java | 3 +-
.../cli/commands/sql/ItSqlReplCommandTest.java | 6 -
.../cli/commands/unit/ItDeploymentUnitTest.java | 13 -
.../apache/ignite/internal/cli/ssl/ItSslTest.java | 2 -
.../call/recovery/PartitionStatesCallInput.java | 24 +-
.../call/recovery/reset/ResetPartitionsCall.java | 56 +
.../recovery/reset/ResetPartitionsCallInput.java | 130 +
.../ignite/internal/cli/commands/Options.java | 14 +-
.../cli/commands/recovery/RecoveryCommand.java | 4 +-
.../cli/commands/recovery/RecoveryReplCommand.java | 4 +-
.../recovery/reset/ResetPartitionsCommand.java | 48 +
.../recovery/reset/ResetPartitionsMixin.java | 65 +
.../recovery/reset/ResetPartitionsReplCommand.java | 50 +
.../internal/cli/IgniteCliInterfaceTest.java | 527 ----
.../internal/cli/commands/CliCommandTestBase.java | 80 +-
.../cli/commands/IgniteCliInterfaceTestBase.java | 50 +
.../cliconfig/CliConfigGetCommandTest.java | 6 +-
.../cliconfig/CliConfigProfileListCommandTest.java | 22 +-
.../cliconfig/CliConfigShowCommandTest.java | 10 +-
.../cli/commands/cluster/ClusterInitTest.java | 199 ++
.../commands/cluster/config/ClusterConfigTest.java | 84 +
.../cli/commands/node/config/NodeConfigTest.java | 86 +
.../cli/commands/node/metric/NodeMetricTest.java | 93 +
.../ignite/internal/cli/AbstractCliTest.java | 74 -
.../internal/client/proto/ClientMessagePacker.java | 13 +
.../client/proto/ClientMessageUnpacker.java | 10 +
.../ignite/internal/client/proto/ClientOp.java | 7 +-
.../handler/ClientInboundMessageHandler.java | 4 +
.../ClientComputeExecuteMapReduceRequest.java | 100 +
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 18 +-
.../handler/requests/sql/ClientSqlProperties.java | 14 +-
.../ignite/client/handler/FakeCatalogService.java | 7 +-
.../apache/ignite/client/ClientOperationType.java | 5 +
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../internal/client/compute/ClientCompute.java | 70 +-
.../client/compute/ClientJobExecution.java | 14 +-
.../client/compute/ClientTaskExecution.java | 140 +
.../internal/client/compute/SubmitTaskResult.java} | 26 +-
.../client/compute/task/ClientTaskExecution.java | 57 -
.../internal/client/sql/ClientAsyncResultSet.java | 2 +-
.../internal/client/sql/ClientColumnMetadata.java | 115 -
.../internal/client/sql/ClientColumnOrigin.java | 85 -
.../client/sql/ClientResultSetMetadata.java | 84 +-
.../ignite/internal/client/sql/ClientSql.java | 28 +-
.../internal/client/sql/ClientStatement.java | 138 -
.../client/sql/ClientStatementBuilder.java | 91 -
.../internal/client/table/AbstractClientView.java | 4 +-
.../client/table/ClientKeyValueBinaryView.java | 44 +-
.../internal/client/table/ClientKeyValueView.java | 169 +-
.../client/table/ClientPartitionManager.java | 10 +-
.../apache/ignite/client/ClientComputeTest.java | 47 +
.../ignite/client/ClientKeyValueViewTest.java | 13 +-
.../org/apache/ignite/client/ClientSqlTest.java | 3 +
.../apache/ignite/client/fakes/FakeCompute.java | 58 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 2 +
.../management/topology/ItLogicalTopologyTest.java | 20 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 5 +-
.../internal/causality/BaseVersionedValue.java | 2 +-
.../ignite/internal/future/OrderingFuture.java | 2 +-
.../internal/properties/IgniteProductVersion.java | 2 +-
.../ignite/internal/sql}/ColumnMetadataImpl.java | 4 +-
.../internal/sql}/ResultSetMetadataImpl.java | 2 +-
.../org/apache/ignite/internal/sql/SqlCommon.java} | 18 +-
.../ignite/internal/sql}/StatementBuilderImpl.java | 4 +-
.../apache/ignite/internal/sql}/StatementImpl.java | 11 +-
.../internal/streamer/StreamerSubscriber.java | 2 +-
.../ignite/internal/util/CompletableFutures.java | 19 +
.../ignite/internal/util/ExceptionUtils.java | 24 +
.../apache/ignite/internal/util/IgniteUtils.java | 19 -
.../ignite/internal/{ => hlc}/HybridClockTest.java | 6 +-
.../internal/{ => hlc}/HybridClockTestUtils.java | 0
.../internal/util/CompletableFuturesTest.java | 25 +
.../ignite/internal/util/IgniteUtilsTest.java | 2 +-
.../src/testFixtures/resources/log4j2-test.xml | 2 +-
.../ItDistributionZonesFiltersTest.java | 40 +-
.../DistributionZoneNotFoundException.java | 6 +-
.../DistributionZoneRebalanceEngineTest.java | 10 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 6 +-
modules/eventlog/build.gradle | 6 +
.../ignite/internal/eventlog/ItEventLogTest.java | 105 +
.../internal/eventlog/api/IgniteEventType.java | 6 +
.../ignite/internal/eventlog/api/IgniteEvents.java | 1 -
.../internal/eventlog/event/EventBuilder.java | 11 +-
.../internal/eventlog/event/EventBuilderTest.java | 3 +-
.../internal/eventlog/event/IgniteEventsTest.java | 12 +-
.../internal/index/ItBuildIndexOneNodeTest.java | 18 +-
.../internal/index/ItIndexAndRebalanceTest.java | 4 +-
.../internal/index/IndexBuildController.java | 15 +-
.../apache/ignite/internal/index/IndexManager.java | 1 -
.../index/IndexAvailabilityControllerTest.java | 6 +-
.../internal/index/IndexBuildControllerTest.java | 6 +-
.../ignite/internal/index/IndexManagerTest.java | 8 +-
.../internal/index/TestIndexManagementUtils.java | 8 +-
.../ignite/internal/jdbc/JdbcConnection.java | 7 +-
.../internal/marshaller/ValidationUtils.java | 34 +
.../ignite/internal/metastorage/CommandId.java} | 17 +-
.../metastorage/dsl/MetaStorageMessageGroup.java | 4 +
modules/metastorage/build.gradle | 3 +
.../impl/ItIdempotentCommandCacheTest.java | 368 +++
.../impl/ItMetaStorageManagerImplTest.java | 4 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 1 +
.../impl/ItMetaStorageServicePersistenceTest.java | 8 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 3 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 1 +
.../server/raft/ItMetaStorageRaftGroupTest.java | 3 +-
...tiInvokeCommand.java => IdempotentCommand.java} | 14 +-
.../metastorage/command/InvokeCommand.java | 2 +-
.../metastorage/command/MultiInvokeCommand.java | 2 +-
.../metastorage/impl/CommandIdGenerator.java | 63 +
.../metastorage/impl/MetaStorageManagerImpl.java | 26 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 9 +-
.../metrics/MetaStorageMetricSource.java | 77 +
.../metastorage/metrics/MetaStorageMetrics.java} | 16 +-
.../server/raft/MetaStorageWriteHandler.java | 80 +
.../metastorage/server/time/ClusterTimeImpl.java | 8 +-
.../impl/IdempotentCommandCacheTest.java | 213 ++
.../MetaStorageDeployWatchesCorrectnessTest.java | 2 +
.../impl/MetaStorageManagerRecoveryTest.java | 2 +
.../impl/StandaloneMetaStorageManager.java | 13 +
.../metrics/exporters/ItOsMetricSourceTest.java | 73 +
.../internal/metrics/sources/JvmMetricSource.java | 32 +-
.../internal/metrics/sources/OsMetricSource.java | 92 +
.../metrics/sources/JvmMetricSourceTest.java | 70 +-
.../metrics/sources/OsMetricSourceTest.java | 79 +
...latilePageMemoryProfileConfigurationSchema.java | 22 -
.../pagememory/datastructure/DataStructure.java | 18 +
.../pagememory/evict/PageEvictionTracker.java | 58 -
.../pagememory/evict/PageEvictionTrackerNoOp.java | 57 -
.../internal/pagememory/freelist/FreeListImpl.java | 21 +-
.../internal/pagememory/freelist/PagesList.java | 2 +
.../pagememory/freelist/FreeListImplTest.java | 2 -
.../MultiActorPlacementDriverTest.java | 1 +
.../PlacementDriverManagerTest.java | 1 +
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 12 +-
.../cpp/ignite/client/detail/utils_test.cpp | 2 +-
.../cpp/ignite/client/sql/sql_statement.h | 29 +-
.../cpp/ignite/odbc/config/configuration.cpp | 4 +
.../cpp/ignite/odbc/config/configuration.h | 17 +-
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 7 +
modules/platforms/cpp/ignite/odbc/string_utils.h | 3 +
modules/platforms/cpp/ignite/odbc/utility.cpp | 1 +
.../platforms/cpp/tests/client-test/sql_test.cpp | 20 +
.../cpp/tests/odbc-test/connection_test.cpp | 39 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 6 +-
.../Table/DataStreamerBenchmark.cs | 20 +-
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 12 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 50 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 90 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 3 +
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 25 +-
.../dotnet/Apache.Ignite/Sql/SqlStatement.cs | 33 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 2 +-
.../ignite/internal/replicator/ReplicaService.java | 36 +-
.../rest/api/recovery/DisasterRecoveryApi.java | 4 +-
modules/rest/build.gradle | 1 +
.../rest/ItInitializedClusterRestTest.java | 14 +-
.../rest/ItNotInitializedClusterRestTest.java | 7 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 2 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 2 +
.../ignite/internal/benchmark/InsertBenchmark.java | 49 +-
.../ItDistributedConfigurationPropertiesTest.java | 1 +
.../ItDistributedConfigurationStorageTest.java | 1 +
.../runner/app/ItIgniteNodeRestartTest.java | 39 +-
.../runner/app/PlatformTestNodeRunner.java | 12 +-
.../app/client/ItNullsEmbeddedClientTest.java} | 18 +-
.../runner/app/client/ItNullsThinClientTest.java | 134 +
.../runner/app/client/ItThinClientComputeTest.java | 122 +
.../schemasync/ItSchemaSyncConfigTest.java | 79 +
.../schemasync/ItSchemaSyncSingleNodeTest.java | 119 +-
.../ignite/internal/table/ItDurableFinishTest.java | 2 +-
.../ignite/internal/table/ItTableScanTest.java | 6 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 15 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 2 +
.../java/org/apache/ignite/internal/Cluster.java | 1 +
.../internal/ClusterPerClassIntegrationTest.java | 8 +-
.../internal/ClusterPerTestIntegrationTest.java | 8 +-
.../schema/registry/SchemaRegistryImpl.java | 36 +-
.../schema/registry/SchemaRegistryImplTest.java | 218 --
.../sql/api/ItKvKeyColumnPositionTest.java | 31 -
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 28 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 20 -
.../internal/sql/engine/ItDataTypesTest.java | 157 ++
.../internal/sql/engine/ItFunctionsTest.java | 15 +
.../sql/engine/ItIndexAvailabilityTest.java | 4 +-
.../ignite/internal/sql/engine/ItIndexDdlTest.java | 6 +-
.../sql/engine/ItIndexesSystemViewTest.java | 4 +-
.../sql/engine/ItNotNullConstraintTest.java | 5 +
.../sql/engine/datatypes/uuid/ItUuidJoinTest.java | 10 +
.../internal/sql/sqllogic/ItSqlLogicTest.java | 12 +-
.../aggregate/aggregates/test_covar.test_ignore | 1 +
.../aggregates/test_regression.test_ignore | 1 +
.../aggregate/aggregates/test_stddev.test_ignore | 1 +
.../src/integrationTest/sql/cte/test_cte.test | 111 +
.../integrationTest/sql/cte/test_cte_in_cte.test | 54 +
.../sql/cte/test_cte_in_subquery.test | 34 +
.../sql/dml/test_self_referencing.test | 107 +
.../sql/function/numeric/test_pg_math.test | 1 +
.../sql/identifiers/test_long_identifiers.test | 227 ++
.../integrationTest/sql/order/test_order_by.test | 24 +-
.../sql/order/test_order_by.test_ignore | 174 --
.../sql/order/test_order_by_in_subquery.test | 60 +
.../integrationTest/sql/set/test_except_all.test | 2 +-
.../integrationTest/sql/set/test_intersect.test | 2 +-
.../sql/set/test_query_primary_offset.test | 33 +
.../src/integrationTest/sql/set/test_union.test | 111 +
.../sql/set/test_union_with_limit.test | 112 +
.../exists/test_enhanced_exists_predicate.test | 38 +
.../scalar/test_correlated_subquery_cte.test | 19 +
.../test_correlated_subquery_cte.test_ignore | 133 -
.../subquery/scalar/test_scalar_subquery_cte.test | 1 +
.../sql/types/char/test_char_length.test | 6 -
.../test_unicode_escapes_in_literals.test_ignored | 51 +
.../ignite/internal/sql/api/IgniteSqlImpl.java | 4 +-
.../internal/sql/engine/SqlOperationContext.java | 189 ++
.../internal/sql/engine/SqlQueryProcessor.java | 107 +-
.../sql/engine/exec/ExecutableTableRegistry.java | 4 +-
.../engine/exec/ExecutableTableRegistryImpl.java | 4 +-
.../engine/exec/ExecutionDependencyResolver.java | 2 +-
.../exec/ExecutionDependencyResolverImpl.java | 14 +-
.../internal/sql/engine/exec/ExecutionService.java | 6 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 120 +-
.../sql/engine/exec/LogicalRelImplementor.java | 20 +-
.../sql/engine/exec/TableFunctionScan.java | 51 -
.../sql/engine/exec/UpdatableTableImpl.java | 51 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 136 -
.../internal/sql/engine/exec/exp/RexImpTable.java | 14 +-
.../exec/exp/func/IterableTableFunction.java | 60 +
.../exec/exp/func/SystemRangeTableFunction.java | 114 +
.../func/TableFunction.java} | 18 +-
.../exec/exp/func/TableFunctionInstance.java} | 37 +-
.../func/TableFunctionRegistry.java} | 22 +-
.../exec/exp/func/TableFunctionRegistryImpl.java | 65 +
.../internal/sql/engine/exec/rel/ScanNode.java | 53 +-
.../sql/engine/externalize/RelJsonReader.java | 10 +-
.../sql/engine/externalize/RelOptSchemaImpl.java | 174 ++
.../sql/engine/message/QueryStartRequest.java | 20 +-
.../internal/sql/engine/prepare/DdlPlan.java | 4 +-
.../internal/sql/engine/prepare/ExplainPlan.java | 4 +-
.../sql/engine/prepare/IgniteTypeCoercion.java | 42 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 8 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 8 +-
.../internal/sql/engine/prepare/MultiStepPlan.java | 10 +-
.../sql/engine/prepare/PlanningContext.java | 154 +-
.../sql/engine/prepare/PrepareService.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 73 +-
.../internal/sql/engine/schema/IgniteSchema.java | 12 +-
.../sql/engine/schema/SqlSchemaManager.java | 18 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 24 +-
.../internal/sql/engine/util/BaseQueryContext.java | 304 ---
.../ignite/internal/sql/engine/util/Commons.java | 20 +-
.../internal/sql/engine/util/IgniteMethod.java | 4 -
.../ignite/internal/sql/engine/util/TypeUtils.java | 95 +
.../internal/sql/api/StatementBuilderImplTest.java | 13 +-
.../sql/engine/AsyncSqlCursorImplTest.java | 2 +-
.../exec/ExecutionDependencyResolverSelfTest.java | 2 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 144 +-
.../engine/exec/NoOpExecutableTableRegistry.java | 2 +-
.../engine/exec/mapping/FragmentMappingTest.java | 10 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 4 +-
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 135 +
.../exec/rel/SystemRangeTableFunctionTest.java | 114 +
.../engine/framework/PredefinedSchemaManager.java | 8 +-
.../sql/engine/framework/TestBuilders.java | 11 +-
.../internal/sql/engine/framework/TestNode.java | 27 +-
.../sql/engine/planner/AbstractPlannerTest.java | 109 +-
.../sql/engine/planner/ImplicitCastsTest.java | 2 +-
.../engine/planner/KeyValueModifyPlannerTest.java | 4 +-
.../sql/engine/planner/LimitOffsetPlannerTest.java | 49 +
.../internal/sql/engine/planner/PlannerTest.java | 15 +-
.../sql/engine/planner/PlannerTimeoutTest.java | 15 +-
.../planner/PrimaryKeyLookupPlannerTest.java | 4 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 58 +-
.../sql/engine/prepare/TypeCoercionTest.java | 46 +-
.../ddl/AbstractDdlSqlToCommandConverterTest.java | 13 +-
.../engine/schema/SqlSchemaManagerImplTest.java | 2 +-
.../sql/engine/sql/AbstractParserTest.java | 6 +-
.../sql/engine/sql/CommentParsingTest.java | 87 +-
.../internal/sql/engine/util/StatementChecker.java | 4 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 28 +-
.../PersistentPageMemoryTableStorage.java | 5 -
.../pagememory/VolatilePageMemoryDataRegion.java | 9 +-
.../VolatilePageMemoryDataStorageModule.java | 3 +-
.../VolatilePageMemoryStorageEngine.java | 14 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 8 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 7 +-
.../pagememory/mv/CommitWriteInvokeClosure.java | 8 -
.../mv/PersistentPageMemoryMvPartitionStorage.java | 4 -
.../mv/RemoveWriteOnGcInvokeClosure.java | 8 -
.../mv/VolatilePageMemoryMvPartitionStorage.java | 4 -
.../VolatilePageMemoryMvTableStorageTest.java | 18 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 4 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 4 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 4 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 4 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 2 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 2 +-
.../schema/RocksDbProfileConfigurationSchema.java | 2 +-
...bStorageEngineExtensionConfigurationSchema.java | 2 +-
.../rocksdb/instance/SharedRocksDbInstance.java | 6 +
.../instance/SharedRocksDbInstanceCreator.java | 1 +
.../RocksDbMvPartitionStorageConcurrencyTest.java | 4 +-
.../rocksdb/RocksDbMvPartitionStorageGcTest.java | 4 +-
.../rocksdb/RocksDbMvPartitionStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbStorageEngineTest.java | 66 -
.../rocksdb/engine/RocksDbStorageEngineTest.java | 2 +-
.../rocksdb/index/RocksDbHashIndexStorageTest.java | 4 +-
.../index/RocksDbSortedIndexStorageTest.java | 4 +-
.../instance/SharedRocksDbInstanceTest.java | 2 +-
.../internal/systemview/SystemViewManagerImpl.java | 3 +-
.../internal/systemview/SystemViewManagerTest.java | 38 +-
modules/table/build.gradle | 4 +
.../disaster/ItDisasterRecoveryManagerTest.java | 109 +
.../ItDisasterRecoveryReconfigurationTest.java | 4 +-
.../disaster/ItDisasterRecoverySystemViewTest.java | 101 +
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 14 +-
.../rebalance/ItRebalanceDistributedTest.java | 13 +-
.../internal/table/ItTxResourcesVacuumTest.java | 63 +-
.../internal/table/KeyValueBinaryViewImpl.java | 58 +-
.../ignite/internal/table/KeyValueViewImpl.java | 168 +-
.../PartitionReplicatorNodeRecovery.java | 113 +-
.../internal/table/distributed/TableManager.java | 67 +-
.../disaster/DisasterRecoveryManager.java | 193 +-
.../disaster/DisasterRecoveryRequest.java | 10 +-
.../disaster/DisasterRecoveryRequestType.java} | 19 +-
.../disaster/DisasterRecoverySystemViews.java | 161 ++
.../disaster/ManualGroupRestartRequest.java | 104 +
.../disaster/ManualGroupUpdateRequest.java | 19 +-
.../table/distributed/gc/GcStorageHandler.java | 3 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 10 +-
.../{HasDataResponse.java => DataPresence.java} | 18 +-
.../table/distributed/message/HasDataResponse.java | 13 +-
.../table/distributed/raft/PartitionListener.java | 4 +-
.../raft/snapshot/PartitionAccessImpl.java | 2 +-
.../replicator/PartitionReplicaListener.java | 60 +-
.../distributed/storage/InternalTableImpl.java | 243 +-
.../ignite/internal/utils/RebalanceUtilEx.java | 19 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 10 +-
.../internal/table/KeyValueViewOperationsTest.java | 116 +-
.../CatalogStorageIndexDescriptorSupplierTest.java | 10 +-
.../distributed/TableManagerRecoveryTest.java | 10 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../internal/table/distributed/TableUtilsTest.java | 4 +-
.../gc/AbstractGcUpdateHandlerTest.java | 52 +
.../distributed/gc/RocksDbGcUpdateHandlerTest.java | 2 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 3 +-
.../FullStateTransferIndexChooserTest.java | 8 +-
.../incoming/IncomingSnapshotCopierTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 11 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 7 +-
.../ignite/internal/table/TableTestUtils.java | 12 +-
.../tx/TransactionExceptionMapperProvider.java | 46 +
.../internal/tx/impl/TxCleanupRequestSender.java | 4 +-
.../state/ThreadAssertingTxStateStorage.java | 12 +-
.../internal/tx/storage/state/TxStateStorage.java | 19 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 100 +-
.../storage/state/AbstractTxStateStorageTest.java | 110 +-
.../tx/storage/state/test/TestTxStateStorage.java | 20 +-
427 files changed, 12506 insertions(+), 7485 deletions(-)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/CreateSchemaCommand.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/commands/CreateSchemaCommandBuilder.java}
(64%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/NewSchemaEntry.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogIndexTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogSchemaTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogTableTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/CatalogZoneTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/CreateSchemaCommandValidationTest.java
delete mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/ItClusterCommandTest.java
copy
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{ItPartitionStatesCommandTest.java
=> ItResetPartitionsCommandTest.java} (69%)
copy
modules/cli/src/{main/java/org/apache/ignite/internal/cli/commands/recovery/RecoveryCommand.java
=>
integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/ItResetPartitionsReplCommandTest.java}
(65%)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/ItResetPartitionsTest.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/reset/ResetPartitionsCall.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/reset/ResetPartitionsCallInput.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/reset/ResetPartitionsCommand.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/reset/ResetPartitionsMixin.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/reset/ResetPartitionsReplCommand.java
delete mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/IgniteCliInterfaceTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/IgniteCliInterfaceTestBase.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/ClusterInitTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/config/ClusterConfigTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/node/config/NodeConfigTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/node/metric/NodeMetricTest.java
delete mode 100644
modules/cli/src/testFixtures/java/org/apache/ignite/internal/cli/AbstractCliTest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/compute/ClientComputeExecuteMapReduceRequest.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/compute/ClientTaskExecution.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
client/src/main/java/org/apache/ignite/internal/client/compute/SubmitTaskResult.java}
(55%)
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/compute/task/ClientTaskExecution.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientColumnMetadata.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientColumnOrigin.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
delete mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatementBuilder.java
rename modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/api =>
core/src/main/java/org/apache/ignite/internal/sql}/ColumnMetadataImpl.java (97%)
rename modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/api =>
core/src/main/java/org/apache/ignite/internal/sql}/ResultSetMetadataImpl.java
(98%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=> core/src/main/java/org/apache/ignite/internal/sql/SqlCommon.java} (63%)
rename modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/api =>
core/src/main/java/org/apache/ignite/internal/sql}/StatementBuilderImpl.java
(96%)
rename modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/api =>
core/src/main/java/org/apache/ignite/internal/sql}/StatementImpl.java (91%)
rename modules/core/src/test/java/org/apache/ignite/internal/{ =>
hlc}/HybridClockTest.java (95%)
rename modules/core/src/test/java/org/apache/ignite/internal/{ =>
hlc}/HybridClockTestUtils.java (100%)
create mode 100644
modules/eventlog/src/integrationTest/java/org/apache/ignite/internal/eventlog/ItEventLogTest.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/message/HasDataResponse.java
=>
metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/CommandId.java}
(67%)
create mode 100644
modules/metastorage/src/integrationTest/java/org/apache/ignite/internal/metastorage/impl/ItIdempotentCommandCacheTest.java
copy
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/{MultiInvokeCommand.java
=> IdempotentCommand.java} (68%)
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/impl/CommandIdGenerator.java
create mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/metrics/MetaStorageMetricSource.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
metastorage/src/main/java/org/apache/ignite/internal/metastorage/metrics/MetaStorageMetrics.java}
(65%)
create mode 100644
modules/metastorage/src/test/java/org/apache/ignite/internal/metastorage/impl/IdempotentCommandCacheTest.java
create mode 100644
modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/ItOsMetricSourceTest.java
create mode 100644
modules/metrics/src/main/java/org/apache/ignite/internal/metrics/sources/OsMetricSource.java
create mode 100644
modules/metrics/src/test/java/org/apache/ignite/internal/metrics/sources/OsMetricSourceTest.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/evict/PageEvictionTracker.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/evict/PageEvictionTrackerNoOp.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItNullsEmbeddedClientTest.java}
(64%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItNullsThinClientTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/schemasync/ItSchemaSyncConfigTest.java
create mode 100644 modules/sql-engine/src/integrationTest/sql/cte/test_cte.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/cte/test_cte_in_cte.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/cte/test_cte_in_subquery.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/dml/test_self_referencing.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/identifiers/test_long_identifiers.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/order/test_order_by.test_ignore
create mode 100644
modules/sql-engine/src/integrationTest/sql/order/test_order_by_in_subquery.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/set/test_query_primary_offset.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/set/test_union.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/set/test_union_with_limit.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/subquery/exists/test_enhanced_exists_predicate.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/subquery/scalar/test_correlated_subquery_cte.test_ignore
create mode 100644
modules/sql-engine/src/integrationTest/sql/types/string/test_unicode_escapes_in_literals.test_ignored
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlOperationContext.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TableFunctionScan.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/func/IterableTableFunction.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/func/SystemRangeTableFunction.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{ExecutionDependencyResolver.java
=> exp/func/TableFunction.java} (64%)
copy
modules/sql-engine/src/{integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/uuid/ItUuidJoinTest.java
=>
main/java/org/apache/ignite/internal/sql/engine/exec/exp/func/TableFunctionInstance.java}
(51%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{ExecutableTableRegistry.java
=> exp/func/TableFunctionRegistry.java} (59%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/func/TableFunctionRegistryImpl.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/externalize/RelOptSchemaImpl.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/BaseQueryContext.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/ScanNodeExecutionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/SystemRangeTableFunctionTest.java
delete mode 100644
modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageEngineTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoveryManagerTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoverySystemViewTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionDependencyResolver.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/DisasterRecoveryRequestType.java}
(63%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/DisasterRecoverySystemViews.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/ManualGroupRestartRequest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/message/{HasDataResponse.java
=> DataPresence.java} (65%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/TransactionExceptionMapperProvider.java
