This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 6fd95d5610 Merge branch 'ai-main' into catalog-feature
add 7ee03fdfe6 IGNITE-20316 Fix possible lost updates in
MetastorageInhibitor (#2521)
add e569728d29 IGNITE-20312 Increase the number of log files in rotation
(#2515)
add 7363d4e9f0 IGNITE-20018: Introduce system view definition API. (#2494)
add b75485057c IGNITE-20318 Fix logging for raft log truncation (#2522)
add 0ca0a8241d IGNITE-20321: Fix compilation error in ErrorGroups. (#2524)
add f7b464cef7 IGNITE-20275 Fix race condition in
ClientInboundMessageHandler (#2525)
add 5cd2c01ef1 IGNITE-20285 Move handler of CreateTable command from
CatalogManager to command itself (#2508)
add d2c56b072a IGNITE-19889 Implement observable timestamp on server
(#2514)
add 0189bed12d IGNITE-20305 Incorrect using of Assertions.assertThrows
(#2510)
add f189bf979b IGNITE-20288 .NET: Fix
TestDroppedConnectionsAreRestoredInBackground flakiness (#2533)
add 950a3c0428 IGNITE-20164 Sql. Incorrect propagation of RelCollation
trait for Sort-based map/reduce aggregates (#2461)
add f4914e4749 IGNITE-20077 Sql. Bump calcite version to 1.35.0 (#2503)
add 1d856fcaff IGNITE-20334 Sql. Fix compilation after IGNITE-20077 (#2535)
add ec56829581 IGNITE-20329 Fix ODBC build for MacOS (#2532)
add 653cc4c8da IGNITE-20262 Refuse accepting partition Raft commands when
not enough schemas are available (#2484)
add 5d5766092f IGNITE-20338 CheckCatalogVersionOnActionRequestTest fails
with NPEs (#2540)
add ba27e89c58 IGNITE-20016 Introduce bulk operation to catalog (#2530)
add 2808a7c3d7 IGNITE-20319 MultiActorPlacementDriverTest and
PlacementDriverManagerTest incorrectly share hybridClock (#2536)
add 2116dd0a1d IGNITE-20182 Sql. Flaky test
ExchangeExecutionTest#racesBetweenRewindAndBatchesFromPreviousRequest (#2534)
add 230fe64b39 IGNITE-20328 Cleanup in BaseIgniteAbstractTest (#2531)
add 0f7643ba39 IGNITE-19246 Ask for for auth settings in CLI interactive
mode (#2472)
add 4406ebf825 IGNITE-20256 Refuse to install Raft snapshots on partitions
when not enough schemas are available (#2473)
add 73acf1841e IGNITE-20307 Move handler of DropTable command from
CatalogManager to command itself (#2526)
add 948f6f1874 IGNITE-14604 Remove outdated TODOs
add 1fa1caf370 IGNITE-15713 Remove outdated TODO
add 91dbe869b2 IGNITE-18784 Fix tests for Windows (#2527)
add 5ac19cfb95 IGNITE-19710 .NET: Add Data Streamer schema synchronization
(#2548)
add 6ada35b789 IGNITE-20303 Fix an issue that could lead to "Raft group on
the node is already started" (#2519)
add 77e04f96d4 IGNITE-19214 Table metadata fetching for ODBC (#2551)
add c07258e61b IGNITE-20308 Fix ItAbstractDataStreamerTest flakiness
(#2556)
add cd9bfab4f3 Merge branch 'main' into catalog-feature
No new revisions were added by this update.
Summary of changes:
gradle/libs.versions.toml | 8 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 9 +
.../main/java/org/apache/ignite/sql/Session.java | 16 +
.../ignite/internal/catalog/CatalogCommand.java} | 18 +-
.../ignite/internal/catalog/CatalogManager.java | 20 +-
.../internal/catalog/CatalogManagerImpl.java | 102 +-
.../catalog/CatalogParamsValidationUtils.java | 116 +-
.../catalog/CatalogValidationException.java | 10 +
.../catalog/TableExistsValidationException.java} | 23 +-
.../catalog/TableNotFoundValidationException.java} | 22 +-
.../ignite/internal/catalog/UpdateProducer.java} | 23 +-
...ableParams.java => AbstractCatalogCommand.java} | 19 +-
.../catalog/commands/AbstractTableCommand.java | 46 +
...arams.java => AbstractTableCommandBuilder.java} | 30 +-
.../internal/catalog/commands/CatalogUtils.java | 85 +-
.../catalog/commands/CreateTableCommand.java | 263 +
.../commands/CreateTableCommandBuilder.java | 48 +
.../catalog/commands/CreateTableParams.java | 122 -
.../catalog/commands/DropTableCommand.java | 95 +
.../catalog/commands/DropTableCommandBuilder.java} | 21 +-
.../internal/catalog/CatalogManagerSelfTest.java | 202 +-
.../catalog/CatalogManagerValidationTest.java | 110 +-
.../commands/AbstractCommandValidationTest.java | 106 +
.../commands/CreateTableCommandValidationTest.java | 343 +
.../commands/DropTableCommandValidationTest.java | 99 +
.../internal/catalog/BaseCatalogManagerTest.java | 37 +-
.../internal/cli/CliIntegrationTestBase.java | 4 +-
...liCommandTestNotInitializedIntegrationBase.java | 10 +-
.../cli/commands/ItConnectToClusterTestBase.java | 6 +-
.../cli/commands/ItConnectionHeartbeatTest.java | 2 +-
.../internal/cli/commands/ItNodeNameTest.java | 2 +-
...tConnectWithBasicAuthenticationCommandTest.java | 54 +-
.../questions/ItConnectToBasicAuthClusterTest.java | 65 +
.../ItConnectToSslAndAuthClusterTest.java | 328 +
.../cli/commands/sql/CliSqlCommandTestBase.java | 9 +-
.../commands/sql/CliSqlConnectCommandTestBase.java | 5 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 9 +-
.../ignite/internal/cli/ssl/ItJdbcSslTest.java | 9 +-
.../java/org/apache/ignite/internal/cli/Main.java | 2 -
...nectSslConfigCallInput.java => AuthConfig.java} | 26 +-
.../internal/cli/call/connect/ConnectCall.java | 59 +-
.../internal/cli/call/connect/ConnectSslCall.java | 59 -
.../cli/call/connect/ConnectSslConfigCall.java | 80 -
.../cli/call/connect/ConnectSuccessCall.java | 59 +
.../cli/call/connect/ConnectWizardCall.java | 126 +
.../cli/call/connect/ConnectionChecker.java | 170 +
.../cli/commands/connect/ConnectReplCommand.java | 4 +-
.../questions/ConnectToClusterQuestion.java | 35 +-
.../handler/IgniteCliApiExceptionHandler.java | 6 +
.../ignite/internal/cli/core/repl/SessionInfo.java | 3 +-
.../internal/cli/core/rest/ApiClientFactory.java | 40 +-
.../jdbc/proto/event/JdbcMetaTablesResult.java | 4 +-
modules/client-handler/build.gradle | 1 +
.../apache/ignite/client/handler/TestServer.java | 2 +-
.../ignite/client/handler/ClientHandlerModule.java | 32 +-
.../handler/ClientInboundMessageHandler.java | 8 +-
.../requests/sql/ClientSqlExecuteRequest.java | 18 +-
.../requests/jdbc/JdbcQueryCursorSelfTest.java | 4 +-
.../internal/client/sql/ClientSessionBuilder.java | 11 +
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../ignite/client/TestClientHandlerModule.java | 3 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 10 +-
.../ignite/client/fakes/FakeSessionBuilder.java | 11 +
.../apache/ignite/client/fakes/FakeTxManager.java | 32 +-
.../AbstractClusterStateStorageManagerTest.java | 11 +-
.../RocksDbClusterStateStorageManagerTest.java | 4 -
.../compute/loader/JobClassLoaderFactoryTest.java | 13 +-
.../compute/loader/JobContextManagerTest.java | 3 +-
.../apache/ignite/internal/util}/AsyncCursor.java | 2 +-
.../apache/ignite/internal/util}/AsyncWrapper.java | 3 +-
.../ignite/internal/util/CollectionUtils.java | 9 +
.../apache/ignite/lang/IgniteSystemProperties.java | 3 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 2 +-
.../internal/util}/AsyncWrapperSelfTest.java | 5 +-
.../testframework/BaseIgniteAbstractTest.java | 69 +-
.../internal/testframework/IgniteAbstractTest.java | 27 +-
.../internal/testframework/IgniteTestUtils.java | 10 +-
.../testframework/IntegrationTestBase.java | 21 -
.../ignite/internal/index/IndexManagerTest.java | 6 +-
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 5 +-
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 16 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 30 +-
.../ignite/jdbc/ItJdbcConnectionSelfTest.java | 335 +-
.../ignite/jdbc/ItJdbcErrorsAbstractSelfTest.java | 13 +-
.../ignite/jdbc/ItJdbcInsertStatementSelfTest.java | 10 +-
.../jdbc/ItJdbcMetadataPrimaryKeysSelfTest.java | 5 +-
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 36 +-
.../ignite/jdbc/ItJdbcSelectAfterAlterTable.java | 9 +-
.../ignite/jdbc/ItJdbcStatementCancelSelfTest.java | 13 +-
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 66 +-
.../org/apache/ignite/jdbc/util/JdbcTestUtils.java | 75 +
.../internal/marshaller/FieldAccessorTest.java | 8 +-
.../tree/AbstractBplusTreePageMemoryTest.java | 9 +-
.../tree/AbstractBplusTreeReusePageMemoryTest.java | 10 +-
.../internal/placementdriver/ActiveActorTest.java | 5 +-
.../placementdriver/BasePlacementDriverTest.java | 2 +-
.../MultiActorPlacementDriverTest.java | 7 +-
.../PlacementDriverManagerTest.java | 9 +-
modules/platforms/cpp/cmake/find_odbc.cmake | 3 +
.../cpp/ignite/client/detail/node_connection.cpp | 3 +-
.../cpp/ignite/client/detail/node_connection.h | 2 +-
modules/platforms/cpp/ignite/odbc/CMakeLists.txt | 4 +-
.../platforms/cpp/ignite/odbc/meta/column_meta.h | 16 +-
.../platforms/cpp/ignite/odbc/meta/table_meta.cpp | 18 +-
.../platforms/cpp/ignite/odbc/meta/table_meta.h | 4 +-
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 3 +-
modules/platforms/cpp/ignite/odbc/query/query.h | 3 +
.../cpp/ignite/odbc/query/table_metadata_query.cpp | 223 +
.../cpp/ignite/odbc/query/table_metadata_query.h | 151 +
.../platforms/cpp/ignite/odbc/sql_statement.cpp | 12 +-
modules/platforms/cpp/ignite/odbc/string_utils.h | 25 +
.../cpp/ignite/protocol/client_operation.h | 3 +
modules/platforms/cpp/ignite/protocol/messages.cpp | 4 +-
modules/platforms/cpp/ignite/protocol/messages.h | 6 +-
.../platforms/cpp/tests/client-test/sql_test.cpp | 4 +-
.../cpp/tests/odbc-test/api_robustness_test.cpp | 29 +-
.../cpp/tests/odbc-test/meta_queries_test.cpp | 137 +-
.../cpp/tests/odbc-test/odbc_connection.h | 3 +-
.../cpp/tests/odbc-test/odbc_test_utils.h | 4 +-
.../platforms/cpp/tests/odbc-test/queries_test.cpp | 7 +-
.../dotnet/Apache.Ignite.Benchmarks/Program.cs | 4 +-
.../Table/DataStreamerBenchmark.cs | 2 +-
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 3 +-
.../Compute/ComputeClusterAwarenessTests.cs | 8 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 4 +-
.../Apache.Ignite.Tests/IgniteClientExtensions.cs | 36 +
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 2 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/ReconnectTests.cs | 14 +-
.../Apache.Ignite.Tests/RequestBalancingTests.cs | 4 +-
.../Table/SchemaSynchronizationTest.cs | 68 +
.../Internal/Buffers/PooledArrayBuffer.cs | 29 +-
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 158 +-
.../Apache.Ignite/Internal/Table/RecordView.cs | 4 +-
.../Table/Serialization/ObjectSerializerHandler.cs | 2 +-
.../Table/Serialization/RecordSerializer.cs | 24 +-
.../Serialization/TuplePairSerializerHandler.cs | 2 +-
.../Table/Serialization/TupleSerializerHandler.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 12 -
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 5 +-
.../raft/server/ItJraftCounterServerTest.java | 2 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 20 +
.../ignite/internal/raft/server/RaftServer.java | 8 +
.../internal/raft/server/impl/JraftServerImpl.java | 23 +-
.../ignite/raft/jraft/entity/RaftOutter.java | 3 +
...erceptor.java => ActionRequestInterceptor.java} | 16 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 5 +-
...ava => InterceptingActionRequestProcessor.java} | 34 +-
.../rpc/impl/NullActionRequestInterceptor.java} | 17 +-
.../impl/core/AppendEntriesRequestInterceptor.java | 1 +
.../InterceptingAppendEntriesRequestProcessor.java | 6 +-
.../raft/jraft/storage/impl/LogManagerImpl.java | 14 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 2 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 4 +-
.../ignite/internal/replicator/ReplicaManager.java | 10 +
.../ignite/internal/BaseIgniteRestartTest.java | 7 +-
.../internal/ClusterPerTestIntegrationTest.java | 12 +-
.../ItNodeBootstrapConfigurationTest.java | 2 +-
.../storage/ItRebalanceDistributedTest.java | 181 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 214 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 4 +-
.../runner/app/PlatformTestNodeRunner.java | 19 +-
.../app/client/ItAbstractThinClientTest.java | 6 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 16 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 90 +-
.../sql/engine/ClusterPerClassIntegrationTest.java | 24 -
.../internal/sql/engine/ItAggregatesTest.java | 411 +-
.../internal/sql/engine/ItCorrelatesTest.java | 12 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 120 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 57 +-
.../sql/engine/ItDynamicParameterTest.java | 18 +-
.../internal/sql/engine/ItFunctionsTest.java | 40 +-
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 6 +-
.../internal/sql/engine/ItSqlOperatorsTest.java | 2 +-
.../ignite/internal/sqllogic/ScriptContext.java | 22 +-
.../apache/ignite/internal/sqllogic/Statement.java | 14 +-
.../streamer/ItAbstractDataStreamerTest.java | 12 +-
.../internal/table/ItPublicApiColocationTest.java | 12 +-
.../internal/table/ItReadOnlyTransactionTest.java | 6 +-
.../internal/test/WatchListenerInhibitor.java | 36 +-
.../sql/function/string/test_concat.test | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 16 +-
.../storage/DistributedConfigurationStorage.java | 4 -
.../schema/marshaller/KvMarshallerTest.java | 7 +-
.../RecordMarshallerValidationsTest.java | 6 +-
modules/sql-engine/build.gradle | 2 +
modules/sql-engine/src/main/codegen/config.fmpp | 5 +
.../internal/sql/api/AsyncResultSetImpl.java | 2 +-
.../internal/sql/api/SessionBuilderImpl.java | 20 +-
.../ignite/internal/sql/api/SessionImpl.java | 2 +-
.../ignite/internal/sql/engine/AsyncSqlCursor.java | 1 +
.../internal/sql/engine/AsyncSqlCursorImpl.java | 1 +
.../internal/sql/engine/SqlQueryProcessor.java | 1 +
.../internal/sql/engine/exec/ExecutionService.java | 2 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 3 +-
.../engine/exec/ddl/DdlCommandHandlerWrapper.java | 18 +-
.../exec/ddl/DdlToCatalogCommandConverter.java | 21 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 7395 ++++++++++----------
.../sql/engine/exec/exp/RexToLixTranslator.java | 14 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 35 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 14 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 2 +-
.../internal/sql/engine/exec/rel/RootNode.java | 3 +-
.../internal/sql/engine/externalize/RelJson.java | 7 +
.../sql/engine/externalize/RelJsonReader.java | 16 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 3 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 2 +-
.../sql/engine/rel/agg/IgniteMapSortAggregate.java | 2 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 33 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 28 +-
.../engine/rule/HashAggregateConverterRule.java | 20 +-
.../engine/rule/SortAggregateConverterRule.java | 32 +-
.../engine/rule/logical/LogicalOrToUnionRule.java | 2 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 12 +-
.../sql/engine/sql/fun/SqlSubstringFunction.java | 177 -
.../sql/engine/trait/TraitsAwareIgniteRel.java | 2 +-
.../ignite/internal/sql/engine/util/Commons.java | 54 +-
.../ignite/internal/sql/engine/util/PlanUtils.java | 40 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 6 +-
.../sql/engine/AsyncSqlCursorImplTest.java | 5 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 13 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 4 +
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 23 +-
.../sql/engine/exec/rel/ExecutionTest.java | 9 +-
.../exec/rel/HashAggregateExecutionTest.java | 5 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 2 +
.../exec/rel/SortAggregateExecutionTest.java | 7 +-
.../exec/rel/TableScanNodeExecutionTest.java | 10 +-
.../internal/sql/engine/framework/TestNode.java | 2 +-
.../planner/AbstractAggregatePlannerTest.java | 72 +
.../sql/engine/planner/AggregatePlannerTest.java | 55 +
.../planner/ColocatedHashAggregatePlannerTest.java | 44 +
.../planner/ColocatedSortAggregatePlannerTest.java | 33 +
.../engine/planner/MapReduceAggregatesTest.java | 138 +
.../planner/MapReduceHashAggregatePlannerTest.java | 56 +
.../planner/MapReduceSortAggregatePlannerTest.java | 67 +
.../internal/sql/engine/planner/PlannerTest.java | 33 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 2 -
.../internal/sql/engine/util/CommonsTest.java | 26 +-
.../internal/sql/engine/util/PlanUtilsTest.java | 2 +
.../internal/sql/engine/util/CursorUtils.java | 4 +-
.../internal/sql/engine/util/SqlTestUtils.java | 11 +-
.../storage/util/MvPartitionStoragesTest.java | 112 +-
.../storage/AbstractMvTableStorageTest.java | 35 +-
.../storage/index/AbstractIndexStorageTest.java | 28 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 2 +-
modules/system-view/README.md | 3 +
modules/system-view/build.gradle | 52 +
.../internal/systemview/ClusterSystemView.java | 86 +
.../ignite/internal/systemview/NodeSystemView.java | 118 +
.../ignite/internal/systemview/SystemView.java | 191 +
.../internal/systemview/SystemViewColumn.java | 94 +
.../ignite/internal/systemview/SystemViews.java | 51 +
.../ignite/internal/systemview/SystemViewTest.java | 276 +
.../ItInternalTableReadWriteScanTest.java | 6 +-
.../ignite/distributed/ItTablePersistenceTest.java | 4 +-
.../distributed/ItTxDistributedTestSingleNode.java | 3 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 4 +-
.../ignite/internal/table/ItColocationTest.java | 5 +-
.../internal/table/distributed/TableManager.java | 60 +-
.../raft/snapshot/PartitionSnapshotStorage.java | 13 +
.../snapshot/PartitionSnapshotStorageFactory.java | 13 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 126 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 8 +-
.../snapshot/outgoing/OutgoingSnapshotReader.java | 2 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 6 +-
.../schema/CatalogVersionSufficiency.java} | 27 +-
.../schema/CheckCatalogVersionOnActionRequest.java | 78 +
.../schema/CheckCatalogVersionOnAppendEntries.java | 21 +-
.../distributed/storage/InternalTableImpl.java | 25 +-
.../RepeatedFinishReadWriteTransactionTest.java | 43 +-
.../apache/ignite/internal/table/TxLocalTest.java | 24 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../PartitionSnapshotStorageFactoryTest.java | 3 +
.../snapshot/PartitionSnapshotStorageTest.java | 2 +
.../incoming/IncomingSnapshotCopierTest.java | 254 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 11 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 6 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 2 +
.../OutgoingSnapshotTxDataStreamingTest.java | 6 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 6 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 5 +-
.../schema/CatalogVersionSufficiencyTest.java} | 39 +-
.../CheckCatalogVersionOnActionRequestTest.java | 139 +
.../distributed/storage/InternalTableImplTest.java | 7 +-
.../table/type/NumericTypesSerializerTest.java | 30 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 13 +-
.../ignite/internal/table/TableTestUtils.java | 10 +-
.../ignite/internal/table/TxAbstractTest.java | 7 +-
.../table/impl/DummyInternalTableImpl.java | 21 +-
.../ignite/internal/tx/HybridTimestampTracker.java | 52 +
.../org/apache/ignite/internal/tx/TxManager.java | 33 +-
.../internal/tx/impl/IgniteTransactionsImpl.java | 32 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 11 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 35 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 74 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 3 +-
packaging/db/ignite.java.util.logging.properties | 5 +-
settings.gradle | 2 +
301 files changed, 11117 insertions(+), 6568 deletions(-)
copy modules/{platforms/dotnet/Apache.Ignite.Benchmarks/Program.cs =>
catalog/src/main/java/org/apache/ignite/internal/catalog/CatalogCommand.java}
(69%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursor.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/TableExistsValidationException.java}
(65%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursor.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/TableNotFoundValidationException.java}
(67%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/ExecutionService.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/UpdateProducer.java}
(56%)
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DropTableParams.java
=> AbstractCatalogCommand.java} (64%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/AbstractTableCommand.java
rename
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/{DropTableParams.java
=> AbstractTableCommandBuilder.java} (55%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/CreateTableCommand.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/CreateTableCommandBuilder.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/CreateTableParams.java
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DropTableCommand.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursor.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DropTableCommandBuilder.java}
(65%)
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/AbstractCommandValidationTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/CreateTableCommandValidationTest.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/commands/DropTableCommandValidationTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/questions/ItConnectToBasicAuthClusterTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/questions/ItConnectToSslAndAuthClusterTest.java
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/{ConnectSslConfigCallInput.java
=> AuthConfig.java} (66%)
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectSslCall.java
delete mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectSslConfigCall.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectSuccessCall.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectWizardCall.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/connect/ConnectionChecker.java
rename modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine
=> core/src/main/java/org/apache/ignite/internal/util}/AsyncCursor.java (98%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
core/src/main/java/org/apache/ignite/internal/util}/AsyncWrapper.java (97%)
rename
modules/{sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec =>
core/src/test/java/org/apache/ignite/internal/util}/AsyncWrapperSelfTest.java
(97%)
create mode 100644
modules/jdbc/src/integrationTest/java/org/apache/ignite/jdbc/util/JdbcTestUtils.java
create mode 100644
modules/platforms/cpp/ignite/odbc/query/table_metadata_query.cpp
create mode 100644
modules/platforms/cpp/ignite/odbc/query/table_metadata_query.h
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/IgniteClientExtensions.cs
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/{core/AppendEntriesRequestInterceptor.java
=> ActionRequestInterceptor.java} (70%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/{core/InterceptingAppendEntriesRequestProcessor.java
=> InterceptingActionRequestProcessor.java} (50%)
copy
modules/{cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/raft/RocksDbClusterStateStorageManagerTest.java
=>
raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/NullActionRequestInterceptor.java}
(60%)
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/fun/SqlSubstringFunction.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MapReduceAggregatesTest.java
create mode 100644 modules/system-view/README.md
create mode 100644 modules/system-view/build.gradle
create mode 100644
modules/system-view/src/main/java/org/apache/ignite/internal/systemview/ClusterSystemView.java
create mode 100644
modules/system-view/src/main/java/org/apache/ignite/internal/systemview/NodeSystemView.java
create mode 100644
modules/system-view/src/main/java/org/apache/ignite/internal/systemview/SystemView.java
create mode 100644
modules/system-view/src/main/java/org/apache/ignite/internal/systemview/SystemViewColumn.java
create mode 100644
modules/system-view/src/main/java/org/apache/ignite/internal/systemview/SystemViews.java
create mode 100644
modules/system-view/src/test/java/org/apache/ignite/internal/systemview/SystemViewTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursor.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/schema/CatalogVersionSufficiency.java}
(50%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/schema/CheckCatalogVersionOnActionRequest.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImplTest.java
=>
table/src/test/java/org/apache/ignite/internal/table/distributed/schema/CatalogVersionSufficiencyTest.java}
(51%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/schema/CheckCatalogVersionOnActionRequestTest.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/HybridTimestampTracker.java
