This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-26156
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 813cc8fe4e8 Minor after review. Rearrange code. Get rid of
IgniteSqlInternal class.
discard 3d20beabc01 wip
add dd204d737e8 IGNITE-25983 Hash index isn't used with multiple keys
(#6534)
add d169714b99e IGNITE-26367 Improve error message when deployment unit is
not provided (#6532)
add 7e328affe13 IGNITE-26370 Add gradle task for updating versions for
compatibility tests (#6540)
add 4ead1e5d18a IGNITE-26375 Update compute examples (#6541)
add 312f07ac2e6 IGNITE-26374 Update SQL API doc (#6539)
add 4ce382816eb IGNITE-26017 Sql. Improve row count estimation for all
join types (#6543)
add b7514e218a6 Bump com.github.spotbugs from 6.2.5 to 6.2.7 (#6548)
add 7a6cfd0286a Bump org.jetbrains:annotations from 26.0.2 to 26.0.2-1
(#6526)
add 5dbd954eb32 Bump io.swagger.parser.v3:swagger-parser from 2.1.32 to
2.1.33 (#6536)
add 4fb2e4ff001 IGNITE-26388 Add python DB API example (#6550)
add 9221ebe6303 Bump io.dropwizard.metrics:metrics-core from 4.2.34 to
4.2.36 (#6525)
add 55ebe94dab0 IGNITE-25945 Acknowledge messages in batches (#6552)
add 3c091114464 Bump com.google.testing.compile:compile-testing from
0.21.0 to 0.22.0 (#6560)
add cffe30fc597 Bump com.github.spotbugs from 6.2.7 to 6.3.0 (#6559)
add e4b286f7cf3 Bump netty from 4.2.4.Final to 4.2.5.Final (#6558)
add 1097ec3a005 IGNITE-24458 Java API compatibility extension (#6501)
add abf6e2b30ef IGNITE-26397 OutNetworkObject constructor with
shouldBeSavedForRecovery is redundant (#6561)
add f8f970e6884 IGNITE-26401 Rename generateCompatibilitySnapshot task
(#6564)
add b1fa2f59159 IGNITE-26398 Update RW transaction timeout javadoc (#6562)
add 1da7cad2069 IGNITE-26346 Ban the creation of distribution zones which
don't have data nodes at the moment of creation (#6546)
add a8aec521f2b Bump io.opentelemetry:opentelemetry-exporter-otlp from
1.53.0 to 1.54.0 (#6568)
add fc24ebf5b95 Bump netty from 4.2.5.Final to 4.2.6.Final (#6567)
add 33fa7b0f3fa IGNITE-26328 Add table metrics (#6544)
add a56e9aabf2e IGNITE-26409 Rename InternalClusterNodeImpl back to
ClusterNodeImpl (#6574)
add 56ecde1a897 IGNITE-25918 Fix datarace in ReadWriteTransactionImpl
(#6554)
add 60d86b920fe IGNITE-26347 Adjust the rebalancing logic in the case of
empty data nodes (#6572)
add b654d8dc3d5 wip
add 03d1da335ee Minor after review. Rearrange code. Get rid of
IgniteSqlInternal class.
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 (813cc8fe4e8)
\
N -- N -- N refs/heads/ignite-26156 (03d1da335ee)
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:
RELEASE.md | 6 +-
check-rules/checkstyle-rules.xml | 2 +-
docs/_docs/developers-guide/compute/compute.adoc | 96 ++--
docs/_docs/developers-guide/sql/sql-api.adoc | 4 +-
.../example/compute/ComputeBroadcastExample.java | 21 +-
.../example/compute/ComputeJobPriorityExample.java | 2 +-
...uteExample.java => ComputeJobStateExample.java} | 50 +-
examples/python/db_api_example.py | 145 +++++
gradle/libs.versions.toml | 17 +-
.../org/apache/ignite/tx/TransactionOptions.java | 6 +-
.../compaction/ItCatalogCompactionTest.java | 4 +-
.../CatalogCompactionRunnerSelfTest.java | 4 +-
.../catalog/ItCatalogApiThreadingTest.java | 3 +-
.../ignite/internal/catalog/ItCatalogDslTest.java | 3 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 4 +-
.../apache/ignite/client/fakes/FakeCompute.java | 4 +-
.../ignite/client/fakes/FakeInternalTable.java | 10 +-
.../management/ClusterManagementGroupManager.java | 4 +-
.../raft/commands/ClusterNodeMessage.java | 4 +-
.../management/topology/api/LogicalNode.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 28 +-
.../management/raft/CmgRaftServiceTest.java | 4 +-
modules/compatibility-tests/build.gradle | 37 +-
.../ignite/internal/ItApiCompatibilityTest.java | 52 ++
.../ignite/internal/OpenApiCompatibilityTest.java | 3 +-
.../versions/{3_0_0 => 3.0.0}/openapi.yaml | 0
.../org/apache/ignite/internal/Dependencies.java | 149 +++++
.../org/apache/ignite/internal/IgniteCluster.java | 47 +-
.../apache/ignite/internal/OldClientLoader.java | 2 +-
.../api/ApiCompatibilityExtension.java | 68 +++
.../compatibility/api/ApiCompatibilityTest.java | 77 +++
.../ApiCompatibilityTestInvocationContext.java} | 29 +-
.../compatibility/api/CompatibilityChecker.java | 135 +++++
.../compatibility/api/CompatibilityExtension.java | 55 ++
.../compatibility/api/CompatibilityInput.java | 62 ++
.../compatibility/api/CompatibilityOutput.java | 50 ++
.../internal/compatibility/api/MethodProvider.java | 104 ++++
.../compatibility/api/TestNameFormatter.java | 41 ++
.../src/testFixtures/resources/igniteVersions.json | 2 +-
.../internal/compute/ItComputeTestStandalone.java | 98 ++--
.../internal/compute/utils/InteractiveJobs.java | 4 +-
.../internal/compute/ComputeComponentImpl.java | 3 +-
.../ignite/internal/compute/ComputeUtils.java | 12 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 4 +-
.../internal/compute/executor/ComputeExecutor.java | 4 +-
.../compute/executor/ComputeExecutorImpl.java | 7 +-
.../internal/compute/ComputeComponentImplTest.java | 6 +-
.../internal/compute/IgniteComputeImplTest.java | 6 +-
.../compute/loader/JobClassLoaderTest.java | 10 +-
.../ItDistributionZonesFiltersTest.java | 83 ++-
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 3 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 8 +-
.../DistributionZoneRebalanceEngineV2.java | 8 +-
.../distributionzones/rebalance/RebalanceUtil.java | 2 +-
.../rebalance/ZoneRebalanceUtil.java | 2 +-
.../DistributionZoneManagerAlterFilterTest.java | 12 +-
.../DistributionZoneManagerFilterTest.java | 12 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 4 +-
...butionZoneManagerStorageProfilesFilterTest.java | 12 +-
.../DistributionZoneCausalityDataNodesTest.java | 8 +-
.../DistributionZonesTestUtil.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 6 +-
.../apache/ignite/internal/index/IndexManager.java | 4 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 4 +-
.../internal/index/IndexManagementUtilsTest.java | 8 +-
.../internal/index/TestIndexManagementUtils.java | 4 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 4 +-
.../MetaStorageLeaderElectionListenerTest.java | 6 +-
.../impl/MetaStorageManagerRecoveryTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 4 +-
...alClusterNodeImpl.java => ClusterNodeImpl.java} | 12 +-
.../internal/network/ClusterNodeSerializer.java | 2 +-
.../network/InternalClusterNodeSerializerTest.java | 2 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 6 +-
.../network/netty/ItConnectionManagerTest.java | 42 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 106 +++-
.../internal/network/DefaultMessagingService.java | 2 +-
.../internal/network/NettyBootstrapFactory.java | 10 +
.../ignite/internal/network/OutNetworkObject.java | 13 +-
...tionSchema.java => AckConfigurationSchema.java} | 34 +-
.../configuration/NetworkConfigurationSchema.java | 4 +
.../network/message/ClusterNodeMessage.java | 4 +-
.../internal/network/netty/ConnectionManager.java | 6 +-
.../network/netty/InboundRecoveryHandler.java | 67 ++-
.../ignite/internal/network/netty/NettySender.java | 4 +-
.../internal/network/netty/PipelineUtils.java | 9 +-
.../network/recovery/HandshakeManagerUtils.java | 2 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 14 +-
.../RecoveryInitiatorHandshakeManager.java | 14 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 4 +-
.../scalecube/ScaleCubeTopologyService.java | 4 +-
.../network/DefaultMessagingServiceTest.java | 33 +-
.../internal/network/OutNetworkObjectTest.java | 2 +-
.../network/netty/RecoveryHandshakeTest.java | 40 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 15 +-
.../network/recovery/RecoveryDescriptorTest.java | 6 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 19 +-
.../partition/replicator/fixtures/Node.java | 3 +-
.../PartitionReplicaLifecycleManagerTest.java | 4 +-
.../ItPrimaryReplicaChoiceTest.java | 6 +-
.../placementdriver/PlacementDriverTest.java | 6 +-
.../Transactions/TransactionOptions.cs | 4 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 2 -
.../ignite/internal/raft/RaftGroupServiceTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 4 +-
.../replicator/PlacementDriverReplicaSideTest.java | 6 +-
.../internal/replicator/ReplicaManagerTest.java | 4 +-
modules/runner/build.gradle | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 3 +-
.../internal/table/ItReadOnlyTransactionTest.java | 6 +-
.../ignite/internal/table/ItTableScanTest.java | 8 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../ConfigurationCompatibilityTest.java | 6 +-
.../configuration/ignite-snapshot.bin | Bin 5511 -> 5581 bytes
.../internal/sql/api/ItSqlAlterZoneTest.java | 55 ++
.../internal/sql/api/ItSqlCreateZoneTest.java | 17 +
.../internal/sql/engine/ItSecondaryIndexTest.java | 17 +
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../sql/engine/metadata/IgniteMdRowCount.java | 98 +++-
.../ddl/ClusterWideNodeFilterValidator.java | 87 +++
.../prepare/ddl/DdlSqlToCommandConverter.java | 44 +-
...fileValidator.java => NodeFilterValidator.java} | 15 +-
.../prepare/ddl/StorageProfileValidator.java | 3 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 230 ++++----
.../sql/engine/exec/ExecutionServiceImplTest.java | 9 +-
.../sql/engine/exec/PartitionProvidersTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 14 +-
.../exec/rel/TableScanNodeExecutionTest.java | 9 +-
.../engine/framework/ClusterServiceFactory.java | 6 +-
.../sql/engine/framework/NoOpTransaction.java | 4 +-
.../sql/engine/framework/TestBuilders.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 6 +-
.../planner/IndexSearchBoundsPlannerTest.java | 91 ++-
.../engine/planner/JoinRowCountEstimationTest.java | 210 ++++++-
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 2 +-
.../DistributionZoneSqlToCommandConverterTest.java | 9 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 4 +-
.../engine/util/IgniteSqlDateTimeUtilsTest.java | 4 +-
.../src/test/resources/tpcds/plan/q14.plan | 214 +++++++
.../test/resources/tpcds/plan/q14_colocated.plan | 214 +++++++
.../src/test/resources/tpcds/plan/q23.plan | 87 +++
.../test/resources/tpcds/plan/q23_colocated.plan | 87 +++
.../src/test/resources/tpcds/plan/q24.plan | 46 ++
.../test/resources/tpcds/plan/q24_colocated.plan | 46 ++
.../src/test/resources/tpcds/plan/q40.plan | 45 +-
.../test/resources/tpcds/plan/q40_colocated.plan | 45 +-
.../src/test/resources/tpcds/plan/q5.plan | 61 +-
.../test/resources/tpcds/plan/q5_colocated.plan | 52 +-
.../src/test/resources/tpcds/plan/q72.plan | 153 +++--
.../test/resources/tpcds/plan/q72_colocated.plan | 153 +++--
.../src/test/resources/tpcds/plan/q75.plan | 40 +-
.../test/resources/tpcds/plan/q75_colocated.plan | 40 +-
.../src/test/resources/tpcds/plan/q77.plan | 16 +-
.../test/resources/tpcds/plan/q77_colocated.plan | 16 +-
.../src/test/resources/tpcds/plan/q78.plan | 106 ++--
.../test/resources/tpcds/plan/q78_colocated.plan | 106 ++--
.../src/test/resources/tpcds/plan/q80.plan | 155 +++--
.../test/resources/tpcds/plan/q80_colocated.plan | 155 +++--
.../src/test/resources/tpcds/plan/q93.plan | 62 +-
.../test/resources/tpcds/plan/q93_colocated.plan | 62 +-
.../src/test/resources/tpch/plan/q13.plan | 31 +-
.../system/SystemDisasterRecoveryManagerImpl.java | 1 +
.../disaster/system/MetastorageRepairImplTest.java | 10 +-
.../SystemDisasterRecoveryManagerImplTest.java | 12 +-
.../internal/systemview/SystemViewManagerTest.java | 4 +-
modules/table/build.gradle | 1 +
...xDistributedTestSingleNodeNoCleanupMessage.java | 5 +-
.../ignite/internal/table/ItColocationTest.java | 5 +-
.../internal/table/metrics/ItTableMetricsTest.java | 631 +++++++++++++++++++++
.../ignite/internal/table/InternalTable.java | 8 +
.../apache/ignite/internal/table/TableImpl.java | 6 +
.../ignite/internal/table/TableViewInternal.java | 8 +
.../internal/table/distributed/TableManager.java | 45 +-
.../replicator/PartitionReplicaListener.java | 161 +++++-
.../distributed/storage/InternalTableImpl.java | 12 +-
.../internal/table/metrics/TableMetricSource.java | 222 ++++++++
.../distributed/TableManagerRecoveryTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 5 +-
...itionReplicaListenerSortedIndexLockingTest.java | 5 +-
.../replication/PartitionReplicaListenerTest.java | 11 +-
.../ZonePartitionReplicaListenerTest.java | 11 +-
.../storage/InternalTableEstimatedSizeTest.java | 8 +-
.../distributed/storage/InternalTableImplTest.java | 9 +-
.../table/metrics/TableMetricSourceTest.java} | 36 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 7 +-
.../ignite/internal/table/TxAbstractTest.java | 6 +-
.../table/impl/DummyInternalTableImpl.java | 12 +-
.../ignite/internal/tx/ItTxTimeoutOneNodeTest.java | 2 -
.../tx/distributed/ItTransactionRecoveryTest.java | 4 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 12 +
.../apache/ignite/internal/tx/TxCleanupTest.java | 6 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 6 +-
.../internal/tx/impl/OrphanDetectorTest.java | 6 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 4 +-
200 files changed, 4933 insertions(+), 1567 deletions(-)
copy
examples/java/src/main/java/org/apache/ignite/example/compute/{ComputeExample.java
=> ComputeJobStateExample.java} (64%)
create mode 100644 examples/python/db_api_example.py
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/ItApiCompatibilityTest.java
rename modules/compatibility-tests/src/test/resources/versions/{3_0_0 =>
3.0.0}/openapi.yaml (100%)
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/Dependencies.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityExtension.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/trait/AllNodes.java
=>
compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityTestInvocationContext.java}
(54%)
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityChecker.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityExtension.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityInput.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityOutput.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/MethodProvider.java
create mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/TestNameFormatter.java
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{InternalClusterNodeImpl.java
=> ClusterNodeImpl.java} (85%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/configuration/{FileTransferConfigurationSchema.java
=> AckConfigurationSchema.java} (59%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItSqlAlterZoneTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/ClusterWideNodeFilterValidator.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/{StorageProfileValidator.java
=> NodeFilterValidator.java} (63%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/metrics/ItTableMetricsTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/metrics/TableMetricSource.java
copy
modules/{transactions/src/test/java/org/apache/ignite/internal/tx/metrics/TransactionMetricSourceTest.java
=>
table/src/test/java/org/apache/ignite/internal/table/metrics/TableMetricSourceTest.java}
(64%)
