This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-27242
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from a9e69ed310e minor
add 958f1ccfdd9 IGNITE-26985 Marshaller java records support (#6931)
add 31decb26df4 IGNITE-27095 Jdbc. Get rid of JdbcResultSetBaseSelfTest
and JdbcResultSetMetadataBaseSelfTest (#7172)
add 3a88fd9defc IGNITE-27261 Graceful TimeoutException handling within
CMG/MG groups on node stop (#7193)
add 777d97e0989 IGNITE-26796 Improve java doc (#7195)
add d8b296c932d IGNITE-27309 .NET: Improve tx logging (#7204)
add eef474c591f IGNITE-27286 Sql. Set class loader explicitly for
expression compilation (#7190)
add 2bf1e14b392 IGNITE-27311 Fix client KeyValueView DataStreamer column
order mixup (#7205)
add 97c064c39c0 IGNITE-27012 Improve partition API (#7091)
add a5f7c91ccb1 IGNITE-26634 Sql. Remove class-level generic from SQL
expressions (#7181)
add 014873b3947 IGNITE-27315 Marshaller java records test fixtures
checkstyle (#7209)
add fedaaa260d6 IGNITE-27290 Add new components to handshake managers
(#7191)
add 15140b5f184 IGNITE-26846 Adjust InternalTable.scan methods (#7155)
add c3a061ebfd3 IGNITE-26107 Add Vault storage format compatibility tests
(#7192)
add 1de12419d47 IGNITE-26286 Implement reset operation (#7198)
add b0b043262b9 IGNITE-27084 Sql. Improve printout of searchBounds in
EXPLAIN (#7150)
add f507cb7cd67 IGNITE-27322 .NET: Extract common test functionality into
a separate project (#7215)
add db73d706343 IGNITE-27097 Improve recovery from interrupted Raft
snapshot install (#7207)
add 26400f6af94 IGNITE-27307 Migration Tools: flush logs on error in
Ignite3ClusterContainer (#7214)
add 5c66de1ad45 IGNITE-27300 Jdbc. Improved compatibility error message
(#7211)
add 5212ae6ca58 IGNITE-27330 Remove unused localAssignment from
PartitionReplicaLifecycleManager (#7221)
add 2414dcdd275 IGNITE-26635 Sql. Decouple ExpressionExecution part from
ExecutionContext (#7212)
add 26904f638f7 IGNITE-23457 Sql. Coordinator failed to send close message
after query cancellation (#7194)
add c00c32776dc IGNITE-21099 .NET: Ensure AOT compatibility (#7217)
add 5c2982065de IGNITE-27321 Thin Client. DML failed in explicit
transaction (#7216)
add be8cf18d440 IGNITE-27335 Fix client data streamer observable timestamp
(#7224)
add b50eac3a0be IGNITE-27299 Limit maximum heap size in CLI (#7197)
add a339fe045e7 IGNITE-27343 Declare explicit serial version UID in
SnapshotMeta impl (#7229)
add 6f26450478b IGNITE-27115 Fix client RO TX read timestamp (#7118)
add b7ba2f3f571 IGNITE-26476 Add new log storage configuration (#7225)
add 1232ff1dd65 IGNITE-27319 Rework PartitionListener to be
TablePartitionProcessor and not RaftGroupListener (#7218)
add 563a4a7c621 Ignite-27267 Remove colocation-specific temporary tests
along with some non-colocation if-clauses. (#7230)
add 63bc9aaf475 Merge branch 'main' into ignite-27242
No new revisions were added by this update.
Summary of changes:
.../platform_tests/PlatformDotnetTestsLinux.kt | 15 +-
.../tests/e2e/ErrorHandlingTest.java | 3 +-
.../tests/e2e/IgniteClientCredentialsTest.java | 4 +-
.../tests/bases/MigrationTestBase.java | 3 +-
.../tests/containers/Ignite3ClusterContainer.java | 63 +-
.../apache/ignite/catalog/annotations/Column.java | 3 +-
.../main/java/org/apache/ignite/table/Table.java | 9 +
.../apache/ignite/table/mapper/MapperBuilder.java | 8 +-
.../apache/ignite/table/partition/Partition.java | 9 +-
.../table/partition/PartitionDistribution.java | 137 +
.../ignite/table/partition/PartitionManager.java | 49 +-
.../handler/ClientInboundMessageHandler.java | 5 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 2 +-
...blePartitionPrimaryReplicasNodesGetRequest.java | 7 +-
.../requests/tx/ClientTransactionBeginRequest.java | 1 +
.../apache/ignite/client/ClientOperationType.java | 4 +-
.../internal/client/compute/ClientCompute.java | 9 +-
.../ignite/internal/client/sql/ClientSql.java | 26 +-
.../internal/client/table/ClientKeyValueView.java | 14 +-
.../client/table/ClientPartitionManager.java | 73 +-
.../ignite/internal/client/table/ClientTable.java | 6 +
...t.java => ClientPartitionDistributionTest.java} | 16 +-
.../management/ClusterManagementGroupManager.java | 14 +
.../cluster/management/raft/CmgRaftService.java | 8 +
modules/compatibility-tests/build.gradle | 1 +
modules/compatibility-tests/jobs.gradle | 1 +
.../internal/ItVaultStorageCompatibilityTest.java | 78 +
...cOverThinSqlWithOldServerCompatibilityTest.java | 13 +-
.../ignite/internal/compute/CheckpointJob.java | 7 +-
.../internal/compute/PutVaultEntriesJob.java | 66 +
.../compute/SendAllMetastorageCommandTypesJob.java | 49 +-
.../internal/compute/TruncateRaftLogCommand.java | 25 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 31 +-
.../internal/compute/utils/InteractiveJobs.java | 3 +-
.../ignite/internal/compute/GetPartitionJob.java | 7 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 2 +-
.../compute/PartitionNextWorkerSelector.java | 3 +-
.../internal/table/partition/HashPartition.java | 3 +-
modules/java-records-tests/README.md | 3 +
.../build.gradle | 41 +-
.../schema/marshaller/ItTableViewTest.java | 189 +
.../internal/schema/marshaller/MarshallerTest.java | 174 +
.../schema/marshaller/AssertMarshaller.java | 105 +
.../ignite/internal/schema/marshaller/Records.java | 477 +++
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 8 +-
.../internal/jdbc/JdbcResultSetBaseSelfTest.java | 4080 --------------------
.../jdbc/JdbcResultSetMetadataBaseSelfTest.java | 320 --
.../jdbc/JdbcResultSetMetadataSelfTest.java | 282 +-
.../internal/jdbc/JdbcResultSetSelfTest.java | 4026 ++++++++++++++++++-
.../apache/ignite/internal/marshaller/Creator.java | 97 +
.../CreatorFromAnnotatedConstructorParameters.java | 113 +
...rFromAnnotatedFieldsWithDefaultConstructor.java | 62 +
.../ignite/internal/marshaller/FieldAccessor.java | 112 +-
.../ignite/internal/marshaller/Marshaller.java | 32 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 8 +
.../metastorage/impl/MetaStorageServiceImpl.java | 8 +
.../internal/network/processor/MessageClass.java | 24 +-
.../processor/messages/MessageImplGenerator.java | 9 +
.../network/processor/tests/GenerationTest.java | 16 +
.../network/processor/tests/OtherMessages.java | 2 +
...Transient.java => MessageSerialVersionUid.java} | 19 +-
modules/network/build.gradle | 2 +
.../network/netty/ItConnectionManagerTest.java | 6 +-
.../internal/network/netty/ConnectionManager.java | 122 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 10 +-
.../RecoveryInitiatorHandshakeManager.java | 16 +-
.../RecoveryInitiatorHandshakeManagerFactory.java | 40 -
.../scalecube/ScaleCubeClusterServiceFactory.java | 4 +-
.../network/DefaultMessagingServiceTest.java | 100 +-
.../network/netty/RecoveryHandshakeTest.java | 12 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 7 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 9 +-
.../replicator/ItAbstractColocationTest.java | 3 -
.../replicator/ItBigZoneOperationTest.java | 3 -
.../partition/replicator/ItBuildIndexTest.java | 121 -
.../replicator/ItCatalogCompactionTest.java | 164 -
.../replicator/ItColocationTxRecoveryTest.java | 98 -
.../replicator/ItTransactionsVacuumTest.java | 131 -
.../partition/replicator/ItZoneInMemoryTest.java | 4 -
.../partition/replicator/ItZoneTxFinishTest.java | 248 --
.../ItZonePartitionRaftListenerRecoveryTest.java | 11 +-
.../LocalBeforeReplicaStartEventParameters.java | 79 +
.../PartitionReplicaLifecycleManager.java | 42 +-
.../partition/replicator/ZoneResourcesManager.java | 4 +
.../handlers/WriteIntentSwitchRequestHandler.java | 4 +-
.../raft/snapshot/PartitionSnapshotStorage.java | 37 +-
.../PartitionReplicaLifecycleManagerTest.java | 2 -
.../raft/ZonePartitionRaftListenerTest.java | 12 +-
.../incoming/IncomingSnapshotCopierTest.java | 4 +-
.../Apache.Extensions.Caching.Ignite.csproj | 2 +
.../ServerBenchmarkBase.cs | 2 +-
.../.editorconfig | 8 -
.../Apache.Ignite.Tests.Aot.csproj | 25 +
.../dotnet/Apache.Ignite.Tests.Aot/Assert.cs | 47 +
.../Compute/ComputeTests.cs | 89 +
.../dotnet/Apache.Ignite.Tests.Aot/Program.cs | 48 +
.../dotnet/Apache.Ignite.Tests.Aot/README.md | 14 +
.../dotnet/Apache.Ignite.Tests.Aot/Sql/SqlTests.cs | 145 +
.../Apache.Ignite.Tests.Aot/Table/TableTests.cs | 162 +
.../dotnet/Apache.Ignite.Tests.Aot/TestRunner.cs | 56 +
.../Transactions/TransactionsTests.cs | 68 +
.../.editorconfig | 8 -
.../Apache.Ignite.Tests.Common.csproj | 16 +
.../Apache.Ignite.Tests.Common.snk} | Bin
.../CommonTestUtils.cs} | 37 +-
.../Compute/DotNetJobs.cs | 25 +-
.../Apache.Ignite.Tests.Common/Compute/JavaJobs.cs | 63 +
.../Compute/TestCases.cs | 4 +-
.../ConsoleLogger.cs | 3 +-
.../DisposeAction.cs} | 27 +-
.../Apache.Ignite.Tests.Common/JavaServer.cs | 388 ++
.../Apache.Ignite.Tests.Common/ListLogger.cs | 77 +
.../ListLoggerFactory.cs | 2 +-
.../Table/KeyPoco.cs | 2 +-
.../Table/KeyValPocoMapper.cs | 6 +-
.../Table/Poco.cs} | 8 +-
.../Apache.Ignite.Tests.Common/Table/Poco2.cs} | 35 +-
.../Table/PocoAllColumns.cs} | 20 +-
.../Table/PocoAllColumnsBigDecimal.cs} | 20 +-
.../Table/PocoAllColumnsBigDecimalMapper.cs | 4 +-
.../Table/PocoAllColumnsMapper.cs | 4 +-
.../Table/PocoAllColumnsNullable.cs} | 23 +-
.../Table/PocoAllColumnsNullableMapper.cs | 4 +-
.../Table/PocoAllColumnsSql.cs | 2 +-
.../Table/PocoAllColumnsSqlMapper.cs | 10 +-
.../Table/PocoAllColumnsSqlNullable.cs | 2 +-
.../Table/PocoAllColumnsSqlNullableMapper.cs | 4 +-
.../Table/PocoCustomNames.cs | 2 +-
.../Table/PocoEnums.cs | 2 +-
.../Table/PocoMapper.cs | 4 +-
.../Table/PocoStruct.cs | 2 +-
.../Apache.Ignite.Tests.Common/Table/TestTables.cs | 47 +
.../Table/ValPoco.cs} | 6 +-
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 1 +
.../CurrentClientWithOldServerCompatibilityTest.cs | 1 +
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 44 +-
.../Compute/Executor/DeploymentUnitLoaderTests.cs | 5 +-
.../Executor/DotNetJobUtils.cs} | 32 +-
.../Compute/Executor/JobLoadContextTests.cs | 1 +
.../Compute/JobDescriptorTests.cs | 1 +
.../Compute/PlatformComputeCompatibilityTests.cs | 4 +-
.../Compute/PlatformComputeTests.cs | 14 +-
.../ExceptionCodeAsStringTests.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/HeartbeatTests.cs | 1 +
.../dotnet/Apache.Ignite.Tests/IgniteProxyTests.cs | 1 +
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 33 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 389 --
.../Linq/LinqSqlGenerationTests.KvView.cs | 2 +-
.../Linq/LinqSqlGenerationTests.cs | 2 +-
.../Linq/LinqTests.Aggregate.cs | 2 +-
.../Linq/LinqTests.AsyncMaterialization.cs | 2 +-
.../Apache.Ignite.Tests/Linq/LinqTests.Dml.cs | 2 +-
.../Linq/LinqTests.Functions.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/Linq/LinqTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/ListLogger.cs | 79 -
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 1 +
.../dotnet/Apache.Ignite.Tests/MultiClusterTest.cs | 1 +
.../PartitionAwarenessRealClusterTests.cs | 5 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 5 +-
.../Apache.Ignite.Tests/SocketTimeoutTest.cs | 1 +
.../Sql/IgniteDbCommandTests.cs | 1 +
.../Sql/IgniteDbDataReaderTests.cs | 2 +-
.../Sql/SqlResultSetObjectMappingTests.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 1 +
.../Table/DataStreamerPlatformReceiverTests.cs | 4 +-
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 16 +-
.../Table/KeyValueViewBinaryTests.cs | 1 +
.../Table/KeyValueViewPocoPrimitiveTests.cs | 1 +
.../Table/KeyValueViewPocoTests.cs | 1 +
.../Table/KeyValueViewPrimitivePocoTests.cs | 1 +
.../Table/KeyValueViewPrimitiveTests.cs | 1 +
.../Table/PartitionManagerTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/Table/Poco.cs | 40 -
.../dotnet/Apache.Ignite.Tests/Table/Poco2.cs | 44 -
.../Apache.Ignite.Tests/Table/PocoAllColumns.cs | 40 -
.../Table/PocoAllColumnsBigDecimal.cs | 40 -
.../Table/PocoAllColumnsNullable.cs | 47 -
.../Table/RecordViewBinaryTests.cs | 1 +
.../Table/RecordViewDefaultMappingTest.cs | 1 +
.../Table/RecordViewPocoTests.cs | 5 +-
.../Table/RecordViewPrimitiveTests.cs | 1 +
.../Table/SchemaSynchronizationTest.cs | 7 +-
.../Table/SchemaValidationTest.cs | 2 +
.../Serialization/MapperSerializerHandlerTests.cs | 1 +
.../Serialization/SerializerHandlerTestBase.cs | 1 +
.../Apache.Ignite.Tests/Table/TablesTests.cs | 2 +
.../dotnet/Apache.Ignite.Tests/Table/ValPoco.cs | 36 -
.../TestHelpers/ManagementApi.cs | 7 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 197 +-
.../Transactions/TransactionsTests.cs | 3 +-
modules/platforms/dotnet/Apache.Ignite.sln | 12 +
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 6 +
.../Apache.Ignite/IgniteClientConfiguration.cs | 8 +-
.../Internal/Buffers/ByteArrayPool.cs | 23 +-
.../Apache.Ignite/Internal/ClientSocket.Server.cs | 8 +
.../Apache.Ignite/Internal/Compute/Compute.cs | 16 +-
.../Compute/Executor/ComputeJobExecutor.cs | 7 +
.../Compute/Executor/DeploymentUnitLoader.cs | 3 +
.../Internal/Compute/Executor/JobLoadContext.cs | 13 +-
.../Compute/Executor/JobLoadContextCache.cs | 1 +
.../Internal/Linq/EnumerableHelper.cs | 57 -
.../Internal/Linq/IgniteQueryExecutor.cs | 6 +
.../Internal/Linq/IgniteQueryExpressionVisitor.cs | 2 +
.../Internal/Linq/IgniteQueryModelVisitor.cs | 1 +
.../Internal/Linq/IgniteQueryProvider.cs | 2 +
.../Apache.Ignite/Internal/Linq/IgniteQueryable.cs | 2 +
.../Apache.Ignite/Internal/Linq/MethodVisitor.cs | 1 +
.../Apache.Ignite/Internal/Linq/ResultSelector.cs | 2 +
.../dotnet/Apache.Ignite/Internal/LogMessages.cs | 27 +
.../Internal/Sql/ColumnTypeExtensions.cs | 2 +
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 4 +
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 2 +
.../Internal/Table/PartitionManager.cs | 1 +
.../Apache.Ignite/Internal/Table/RecordView.cs | 1 +
.../Table/Serialization/BinaryTupleMethods.cs | 2 +
.../Table/Serialization/ILGeneratorExtensions.cs | 2 +
.../Table/Serialization/ObjectSerializerHandler.cs | 2 +
.../Table/Serialization/ReflectionUtils.cs | 8 +
.../StreamerReceiverJob.cs | 7 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 3 +
.../Internal/Transactions/LazyTransaction.cs | 30 +-
.../Internal/Transactions/Transactions.cs | 11 +-
.../Apache.Ignite/Marshalling/JsonMarshaller.cs | 3 +
modules/platforms/dotnet/Apache.Ignite/Sql/ISql.cs | 4 +
.../dotnet/Apache.Ignite/Sql/IgniteDbCommand.cs | 2 +-
.../dotnet/Apache.Ignite/Sql/IgniteDbDataReader.cs | 2 +
.../dotnet/Apache.Ignite/Table/IKeyValueView.cs | 3 +
.../Apache.Ignite/Table/IPartitionManager.cs | 3 +
.../dotnet/Apache.Ignite/Table/IRecordView.cs | 3 +
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 4 +
.../LogStorageConfigurationSchema.java} | 32 +-
.../configuration/RaftConfigurationSchema.java | 4 +
.../internal/raft/service/RaftGroupService.java | 8 +
modules/raft/build.gradle | 2 +
...InterruptedRaftSnapshotStorageRecoveryTest.java | 274 ++
.../ignite/internal/raft/RaftGroupServiceImpl.java | 29 +-
.../raft/storage/segstore/IndexFileManager.java | 1 +
.../raft/storage/segstore/IndexMemTable.java | 14 +
.../raft/storage/segstore/RaftLogCheckpointer.java | 13 +-
.../raft/storage/segstore/SegmentFileManager.java | 212 +-
.../raft/storage/segstore/SegmentInfo.java | 17 +
.../raft/storage/segstore/SegmentPayload.java | 18 +
.../storage/segstore/SegmentPayloadParser.java | 160 +
.../raft/storage/segstore/SegstoreLogStorage.java | 11 +-
.../storage/segstore/WriteModeIndexMemTable.java | 5 +
.../ignite/raft/jraft/entity/RaftOutter.java | 2 +
.../storage/segstore/IndexFileManagerTest.java | 71 +
.../raft/storage/segstore/IndexMemTableTest.java | 229 +-
.../storage/segstore/RaftLogCheckpointerTest.java | 5 +-
.../segstore/SegmentFileManagerGetEntryTest.java | 17 +-
.../storage/segstore/SegmentFileManagerTest.java | 101 +-
.../SegstoreLogStorageConcurrencyTest.java | 18 +-
.../storage/segstore/SegstoreLogStorageTest.java | 45 +-
.../raft/jraft/entity/SnapshotMetaTest.java} | 13 +-
.../PhysicalTopologyAwareRaftGroupService.java | 5 +
.../raft/client/TopologyAwareRaftGroupService.java | 5 +
.../ignite/internal/replicator/ReplicaService.java | 20 +-
.../replicator/message/ReplicaMessageUtils.java | 22 -
.../ignite/internal/app/AsyncApiOperation.java | 10 +
.../org/apache/ignite/internal/app/References.java | 3 +
.../ignite/internal/app/SyncApiOperation.java | 16 +
.../benchmark/AbstractColocationBenchmark.java | 132 -
.../benchmark/ColocationInsertBenchmark.java | 101 -
.../benchmark/ColocationSelectBenchmark.java | 135 -
.../runner/app/PlatformTestNodeRunner.java | 5 +-
.../runner/app/client/ItThinClientSqlTest.java | 49 +
.../app/client/ItThinClientTransactionsTest.java | 50 +-
...ClientTransactionsWithBrokenReplicatorTest.java | 13 +-
.../ItThinClientTransactionsWithReplicasTest.java | 4 +-
.../streamer/ItAbstractDataStreamerTest.java | 247 +-
.../table/ItColocationDurableFinishTest.java | 50 -
.../internal/table/ItPublicApiColocationTest.java | 4 -
...va => ItAbstractPartitionDistributionTest.java} | 62 +-
... => ItStandalonePartitionDistributionTest.java} | 8 +-
... => ItThinClientPartitionDistributionTest.java} | 8 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +
.../restart/RestartProofPartitionManager.java | 52 +-
.../ignite/internal/restart/RestartProofTable.java | 8 +-
.../java/org/apache/ignite/internal/Cluster.java | 8 +-
.../internal/sql/engine/ItColocatedDataTest.java | 3 -
.../internal/sql/engine/ItCreateTableDdlTest.java | 21 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 12 +
.../internal/sql/engine/ItOrToUnionRuleTest.java | 2 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 120 +-
.../ignite/internal/sql/engine/ItSetOpTest.java | 3 -
.../integrationTest/sql/group1/explain/scan.test | 6 +-
.../internal/sql/engine/InternalSqlRowImpl.java | 2 +-
.../internal/sql/engine/SqlQueryProcessor.java | 3 +-
.../sql/engine/exec/DynamicPartitionProvider.java | 2 +-
.../internal/sql/engine/exec/ExecutionContext.java | 36 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 21 +-
.../sql/engine/exec/LogicalRelImplementor.java | 111 +-
.../exec/ProjectedTableRowConverterImpl.java | 1 -
...leRowConverterFactory.java => RowAccessor.java} | 19 +-
.../internal/sql/engine/exec/RowFactory.java | 118 +
...{ExecutablePlan.java => RowFactoryFactory.java} | 27 +-
.../internal/sql/engine/exec/RowHandler.java | 127 +-
.../internal/sql/engine/exec/RuntimeHashIndex.java | 2 +-
.../sql/engine/exec/RuntimeSortedIndex.java | 4 +-
.../internal/sql/engine/exec/ScannableTable.java | 1 -
.../sql/engine/exec/ScannableTableImpl.java | 7 +-
.../sql/engine/exec/SqlEvaluationContext.java | 40 +
.../internal/sql/engine/exec/SqlRowHandler.java | 17 +-
.../sql/engine/exec/TableRowConverter.java | 2 +-
.../sql/engine/exec/TableRowConverterImpl.java | 6 +-
.../sql/engine/exec/UpdatableTableImpl.java | 34 +-
.../sql/engine/exec/exp/BiFieldGetter.java | 2 +-
.../sql/engine/exec/exp/ComparatorImplementor.java | 121 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 34 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 33 +-
.../internal/sql/engine/exec/exp/FieldGetter.java | 2 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 13 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 35 +-
.../sql/engine/exec/exp/PredicateImplementor.java | 13 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 35 +-
.../sql/engine/exec/exp/RangeIterable.java | 2 +-
.../engine/exec/exp/RowProviderImplementor.java | 45 +-
.../sql/engine/exec/exp/ScalarImplementor.java | 21 +-
.../engine/exec/exp/SearchBoundsImplementor.java | 82 +-
.../sql/engine/exec/exp/SqlComparator.java | 13 +-
.../sql/engine/exec/exp/SqlJoinPredicate.java | 11 +-
.../sql/engine/exec/exp/SqlJoinProjection.java | 11 +-
.../internal/sql/engine/exec/exp/SqlPredicate.java | 11 +-
.../sql/engine/exec/exp/SqlProjection.java | 11 +-
...Scalar.java => SqlRangeConditionsProvider.java} | 24 +-
.../sql/engine/exec/exp/SqlRowProvider.java | 17 +-
.../internal/sql/engine/exec/exp/SqlScalar.java | 10 +-
.../sql/engine/exec/exp/ValuesImplementor.java | 72 -
.../engine/exec/exp/agg/AccumulatorsFactory.java | 18 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 2 +-
.../exec/exp/func/SystemRangeTableFunction.java | 4 +-
.../exec/exp/func/TableFunctionRegistryImpl.java | 4 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 6 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 6 +-
.../sql/engine/exec/rel/DataSourceScanNode.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 38 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../sql/engine/exec/rel/IndexScanNode.java | 6 +-
.../sql/engine/exec/rel/IntersectNode.java | 2 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 43 +-
.../internal/sql/engine/exec/rel/MinusNode.java | 2 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 12 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 28 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 6 +-
.../sql/engine/exec/rel/TableScanNode.java | 5 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 88 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 28 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 10 +-
.../sql/engine/prepare/SelectCountPlan.java | 6 +-
.../prepare/pruning/PartitionPruningPredicate.java | 2 +-
.../engine/rel/explain/RelTreeToTextWriter.java | 132 +-
.../ignite/internal/sql/engine/util/Commons.java | 1 +
.../internal/sql/engine/util/IgniteMethod.java | 15 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 18 +-
.../sql/engine/exec/DummyScannableTable.java | 1 -
.../sql/engine/exec/ExecutionServiceImplTest.java | 191 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 11 +-
.../sql/engine/exec/PartitionsResolutionTest.java | 5 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 3 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../sql/engine/exec/TableRowConverterSelfTest.java | 11 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 121 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 22 +-
.../engine/exec/rel/AbstractJoinExecutionTest.java | 12 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 8 +-
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 14 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 8 +-
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 14 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 34 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 10 +-
.../sql/engine/exec/rel/ExecutionTest.java | 12 +-
.../sql/engine/exec/rel/FilterExecutionTest.java | 6 +
.../exec/rel/HashAggregateExecutionTest.java | 12 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 12 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 6 +
.../exec/rel/IndexScanNodeExecutionTest.java | 12 +-
.../engine/exec/rel/IntersectExecutionTest.java | 4 +-
.../sql/engine/exec/rel/LimitExecutionTest.java | 6 +
.../engine/exec/rel/MergeJoinExecutionTest.java | 10 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 2 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 30 +-
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 6 +
.../engine/exec/rel/ScannableTableSelfTest.java | 14 +-
.../exec/rel/SortAggregateExecutionTest.java | 14 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 6 +
.../exec/rel/SystemRangeTableFunctionTest.java | 6 +
.../exec/rel/TableScanNodeExecutionTest.java | 12 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 6 +
.../sql/engine/exec/row/SqlRowHandlerTest.java | 35 +-
.../sql/engine/framework/ArrayRowHandler.java | 17 +-
.../sql/engine/framework/TestBuilders.java | 5 +-
.../sql/engine/framework/TestClusterTest.java | 2 +-
.../internal/sql/engine/framework/TestNode.java | 5 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 2 +-
.../internal/sql/engine/util/CommonsTest.java | 27 +
.../internal/sql/engine/util/TypeUtilsTest.java | 1 +
.../src/test/resources/tpcds/plan/q9.plan | 2 +-
.../src/test/resources/tpch/plan/q1.plan | 2 +-
.../src/test/resources/tpch/plan/q10.plan | 2 +-
.../src/test/resources/tpch/plan/q12.plan | 2 +-
.../src/test/resources/tpch/plan/q14.plan | 2 +-
.../src/test/resources/tpch/plan/q15.plan | 4 +-
.../src/test/resources/tpch/plan/q17.plan | 2 +-
.../src/test/resources/tpch/plan/q2.plan | 2 +-
.../src/test/resources/tpch/plan/q20.plan | 2 +-
.../src/test/resources/tpch/plan/q21.plan | 4 +-
.../src/test/resources/tpch/plan/q22.plan | 2 +-
.../src/test/resources/tpch/plan/q3.plan | 4 +-
.../src/test/resources/tpch/plan/q4.plan | 4 +-
.../src/test/resources/tpch/plan/q6.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q12.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q14.plan | 2 +-
.../src/test/resources/tpch/plan/variant_q8.plan | 2 +-
.../internal/sql/engine/util/QueryChecker.java | 15 +
.../ItTxObservableTimePropagationTest.java | 8 +-
.../ReplicasSafeTimePropagationTest.java | 36 +-
...> ItPartitionDistributionApiThreadingTest.java} | 42 +-
.../ignite/internal/table/InternalTable.java | 35 +-
.../apache/ignite/internal/table/TableImpl.java | 6 +
.../table/distributed/PublicApiThreadingTable.java | 6 +
.../internal/table/distributed/TableManager.java | 159 +-
...nListener.java => TablePartitionProcessor.java} | 89 +-
.../distributed/raft/handlers/package-info.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 4 -
.../table/partition/HashPartitionManagerImpl.java | 84 +-
.../PublicApiThreadingPartitionManager.java | 58 +-
.../raft/PartitionCommandListenerTest.java | 289 +-
.../distributed/storage/InternalTableImplTest.java | 7 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../internal/table/TxInfrastructureTest.java | 8 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
.../readonly/ItReadOnlyTxAndLowWatermarkTest.java | 12 +-
.../ignite/internal/tx/InternalTxOptions.java | 2 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 4 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 4 +-
packaging/build.gradle | 1 +
packaging/cli/build.gradle | 2 +-
packaging/cli/start.sh | 1 +
settings.gradle | 2 +
441 files changed, 11776 insertions(+), 9318 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/partition/PartitionDistribution.java
rename
modules/client/src/test/java/org/apache/ignite/client/{ClientPartitionManagerTest.java
=> ClientPartitionDistributionTest.java} (82%)
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/ItVaultStorageCompatibilityTest.java
create mode 100644
modules/compatibility-tests/src/jobs/java/org/apache/ignite/internal/compute/PutVaultEntriesJob.java
create mode 100644 modules/java-records-tests/README.md
copy modules/{failure-handler => java-records-tests}/build.gradle (61%)
create mode 100644
modules/java-records-tests/src/integrationTest/java/org/apache/ignite/internal/schema/marshaller/ItTableViewTest.java
create mode 100644
modules/java-records-tests/src/test/java/org/apache/ignite/internal/schema/marshaller/MarshallerTest.java
create mode 100644
modules/java-records-tests/src/testFixtures/java/org/apache/ignite/internal/schema/marshaller/AssertMarshaller.java
create mode 100644
modules/java-records-tests/src/testFixtures/java/org/apache/ignite/internal/schema/marshaller/Records.java
delete mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetBaseSelfTest.java
delete mode 100644
modules/jdbc/src/test/java/org/apache/ignite/internal/jdbc/JdbcResultSetMetadataBaseSelfTest.java
create mode 100644
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/Creator.java
create mode 100644
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/CreatorFromAnnotatedConstructorParameters.java
create mode 100644
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/CreatorFromAnnotatedFieldsWithDefaultConstructor.java
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/annotations/{Transient.java
=> MessageSerialVersionUid.java} (66%)
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/RecoveryInitiatorHandshakeManagerFactory.java
delete mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItBuildIndexTest.java
delete mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItCatalogCompactionTest.java
delete mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItColocationTxRecoveryTest.java
delete mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItTransactionsVacuumTest.java
delete mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItZoneTxFinishTest.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/LocalBeforeReplicaStartEventParameters.java
copy modules/platforms/dotnet/{Apache.Extensions.Caching.Ignite.Tests =>
Apache.Ignite.Tests.Aot}/.editorconfig (83%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Apache.Ignite.Tests.Aot.csproj
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Assert.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Program.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests.Aot/README.md
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Sql/SqlTests.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Table/TableTests.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/TestRunner.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Transactions/TransactionsTests.cs
copy modules/platforms/dotnet/{Apache.Extensions.Caching.Ignite.Tests =>
Apache.Ignite.Tests.Common}/.editorconfig (83%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Common/Apache.Ignite.Tests.Common.csproj
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Apache.Ignite.Tests.snk =>
Apache.Ignite.Tests.Common/Apache.Ignite.Tests.Common.snk} (100%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests/DisposeAction.cs =>
Apache.Ignite.Tests.Common/CommonTestUtils.cs} (54%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Compute/DotNetJobs.cs (85%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Common/Compute/JavaJobs.cs
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Compute/TestCases.cs (97%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/ConsoleLogger.cs (98%)
copy modules/platforms/dotnet/{Apache.Ignite/Internal/Linq/ExecutionOptions.cs
=> Apache.Ignite.Tests.Common/DisposeAction.cs} (65%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Common/JavaServer.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Common/ListLogger.cs
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/ListLoggerFactory.cs (98%)
copy modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/KeyPoco.cs (96%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/KeyValPocoMapper.cs (93%)
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Table/KeyPoco.cs =>
Apache.Ignite.Tests.Common/Table/Poco.cs} (86%)
copy modules/platforms/{cpp/ignite/network/ssl/secure_configuration.h =>
dotnet/Apache.Ignite.Tests.Common/Table/Poco2.cs} (63%)
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Table/PocoAllColumnsSql.cs
=> Apache.Ignite.Tests.Common/Table/PocoAllColumns.cs} (69%)
copy modules/platforms/dotnet/{Apache.Ignite.Tests/Table/PocoAllColumnsSql.cs
=> Apache.Ignite.Tests.Common/Table/PocoAllColumnsBigDecimal.cs} (69%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsBigDecimalMapper.cs (98%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsMapper.cs (98%)
copy
modules/platforms/dotnet/{Apache.Ignite.Tests/Table/PocoAllColumnsSqlNullable.cs
=> Apache.Ignite.Tests.Common/Table/PocoAllColumnsNullable.cs} (69%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsNullableMapper.cs (98%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsSql.cs (97%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsSqlMapper.cs (95%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsSqlNullable.cs (97%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoAllColumnsSqlNullableMapper.cs (98%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoCustomNames.cs (96%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoEnums.cs (98%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoMapper.cs (94%)
rename modules/platforms/dotnet/{Apache.Ignite.Tests =>
Apache.Ignite.Tests.Common}/Table/PocoStruct.cs (95%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests.Common/Table/TestTables.cs
rename modules/platforms/dotnet/{Apache.Ignite.Tests/Table/KeyPoco.cs =>
Apache.Ignite.Tests.Common/Table/ValPoco.cs} (91%)
copy modules/platforms/dotnet/Apache.Ignite.Tests/{TestHelpers/TempDir.cs =>
Compute/Executor/DotNetJobUtils.cs} (51%)
delete mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/JavaServer.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/ListLogger.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/Poco.cs
delete mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Table/Poco2.cs
delete mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/PocoAllColumns.cs
delete mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/PocoAllColumnsBigDecimal.cs
delete mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/PocoAllColumnsNullable.cs
delete mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/ValPoco.cs
delete mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Linq/EnumerableHelper.cs
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/configuration/GcConfigurationSchema.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/configuration/LogStorageConfigurationSchema.java}
(64%)
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/internal/raftsnapshot/ItInterruptedRaftSnapshotStorageRecoveryTest.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/SegmentPayloadParser.java
copy
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/storage/NullStorageEngineTest.java
=>
raft/src/test/java/org/apache/ignite/raft/jraft/entity/SnapshotMetaTest.java}
(72%)
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/AbstractColocationBenchmark.java
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/ColocationInsertBenchmark.java
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/ColocationSelectBenchmark.java
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItColocationDurableFinishTest.java
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItAbstractPartitionManagerTest.java
=> ItAbstractPartitionDistributionTest.java} (66%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItStandalonePartitionManagerTest.java
=> ItStandalonePartitionDistributionTest.java} (80%)
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/partition/{ItThinClientPartitionManagerTest.java
=> ItThinClientPartitionDistributionTest.java} (81%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{TableRowConverterFactory.java
=> RowAccessor.java} (67%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RowFactory.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{ExecutablePlan.java
=> RowFactoryFactory.java} (51%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/SqlEvaluationContext.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{SqlScalar.java
=> SqlRangeConditionsProvider.java} (53%)
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ValuesImplementor.java
rename
modules/table/src/integrationTest/java/org/apache/ignite/internal/threading/{ItPartitionManagerApiThreadingTest.java
=> ItPartitionDistributionApiThreadingTest.java} (70%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/{PartitionListener.java
=> TablePartitionProcessor.java} (86%)
