This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/npm_and_yarn/docs/undici-7.20.0
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard ba47ec2664f Bump undici from 7.16.0 to 7.20.0 in /docs
add 150c491f389 IGNITE-27645 Python DB API: Fix version generation (#7466)
add 32e609d8b9f IGNITE-27590 "IGN-SQL-3 Failed to parse query" error in
server logs (#7481)
add 1b0c1f8336d IGNITE-27705 .NET: Allow primitive mapping without
reflection (#7505)
add a7be03b4147 IGNITE-27569 Reintroduce page memory metrics (#7455)
add d657dd37615 IGNITE-27628 Shut down FastTimestamps scheduled executor
when interrupted (#7510)
add 23332b00e0c IGNITE-25403 Add overloads without tx to IgniteSql,
RecordView, KeyValueView (#5836)
add 758fdc41fdd IGNITE-27646 Fix
ItRebalanceMetricsTest.testRebalanceMetrics (#7472)
add c74a930f587 IGNITE-27717 Add timeout to page locking (#7514)
add 75f06185c3a IGNITE-24933 Remove late init for throttling policy (#7526)
add 22e2e77d7c7 IGNITE-24467 Fixed reset and filter rebalance race (#7445)
add 1fc419e437f .NET: Fix GetPartitionAsync exception on full tuple (#7529)
add 5ca805b7a2f IGNITE-27736 Remove PageMemory#start method (#7530)
add 4c194c0ddba Bump io.github.bonede:tree-sitter from 0.26.3 to 0.26.3.1
(#7511)
add 7fc53f029ba IGNITE-27679 Sql. SelectCount plan is affected by
consequent DML in script (#7524)
add 01f149382d7 IGNITE-24995 Optimize correaltes serialization when
propagating to another node (#7471)
add 8b8d67c6710 IGNITE-27748 Make `recordView` and `keyValueView` return
the same values (#7534)
add 89c8d45a2e3 IGNITE-27702 Failure handler should not be triggered by
failed attempt to switch tx state (#7517)
add c60a70edf6d IGNITE-26573 Use JitComparator in sorted indexes by
default (#6685)
add 82dd62fb1dd IGNITE-27703 Remove waiting for cluster time during
assignments waiting (#7531)
add 68af1f91397 IGNITE-27178 Add a total number of unresolved write
intents as a metric (#7428)
add dc3efdeea6d IGNITE-27766 Reduce log level of 'Fail to connect' in Raft
client (#7542)
add b765dbc41d9 IGNITE-27760 Respect LT leave during subscription in
topology-aware client (#7539)
add 9aed840d949 IGNITE-27656 Fix placement-driver metrics inconsistency
when placement driver doesn't work (#7541)
add 6bfe2410f16 Bump netty from 4.2.9.Final to 4.2.10.Final (#7537)
add 33404e8ce09 IGNITE-27768 Docs: remove explicit setting of lastVersion
(#7543)
add 7161f472fe5 IGNITE-27774 Remove BulkUpdateProducer (#7546)
add 0ce80f0cec2 IGNITE-27725 Add additional logs to Placement Driver
(#7533)
add 299dbdf8a4e IGNITE-27779 Disable ItFloatingPointTest.testAggregations
test (#7552)
add 454d7ee13f0 IGNITE-27723 Benchmark for PersistentPageMemory (#7513)
add 756f5593bb7 IGNITE-27782 fix PersistentPageMemoryBenchmarkBase (#7555)
add 30a0188aa23 IGNITE-27771 Reduce logging on handshake error (#7544)
add 7ebb7c7916a Bump js-yaml from 3.14.1 to 3.14.2 in /docs (#7523)
add fe7795c5037 Bump webpack from 5.102.1 to 5.105.0 in /docs (#7551)
add 1ce1987ffe5 Bump qs and express in /docs (#7522)
add d406437cd35 Bump mdast-util-to-hast from 13.2.0 to 13.2.1 in /docs
(#7518)
add 96a2b7600be Bump undici from 7.16.0 to 7.20.0 in /docs
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ba47ec2664f)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/docs/undici-7.20.0 (96a2b7600be)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
buildscripts/jmh.gradle | 5 +-
check-rules/spotbugs-excludes.xml | 21 +
docs/docs/api-reference/api/index.mdx | 6 +-
docs/docs/api-reference/index.mdx | 12 +-
.../api-reference/native-clients/cpp/index.mdx | 12 +-
.../api-reference/native-clients/dotnet/index.mdx | 18 +-
docs/docs/api-reference/native-clients/index.mdx | 6 +-
.../api-reference/native-clients/java/index.mdx | 22 +-
docs/docs/api-reference/sql-only-apis/index.mdx | 6 +-
.../configure-and-operate/configuration/index.mdx | 12 +-
docs/docs/configure-and-operate/index.mdx | 40 +-
.../configure-and-operate/installation/index.mdx | 8 +-
.../configure-and-operate/monitoring/index.mdx | 2 +-
.../configure-and-operate/operations/index.mdx | 8 +-
.../docs/configure-and-operate/reference/index.mdx | 8 +-
docs/docs/develop/connect-to-ignite/index.mdx | 6 +-
docs/docs/develop/ignite-clients/index.mdx | 6 +-
docs/docs/develop/index.mdx | 22 +-
docs/docs/develop/integrate/index.mdx | 4 +-
docs/docs/develop/work-with-data/index.mdx | 20 +-
docs/docs/getting-started/index.mdx | 16 +-
docs/docs/index.mdx | 38 +-
docs/docs/sql/advanced/index.mdx | 4 +-
docs/docs/sql/fundamentals/index.mdx | 2 +-
docs/docs/sql/index.mdx | 26 +-
.../reference/data-types-and-functions/index.mdx | 6 +-
.../operational-commands.mdx | 10 +-
docs/docs/sql/reference/index.mdx | 6 +-
.../docs/sql/reference/language-definition/ddl.mdx | 46 +-
.../language-definition/distribution-zones.mdx | 2 +-
.../docs/sql/reference/language-definition/dml.mdx | 18 +-
.../language-definition/grammar-reference.mdx | 4 +-
.../sql/reference/language-definition/index.mdx | 10 +-
docs/docs/sql/reference/sql-conformance/index.mdx | 4 +-
docs/docs/sql/working-with-sql/index.mdx | 4 +-
docs/docs/tools/index.mdx | 6 +-
docs/docs/understand/architecture/index.mdx | 8 +-
.../architecture/storage-engines/index.mdx | 6 +-
docs/docs/understand/core-concepts/index.mdx | 12 +-
docs/docs/understand/index.mdx | 24 +-
docs/docs/understand/performance/index.mdx | 4 +-
docs/package-lock.json | 161 +++--
.../ignite/example/client/IgniteClientExample.java | 2 +-
.../client/IgniteClientWithConfigExample.java | 2 +-
.../apache/ignite/example/sql/SqlApiExample.java | 10 +-
.../streaming/DetectFailedEntriesExample.java | 4 +-
.../streaming/SingleTableDataStreamerExample.java | 5 +-
.../apache/ignite/example/table/QueryExample.java | 8 +-
.../apache/ignite/example/table/TableExample.java | 2 +-
gradle/libs.versions.toml | 4 +-
.../persistence/Ignite2PersistentCacheTools.java | 2 +-
modules/api/build.gradle | 2 +
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../main/java/org/apache/ignite/sql/IgniteSql.java | 48 ++
.../java/org/apache/ignite/table/KeyValueView.java | 604 ++++++++++++++++-
.../java/org/apache/ignite/table/RecordView.java | 385 ++++++++++-
.../ignite/table/TableApiConsistencyTest.java | 741 +++++++++++++++++++++
.../internal/catalog/sql/SelectFromView.java | 3 +-
.../internal/catalog/BulkUpdateProducer.java | 53 --
.../internal/catalog/CatalogManagerImpl.java | 17 +-
.../ignite/internal/catalog/UpdateContext.java | 2 -
.../ignite/client/handler/JdbcHandlerBase.java | 2 +-
.../table/ClientTupleReplaceExactRequest.java | 2 +-
.../ignite/client/handler/FakePlacementDriver.java | 2 +-
.../apache/ignite/client/ClientOperationType.java | 2 +-
.../client/table/ClientKeyValueBinaryView.java | 12 +-
.../internal/client/table/ClientKeyValueView.java | 12 +-
.../client/table/ClientRecordBinaryView.java | 6 +-
.../internal/client/table/ClientRecordView.java | 6 +-
.../table/api/PublicApiClientKeyValueView.java | 16 +-
.../table/api/PublicApiClientRecordView.java | 8 +-
.../apache/ignite/client/ClientMetricsTest.java | 2 +-
.../org/apache/ignite/client/ClientSqlTest.java | 19 +-
.../apache/ignite/client/ServerMetricsTest.java | 2 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 7 +
.../internal/client/ClientCompatibilityTests.java | 4 +-
.../ignite/internal/ApiCompatibilityTest.java | 14 +-
.../ignite/internal/CompatibilityTestCommon.java | 2 +-
modules/core/build.gradle | 2 +
.../ignite/internal/util/ExceptionUtils.java | 19 +
.../ignite/internal/util/FastTimestamps.java | 22 +-
.../apache/ignite/internal/util/IgniteUtils.java | 24 +
.../ignite/internal/util/OffheapReadWriteLock.java | 116 +++-
modules/distribution-zones/build.gradle | 3 +
.../ItDistributionZonesFiltersTest.java | 25 +-
.../distributionzones/ItEmptyDataNodesTest.java | 6 +-
.../rebalance/ItRebalanceDistributedTest.java | 2 +
.../internal/rebalance/ItRebalanceMetricsTest.java | 192 +++---
.../rebalance/ItRebalanceRecoveryTest.java | 8 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 24 +-
.../rebalance/ZoneRebalanceUtil.java | 21 +
.../distributionzones/RebalanceBlockingUtil.java | 232 +++++++
.../ignite/internal/index/IndexBuildTestUtils.java | 2 +-
.../ignite/internal/index/ItBuildIndexTest.java | 2 +-
.../ItIndexAndIndexStorageDestructionTest.java | 6 +-
.../index/ItIndexBuildCompletenessTest.java | 2 +-
...dexRegistrationAndRebalanceConcurrencyTest.java | 2 +-
.../ignite/internal/index/IndexManagerTest.java | 4 +-
.../ignite/internal/index/TestPlacementDriver.java | 6 +-
.../ignite/jdbc/ItJdbcAuthenticationTest.java | 2 +-
.../internal/metrics/AbstractMetricSource.java | 2 +-
.../internal/network/DefaultMessagingService.java | 20 +-
.../internal/network/NetworkMessageTypes.java | 71 ++
.../message/value/BooleanValueMessage.java} | 14 +-
.../message/value/ByteArrayValueMessage.java} | 12 +-
.../network/message/value/ByteValueMessage.java} | 12 +-
.../network/message/value/DoubleValueMessage.java} | 12 +-
.../network/message/value/FloatValueMessage.java} | 12 +-
.../network/message/value/IntValueMessage.java} | 12 +-
.../network/message/value/LongValueMessage.java} | 12 +-
.../network/message/value/NullValueMessage.java} | 15 +-
.../network/message/value/ShortValueMessage.java} | 12 +-
.../network/message/value/SingleValueMessage.java} | 9 +-
.../network/message/value/StringValueMessage.java} | 12 +-
.../network/message/value/UuidValueMessage.java} | 18 +-
.../internal/network/netty/ConnectionManager.java | 14 +-
modules/page-memory/build.gradle | 9 +-
.../tree/AbstractBplusTreePageMemoryTest.java | 2 -
.../tree/ItBplusTreeReplaceRemoveRaceTest.java | 2 -
.../benchmark/PageReplacementBenchmark.java | 438 ++++++++++++
.../ignite/internal/pagememory/PageMemory.java | 5 -
.../PersistentDataRegionConfiguration.java | 20 +-
.../pagememory/inmemory/VolatilePageMemory.java | 55 +-
.../pagememory/persistence/PageCacheMetrics.java} | 16 +-
.../persistence/PersistentPageMemory.java | 267 +++-----
.../PersistentPageMemoryMetricSource.java | 9 +
.../persistence/PersistentPageMemoryMetrics.java | 132 +++-
.../MeteredPageReplacementPolicyFactory.java | 77 +++
...teChecker.java => ThrottlingPolicyFactory.java} | 14 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 50 +-
.../benchmark/ZipfianDistributionTest.java | 178 +++++
.../pagememory/freelist/FreeListImplTest.java | 2 -
.../inmemory/VolatilePageMemoryNoLoadSelfTest.java | 5 +-
.../replacement/AbstractPageReplacementTest.java | 42 +-
.../throttling/PageMemoryThrottlingTest.java | 36 +-
.../AbstractPageMemoryNoLoadSelfTest.java | 8 -
.../PersistentPageMemoryBenchmarkBase.java | 314 +++++++++
.../benchmark/VolatilePageMemoryBenchmarkBase.java | 2 -
.../pagememory/benchmark/ZipfianDistribution.java | 77 +++
.../partitiondistribution/Assignments.java | 18 +-
.../partitiondistribution/AssignmentsQueue.java | 9 +
.../replicator/ItBigZoneOperationTest.java | 2 +-
.../partition/replicator/fixtures/Node.java | 2 +
.../replicator/fixtures/TestPlacementDriver.java | 8 +-
.../handlers/TxFinishReplicaRequestHandler.java | 22 +-
.../raft/UnexpectedTransactionStateException.java | 42 --
.../raft/handlers/FinishTxCommandHandler.java | 46 +-
.../PartitionReplicaLifecycleManagerTest.java | 1 +
.../TxFinishReplicaRequestHandlerTest.java | 163 +++++
.../AssignmentsPlacementDriver.java | 2 -
.../wrappers/DelegatingPlacementDriver.java | 3 +-
.../wrappers/ExecutorInclinedPlacementDriver.java | 8 +-
.../placementdriver/TestPlacementDriver.java | 6 +-
.../placementdriver/AssignmentsTracker.java | 11 +-
.../internal/placementdriver/LeaseUpdater.java | 55 +-
.../placementdriver/PlacementDriverManager.java | 17 +-
.../placementdriver/leases/LeaseTracker.java | 10 +-
.../metrics/PlacementDriverMetricSource.java | 13 +-
.../placementdriver/AssignmentsTrackerTest.java | 4 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 2 +-
.../metrics/PlacementDriverMetricSourceTest.java | 4 +-
modules/platforms/build.gradle | 102 +--
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
.../SerializerHandlerBenchmarksBase.cs | 4 +
.../SerializerHandlerReadBenchmarks.cs | 9 +
.../SerializerHandlerWriteBenchmarks.cs | 12 +
.../Apache.Ignite.Tests.Aot/Table/TableTests.cs | 71 ++
.../Apache.Ignite.Tests.Common/Table/TestTables.cs | 2 +-
.../Table/KeyValueViewPrimitiveTests.cs | 11 +
.../Table/PartitionDistributionTests.cs | 14 +-
.../Table/RecordViewPrimitiveTests.cs | 3 +-
.../Table/SchemaSynchronizationTest.cs | 13 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
.../Mappers/KeyValueMappers.cs} | 29 +-
.../Mappers/KeyValuePairCompositeMapper.cs | 85 +++
.../Mappers/MapperReader.cs} | 12 +-
.../Mappers/MapperWriter.cs} | 12 +-
.../Table/Serialization/Mappers/OneColumnMapper.cs | 51 ++
.../Serialization/Mappers/OneColumnMappers.cs | 219 ++++++
.../Table/Serialization/TupleSerializerHandler.cs | 9 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 46 +-
.../platforms/python/pyignite_dbapi/_version.txt | 2 +-
modules/platforms/python/setup.py | 9 +-
...InterruptedRaftSnapshotStorageRecoveryTest.java | 6 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 2 +-
.../org/apache/ignite/raft/ItRaftMetricTest.java | 3 +
.../raft/jraft/rpc/impl/AbstractClientService.java | 2 +-
modules/replicator/build.gradle | 1 +
.../ItPlacementDriverReplicaSideTest.java | 2 +
.../raft/client/TopologyAwareRaftGroupService.java | 126 +++-
.../ignite/internal/replicator/ReplicaManager.java | 78 ++-
.../ignite/internal/replicator/ReplicaService.java | 17 +-
.../exception/ReplicaUnavailableException.java | 13 +-
.../TopologyAwareRaftGroupServiceRetriesTest.java | 210 ++++++
.../internal/replicator/ReplicaManagerTest.java | 125 +++-
.../rest/sql/ItSqlQueryControllerTest.java | 3 +-
.../internal/rest/sql/SqlQueryController.java | 3 +-
.../rest/transaction/TransactionController.java | 3 +-
.../ignite/internal/app/AsyncApiOperation.java | 9 +-
.../ignite/internal/app/SyncApiOperation.java | 5 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 4 +-
.../internal/benchmark/BulkDeleteBenchmark.java | 7 +-
.../ignite/internal/benchmark/InsertBenchmark.java | 9 +-
.../internal/benchmark/LargeBinaryBenchmark.java | 8 +-
.../internal/benchmark/LargeStringBenchmark.java | 8 +-
.../ignite/internal/benchmark/SqlBenchmark.java | 12 +-
.../internal/benchmark/SqlIndexScanBenchmark.java | 6 +-
.../internal/benchmark/SqlJoinBenchmark.java | 12 +-
.../benchmark/SqlPartitionPruningBenchmark.java | 12 +-
.../internal/benchmark/SqlSelectAllBenchmark.java | 2 +-
.../internal/benchmark/SystemViewsBenchmark.java | 4 +-
.../ignite/internal/benchmark/TpcdsBenchmark.java | 2 +-
.../ignite/internal/benchmark/TpchBenchmark.java | 2 +-
.../internal/benchmark/UpgradeRowBenchmark.java | 6 +-
.../client/ItClientObservableTimeTest.java | 4 +-
.../management/ItDuplicateNodeNamesTest.java | 4 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 3 +-
.../ignite/internal/runner/app/ItAddNodeTest.java | 2 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 4 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 7 +-
.../runner/app/ItIgniteNodeRestartTest.java | 38 +-
.../internal/runner/app/ItIndexNodeTest.java | 10 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 2 +-
.../runner/app/ItReplicaStateManagerTest.java | 12 +-
.../internal/runner/app/ItSingleNodeTest.java | 2 +-
.../internal/runner/app/ItTablesApiTest.java | 2 +-
.../runner/app/PlatformTestNodeRunner.java | 4 +-
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../client/ItCustomKeyColumnOrderClientTest.java | 4 +-
.../runner/app/client/ItNullsThinClientTest.java | 8 +-
.../app/client/ItThinClientAuthenticationTest.java | 10 +-
.../client/ItThinClientChannelValidatorTest.java | 2 +-
.../runner/app/client/ItThinClientComputeTest.java | 2 +-
.../app/client/ItThinClientConnectionTest.java | 10 +-
.../client/ItThinClientDdlQueriesTrackerTest.java | 2 +-
.../app/client/ItThinClientMarshallingTest.java | 19 +-
.../ItThinClientSchemaSynchronizationTest.java | 30 +-
.../runner/app/client/ItThinClientSqlTest.java | 108 ++-
.../app/client/ItThinClientTablesGetListTest.java | 2 +-
.../app/client/ItThinClientTransactionsTest.java | 2 +-
.../app/client/ItThinConnectionFailoverTest.java | 8 +-
.../schemasync/ItSchemaSyncAndReplicationTest.java | 2 +-
.../streamer/ItAbstractDataStreamerTest.java | 6 +-
.../ignite/internal/table/ItInternalTableTest.java | 9 +-
.../table/ItRebalanceWithPartitionReturnTest.java | 17 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 2 +
.../internal/restart/RestartProofKeyValueView.java | 16 +-
.../internal/restart/RestartProofRecordView.java | 8 +-
.../java/org/apache/ignite/internal/Cluster.java | 2 +-
.../schema/BinaryTupleComparatorUtils.java | 2 +-
.../internal/schema/UnsafeByteBufferAccessor.java | 37 +-
.../schema/BinaryTupleComparatorBaseTest.java | 9 +
.../ExampleApplicationWithCustomAuthenticator.java | 4 +-
.../apache/ignite/example/ExampleApplication.java | 4 +-
.../org/apache/ignite/ExampleApplicationTest.java | 2 +-
.../org/apache/ignite/data/SpringDataJdbcTest.java | 8 +-
.../ignite/internal/sql/api/ItCommonApiTest.java | 4 +-
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 10 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 8 +-
.../internal/sql/api/ItSqlClientMetricsTest.java | 13 +-
.../sql/api/ItSqlClientSynchronousApiTest.java | 3 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 8 +-
.../internal/sql/engine/ItFloatingPointTest.java | 2 +
.../internal/sql/engine/ItLimitOffsetTest.java | 28 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 2 +-
.../sql/engine/ItNotNullConstraintTest.java | 3 +-
.../internal/sql/engine/ItPublicSchemaTest.java | 3 +-
.../ItSqlConcurrentSchemaModificationTest.java | 4 +-
.../internal/sql/engine/ItSqlOperatorsTest.java | 6 +-
.../sql/engine/ItSqlQueryEventLogTest.java | 2 +-
.../sql/engine/ItSqlQueryExecutionMetricsTest.java | 5 +-
.../sql/engine/kill/ItSqlKillCommandTest.java | 4 +-
.../internal/sql/sqllogic/ScriptContext.java | 3 +-
.../sql/threading/ItSqlApiThreadingTest.java | 7 +-
.../integrationTest/sql/group1/explain/join.test | 1 +
.../integrationTest/sql/group1/explain/scan.test | 2 +
.../sql/engine/exec/ExchangeServiceImpl.java | 7 +-
.../internal/sql/engine/exec/ExecutionContext.java | 9 +-
.../sql/engine/exec/LogicalRelImplementor.java | 2 +-
.../internal/sql/engine/exec/SharedState.java | 42 +-
.../engine/exec/SharedStateMessageConverter.java | 188 ++++++
.../sql/engine/exec/SqlEvaluationContext.java | 5 +-
.../sql/engine/exec/exp/CorrelatesBuilder.java | 21 +-
...ieldGetter.java => CorrelationValueGetter.java} | 25 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 2 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 2 +-
.../sql/engine/exec/exp/PredicateImplementor.java | 2 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 2 +-
.../engine/exec/exp/RowProviderImplementor.java | 4 +-
.../sql/engine/exec/exp/ScalarImplementor.java | 5 +-
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 8 +-
.../mapping/ExecutionDistributionProviderImpl.java | 8 +-
.../engine/exec/mapping/MappingServiceImpl.java | 2 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 21 +-
.../expressions/SqlExpressionFactoryAdapter.java | 4 +-
.../sql/engine/externalize/RelJsonReader.java | 8 +-
...rationRequest.java => DecimalValueMessage.java} | 18 +-
.../engine/message/QueryBatchRequestMessage.java | 7 +-
.../sql/engine/message/SharedStateMessage.java} | 10 +-
.../sql/engine/message/SqlQueryMessageGroup.java | 6 +
.../sql/engine/prepare/SelectCountPlan.java | 16 +
.../engine/rel/IgniteCorrelatedNestedLoopJoin.java | 47 +-
.../sql/engine/rel/explain/IgniteRelWriter.java | 9 +
.../engine/rel/explain/RelTreeToTextWriter.java | 8 +
.../sql/engine/rule/CorrelateToNestedLoopRule.java | 1 +
.../engine/rule/CorrelatedNestedLoopJoinRule.java | 7 +
.../ignite/internal/sql/engine/util/Commons.java | 11 +
.../internal/sql/engine/util/IgniteMethod.java | 4 +-
.../ignite/internal/sql/api/IgniteSqlImplTest.java | 8 +-
.../internal/sql/engine/exec/QueryTimeoutTest.java | 12 +-
.../exec/SharedStateMessageConverterTest.java | 141 ++++
.../internal/sql/engine/exec/SharedStateTest.java | 77 +++
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 78 ++-
.../CorrelatedNestedLoopJoinPlannerTest.java | 35 +-
.../internal/sql/engine/util/CommonsTest.java | 29 +
.../src/test/resources/mapping/correlated.test | 7 +
.../resources/mapping/test_partition_pruning.test | 2 +
.../AbstractPageMemoryStorageEngine.java | 152 ++++-
.../pagememory/PersistentPageMemoryDataRegion.java | 42 +-
.../PersistentPageMemoryStorageEngine.java | 9 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 2 -
.../VolatilePageMemoryDataStorageModule.java | 5 +
.../VolatilePageMemoryStorageEngine.java | 7 +-
.../pagememory/index/freelist/IndexColumns.java | 9 +-
.../pagememory/index/sorted/SortedIndexRowKey.java | 9 +
.../pagememory/index/sorted/SortedIndexTree.java | 38 +-
.../sorted/comparator/JitComparatorGenerator.java | 25 +-
.../sorted/comparator/JitComparatorOptions.java | 2 +-
.../index/sorted/io/SortedIndexTreeIo.java | 73 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 6 +-
.../storage/pagememory/mv/IndexStorageFactory.java | 17 +-
.../storage/pagememory/mv/PageMemoryIndexes.java | 10 +-
.../PersistentPageMemoryMvTableStorageTest.java | 6 +-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 14 -
.../VolatilePageMemoryMvTableStorageTest.java | 7 +-
.../benchmarks/SortedIndexTreeInsertBenchmark.java | 8 +-
.../PersistentPageMemoryStorageEngineTest.java | 6 +-
.../VolatilePageMemoryStorageEngineTest.java | 5 +
...PersistentPageMemorySortedIndexStorageTest.java | 7 +-
...morySortedIndexStorageLegacyComparatorTest.java | 44 ++
.../VolatilePageMemorySortedIndexStorageTest.java | 9 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 10 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 7 +-
.../storage/pagememory/mv/BlobStorageTest.java | 2 -
.../pagememory/mv/FailedCheckpointTest.java | 6 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 7 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 7 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 6 +-
...entPageMemoryMvTableStorageConcurrencyTest.java | 7 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 6 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 7 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 5 +-
...ilePageMemoryMvTableStorageConcurrencyTest.java | 6 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 2 +
.../table/AsyncApiKeyValueViewAdapter.java | 12 +-
.../internal/table/AsyncApiRecordViewAdapter.java | 6 +-
...artitionTableStatsMetricConfigurationTest.java} | 4 +-
...t.java => ItPartitionTableStatsMetricTest.java} | 18 +-
...ilablePartitionsRecoveryByFilterUpdateTest.java | 24 +-
.../threading/ItKvRecordApiThreadingTest.java | 4 +-
.../schema/marshaller/TupleMarshallerImpl.java | 35 +-
.../internal/table/KeyValueBinaryViewImpl.java | 12 +-
.../ignite/internal/table/KeyValueViewImpl.java | 12 +-
.../table/PublicApiThreadingKeyValueView.java | 16 +-
.../table/PublicApiThreadingRecordView.java | 8 +-
.../internal/table/RecordBinaryViewImpl.java | 6 +-
.../ignite/internal/table/RecordViewImpl.java | 6 +-
.../apache/ignite/internal/table/TableImpl.java | 32 +-
.../ignite/internal/table/TableViewInternal.java | 7 -
.../PartitionModificationCounterMetricSource.java | 81 ---
.../PartitionTableStatsMetricSource.java | 105 +++
.../table/distributed/StorageUpdateHandler.java | 9 +
.../internal/table/distributed/TableManager.java | 115 ++--
.../disaster/GroupUpdateRequestHandler.java | 32 +-
.../table/distributed/replicator/PendingRows.java | 11 +
.../distributed/storage/InternalTableImpl.java | 2 +
.../distributed/TableManagerRecoveryTest.java | 3 +
.../table/distributed/TableManagerTest.java | 3 +
.../PersistentPageMemoryGcUpdateHandlerTest.java | 7 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +
.../disaster/DisasterRecoveryTestUtil.java | 85 ---
.../disaster/ItDisasterRecoveryManagerTest.java | 15 +-
.../ItDisasterRecoveryReconfigurationTest.java | 67 +-
.../ignite/internal/tx/ItMultipleLocksTest.java | 6 +-
.../internal/tx/ItTransactionMetricsTest.java | 67 ++
.../org/apache/ignite/internal/tx/TxManager.java | 6 +
.../tx/impl/PersistentTxStateVacuumizer.java | 4 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 5 +
.../tx/metrics/TransactionMetricsSource.java | 54 +-
.../tx/metrics/TransactionMetricSourceTest.java | 3 +-
392 files changed, 8018 insertions(+), 2200 deletions(-)
create mode 100644
modules/api/src/test/java/org/apache/ignite/table/TableApiConsistencyTest.java
delete mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/BulkUpdateProducer.java
create mode 100644
modules/distribution-zones/src/testFixtures/java/org/apache/ignite/internal/distributionzones/RebalanceBlockingUtil.java
copy
modules/{code-deployment/src/main/java/org/apache/ignite/internal/deployunit/message/StopDeployResponse.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/BooleanValueMessage.java}
(70%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/PrepareInitCompleteMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/ByteArrayValueMessage.java}
(70%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/ByteValueMessage.java}
(71%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/DoubleValueMessage.java}
(70%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/FloatValueMessage.java}
(71%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/IntValueMessage.java}
(71%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/LongValueMessage.java}
(71%)
copy
modules/{placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/LeaseGrantedMessageResponse.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/NullValueMessage.java}
(71%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/ShortValueMessage.java}
(71%)
copy
modules/network/src/{testFixtures/java/org/apache/ignite/internal/network/messages/NetworkMessage1.java
=>
main/java/org/apache/ignite/internal/network/message/value/SingleValueMessage.java}
(78%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/SuccessResponseMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/StringValueMessage.java}
(70%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxRecoveryMessage.java
=>
network/src/main/java/org/apache/ignite/internal/network/message/value/UuidValueMessage.java}
(70%)
create mode 100644
modules/page-memory/src/jmh/java/org/apache/ignite/internal/pagememory/benchmark/PageReplacementBenchmark.java
copy
modules/{metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/JmxExporterConfigurationSchema.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageCacheMetrics.java}
(70%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/replacement/MeteredPageReplacementPolicyFactory.java
copy
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/{CheckpointLockStateChecker.java
=> ThrottlingPolicyFactory.java} (57%)
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/benchmark/ZipfianDistributionTest.java
create mode 100644
modules/page-memory/src/testFixtures/java/org/apache/ignite/internal/pagememory/benchmark/PersistentPageMemoryBenchmarkBase.java
create mode 100644
modules/page-memory/src/testFixtures/java/org/apache/ignite/internal/pagememory/benchmark/ZipfianDistribution.java
delete mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/UnexpectedTransactionStateException.java
create mode 100644
modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/handlers/TxFinishReplicaRequestHandlerTest.java
copy
modules/platforms/dotnet/Apache.Ignite/Internal/Table/{IgniteTupleCommon.cs =>
Serialization/Mappers/KeyValueMappers.cs} (53%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/Mappers/KeyValuePairCompositeMapper.cs
copy modules/platforms/dotnet/Apache.Ignite/Internal/Table/{MapperSchema.cs =>
Serialization/Mappers/MapperReader.cs} (72%)
copy modules/platforms/dotnet/Apache.Ignite/Internal/Table/{MapperSchema.cs =>
Serialization/Mappers/MapperWriter.cs} (71%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/Mappers/OneColumnMapper.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/Serialization/Mappers/OneColumnMappers.cs
create mode 100644
modules/replicator/src/test/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupServiceRetriesTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/SharedStateMessageConverter.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{FieldGetter.java
=> CorrelationValueGetter.java} (64%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/{CancelOperationRequest.java
=> DecimalValueMessage.java} (71%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/InitCompleteMessage.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/message/SharedStateMessage.java}
(76%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/SharedStateMessageConverterTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/SharedStateTest.java
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/VolatilePageMemorySortedIndexStorageLegacyComparatorTest.java
rename
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/{ItPartitionModificationCounterConfigurationTest.java
=> ItPartitionTableStatsMetricConfigurationTest.java} (93%)
rename
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/{ItPartitionModificationCounterMetricsTest.java
=> ItPartitionTableStatsMetricTest.java} (95%)
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/PartitionModificationCounterMetricSource.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/PartitionTableStatsMetricSource.java
