This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/gradle/jackson-2.20.0
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 345b59325c5 Bump jackson from 2.19.2 to 2.20.0
add 8c956b3f0d8 IGNITE-26178 Sql. List of SQL keywords (#6520)
add 938e09d0306 IGNITE-25987 Add public CLI API for partition restart with
cleanup functionality (#6513)
add a4695b99f9e IGNITE-25631 C++ Client: Move verification to
configuration methods (#6523)
add 06e115514ce IGNITE-26308 Mute the test until heartbeats are
implemented (#6522)
add 62c47e04531 IGNITE-26336 Fix node name and node url options (#6510)
add 2130f880dd9 IGNITE-26309 .NET: Fix MetricsTests flakiness (#6529)
add 8f6a1f99e71 IGNITE-25872 Sql. Support GROUPING aggregate function
(#6479)
add b809e6218fd IGNITE-26373 Return public API for auto adjust related
entities (#6537)
add 3b9e88e6f0d IGNITE-26359 Reduce excessive warninng messages during
client message handling (#6528)
add 31292e3213d IGNITE-26312 .NET: Fix port issues in compat tests (#6545)
add 0666e26f594 IGNITE-26181 Fix default byte array marshalling (#6521)
add 07bb9b89e48 IGNITE-26235 Separate public ClusterNode from internal
ClusterNode (#6538)
add ef0e9454678 IGNITE-26383 Use TableViewInternal instead of
implementation (#6547)
add fe7855e2927 IGNITE-26366 Move java examples to java folder (#6531)
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 b045b2ccf01 Bump jackson from 2.19.2 to 2.20.0
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 (345b59325c5)
\
N -- N -- N refs/heads/dependabot/gradle/jackson-2.20.0
(b045b2ccf01)
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:
docs/_docs/developers-guide/compute/compute.adoc | 96 ++--
docs/_docs/developers-guide/sql/sql-api.adoc | 4 +-
examples/{ => java}/.gitignore | 0
examples/{ => java}/README.md | 0
examples/{ => java}/build.gradle | 0
examples/{ => java}/config/ignite-config.conf | 0
.../{ => java}/config/java.util.logging.properties | 0
.../ignite/example/AbstractExamplesTest.java | 0
.../apache/ignite/example/ExampleTestUtils.java | 0
.../ignite/example/sql/ItSqlExamplesTest.java | 0
.../storage/ItPageMemoryStorageExampleTest.java | 0
.../storage/ItRocksdbStorageExampleTest.java | 0
.../ignite/example/table/ItTableExamplesTest.java | 0
.../example/tx/ItTransactionsExamplesTest.java | 0
.../ignite/example/client/IgniteClientExample.java | 0
.../client/IgniteClientWithConfigExample.java | 0
.../code/deployment/CodeDeploymentExample.java | 0
.../ignite/example/code/deployment/MyJob.java | 0
.../example/code/deployment/resources/script.sh | 0
.../example/compute/ComputeAsyncExample.java | 0
.../example/compute/ComputeBroadcastExample.java | 21 +-
.../compute/ComputeCancellationExample.java | 0
.../example/compute/ComputeColocatedExample.java | 0
.../ignite/example/compute/ComputeExample.java | 0
.../example/compute/ComputeJobPriorityExample.java | 2 +-
.../example/compute/ComputeJobStateExample.java} | 50 +-
.../example/compute/ComputeMapReduceExample.java | 0
.../ComputeWithCustomResultMarshallerExample.java | 0
.../example/compute/ComputeWithResultExample.java | 0
.../example/serialization/AutoSerializableArg.java | 0
.../serialization/AutoSerializableResult.java | 0
.../CustomPojoSerializationExample.java | 0
.../serialization/CustomPojoSerializationJob.java | 0
.../example/serialization/IntegerDecrementJob.java | 0
.../ignite/example/serialization/JsonArg.java | 0
.../example/serialization/JsonArgMarshaller.java | 0
.../ignite/example/serialization/JsonResult.java | 0
.../serialization/JsonResultMarshaller.java | 0
.../NativeTypeSerializationExample.java | 0
.../PojoAutoSerializationExample.java | 0
.../serialization/PojoAutoSerializationJob.java | 0
.../serialization/SerializationExample.java | 0
.../serialization/TupleSerializationExample.java | 0
.../example/serialization/TupleTransformJob.java | 0
.../apache/ignite/example/sql/SqlApiExample.java | 0
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 0
.../PersistentPageMemoryStorageExample.java | 0
.../example/storage/RocksDbStorageExample.java | 0
.../example/storage/StorageEngineExample.java | 0
.../storage/VolatilePageMemoryStorageExample.java | 0
.../apache/ignite/example/streaming/Account.java | 0
.../streaming/DetectFailedEntriesExample.java | 0
.../DistributedComputeWithReceiverExample.java | 0
.../streaming/MultiTableDataStreamerExample.java | 0
.../streaming/SingleTableDataStreamerExample.java | 0
.../ignite/example/streaming/TwoTableReceiver.java | 0
.../ignite/example/table/KeyValueViewExample.java | 0
.../example/table/KeyValueViewPojoExample.java | 0
.../ignite/example/table/RecordViewExample.java | 0
.../example/table/RecordViewPojoExample.java | 0
.../ignite/example/tx/TransactionsExample.java | 0
.../{ => java}/src/main/resources/tradesData.csv | 0
examples/python/db_api_example.py | 145 +++++
gradle/libs.versions.toml | 15 +-
.../apache/ignite/catalog/annotations/Zone.java | 9 +
.../ignite/catalog/definitions/ZoneDefinition.java | 38 ++
.../ignite/marshalling/ByteArrayMarshaller.java | 49 +-
.../JavaSerializationByteArrayMarshalling.java | 70 ---
modules/catalog-compaction/build.gradle | 1 +
.../compaction/ItCatalogCompactionTest.java | 8 +-
.../compaction/CatalogCompactionRunner.java | 20 +-
.../CatalogCompactionRunnerSelfTest.java | 42 +-
modules/cli/build.gradle | 1 +
.../restart/ItRestartPartitionsTest.java | 71 ++-
.../recovery/restart/RestartPartitionsCall.java | 12 +-
.../restart/RestartPartitionsCallInput.java | 22 +-
.../ignite/internal/cli/commands/Options.java | 5 +
.../internal/cli/commands/node/NodeUrlMixin.java | 13 +-
.../partitions/restart/RestartPartitionsMixin.java | 10 +
.../repl/completer/StringDynamicCompleter.java | 1 -
.../ignite/internal/cli/commands/MixinTest.java | 246 +++++++++
.../partitions/restart/RestartPartitionsTest.java | 64 +++
.../filter/ExclusionsCompleterFilterTest.java | 1 -
.../handler/ClientInboundMessageHandler.java | 18 +-
.../compute/ClientComputeExecuteRequest.java | 9 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 2 +
.../java/org/apache/ignite/client/TestServer.java | 8 +-
.../apache/ignite/client/fakes/FakeCompute.java | 13 +-
.../ignite/client/fakes/FakeInternalTable.java | 24 +-
.../cluster/management/ItClusterManagerTest.java | 6 +-
.../management/raft/ItCmgRaftServiceTest.java | 10 +-
.../cluster/management/ClusterInitializer.java | 33 +-
.../management/ClusterManagementGroupManager.java | 70 +--
.../management/network/CmgMessageCallback.java | 12 +-
.../management/network/CmgMessageHandler.java | 8 +-
.../management/raft/CmgRaftGroupListener.java | 8 +-
.../cluster/management/raft/CmgRaftService.java | 12 +-
.../cluster/management/raft/ValidationManager.java | 10 +-
.../raft/commands/ClusterNodeMessage.java | 10 +-
.../topology/LogicalTopologyServiceImpl.java | 4 +-
.../management/topology/api/LogicalNode.java | 12 +-
.../topology/api/LogicalNodeSerializer.java | 4 +-
.../topology/api/LogicalTopologyService.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 63 +--
.../management/raft/CmgRaftServiceTest.java | 6 +-
.../topology/LogicalTopologyImplTest.java | 16 +-
.../topology/LogicalTopologyServiceImplTest.java | 4 +-
.../internal/cluster/management/MockNode.java | 6 +-
.../metrics/messaging/MetricMessaging.java | 34 +-
.../deployunit/DeployMessagingService.java | 10 +-
.../ignite/internal/deployunit/NodesToDeploy.java | 6 +-
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 +-
.../PlatformCompatibilityTestNodeRunner.java | 33 +-
.../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/ItComputeErrorsBaseTest.java | 11 +-
.../internal/compute/ItComputeTestStandalone.java | 98 ++--
.../internal/compute/ItExecutionsCleanerTest.java | 7 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 4 +-
.../internal/compute/ItWorkerShutdownTest.java | 14 +-
.../threading/ItComputeApiThreadingTest.java | 3 +-
.../internal/compute/utils/InteractiveJobs.java | 12 +-
.../ignite/internal/compute/ComputeComponent.java | 6 +-
.../internal/compute/ComputeComponentImpl.java | 9 +-
.../internal/compute/ComputeJobFailover.java | 10 +-
.../ignite/internal/compute/ComputeUtils.java | 12 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 67 ++-
.../internal/compute/IgniteComputeInternal.java | 4 +-
.../internal/compute/NextWorkerSelector.java | 4 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 4 +-
.../compute/TaskToJobExecutionWrapper.java | 10 +-
.../internal/compute/executor/ComputeExecutor.java | 4 +-
.../compute/executor/ComputeExecutorImpl.java | 7 +-
.../compute/executor/JobExecutionInternal.java | 10 +-
.../compute/messaging/ComputeMessaging.java | 62 ++-
.../compute/messaging/RemoteJobExecution.java | 11 +-
.../internal/compute/ComputeComponentImplTest.java | 18 +-
.../internal/compute/IgniteComputeImplTest.java | 38 +-
.../compute/loader/JobClassLoaderTest.java | 10 +-
.../internal/network/PublicClusterNodeImpl.java} | 8 +-
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 8 +-
.../DistributionZoneManagerAlterFilterTest.java | 12 +-
.../DistributionZoneManagerFilterTest.java | 12 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 4 +-
...butionZoneManagerStorageProfilesFilterTest.java | 12 +-
.../DistributionZoneCausalityDataNodesTest.java | 18 +-
.../DistributionZonesTestUtil.java | 8 +-
.../tech-notes/images/cancelRebalance.svg | 2 +-
.../tech-notes/images/primaryReplica.svg | 2 +-
.../ignite/internal/network/file/TestCluster.java | 4 +-
.../network/file/FileTransferServiceImpl.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 8 +-
.../network/file/TestMessagingService.java | 19 +-
.../internal/network/file/TestTopologyService.java | 26 +-
.../internal/index/IndexBuildController.java | 4 +-
.../ignite/internal/index/IndexBuildTask.java | 6 +-
.../apache/ignite/internal/index/IndexBuilder.java | 6 +-
.../internal/index/IndexManagementUtils.java | 6 +-
.../IndexNodeFinishedRwTransactionsChecker.java | 6 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 8 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 19 +-
.../IndexAvailabilityControllerRestorerTest.java | 4 +-
.../index/IndexAvailabilityControllerTest.java | 4 +-
.../ignite/internal/index/IndexBuilderTest.java | 12 +-
.../internal/index/IndexManagementUtilsTest.java | 14 +-
.../internal/index/TestIndexManagementUtils.java | 8 +-
.../internal/lowwatermark/LowWatermarkImpl.java | 4 +-
.../lowwatermark/LowWatermarkImplTest.java | 6 +-
.../cache/IdempotentCacheVacuumizer.java | 4 +-
.../ItMetaStorageMultipleNodesVsStorageTest.java | 4 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 10 +-
.../metastorage/impl/ElectionListener.java | 4 +-
.../impl/MetaStorageCompactionTrigger.java | 6 +-
.../impl/MetaStorageLeaderElectionListener.java | 4 +-
.../impl/MetaStorageLearnerManager.java | 10 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 4 +-
.../MetaStorageLeaderElectionListenerTest.java | 8 +-
.../impl/MetaStorageManagerRecoveryTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 10 +-
.../internal/network/ClusterNodeResolver.java | 7 +-
.../internal/network/ClusterNodeSerializer.java | 11 +-
.../ignite/internal/network/IgniteClusterImpl.java | 14 +-
.../internal/network/InternalClusterNode.java} | 12 +-
...rNodeImpl.java => InternalClusterNodeImpl.java} | 17 +-
.../ignite/internal/network/JoinedNodes.java | 6 +-
.../ignite/internal/network/MessagingService.java | 55 +-
.../internal/network/NetworkMessageHandler.java | 3 +-
.../internal/network/TopologyEventHandler.java | 6 +-
.../ignite/internal/network/TopologyService.java | 9 +-
.../network/TrackableNetworkMessageHandler.java | 3 +-
.../network/UnresolvableConsistentIdException.java | 3 +-
.../JumpToExecutorByConsistentIdAfterSend.java | 15 +-
...java => InternalClusterNodeSerializerTest.java} | 9 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 24 +-
.../network/SingleClusterNodeResolver.java | 11 +-
.../network/netty/ItConnectionManagerTest.java | 32 +-
.../node/ItNodeStalenessAndRestartTest.java | 4 +-
.../network/scalecube/ItClusterServiceTest.java | 14 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 132 +++--
.../internal/network/DefaultMessagingService.java | 35 +-
.../internal/network/NettyBootstrapFactory.java | 10 +
...tionSchema.java => AckConfigurationSchema.java} | 34 +-
.../configuration/NetworkConfigurationSchema.java | 4 +
.../handshake/HandshakeEventLoopSwitcher.java | 4 +-
.../network/message/ClusterNodeMessage.java | 12 +-
.../internal/network/netty/ConnectionManager.java | 14 +-
.../internal/network/netty/HandshakeHandler.java | 4 +-
.../internal/network/netty/InNetworkObject.java | 10 +-
.../network/netty/InboundRecoveryHandler.java | 67 ++-
.../internal/network/netty/MessageHandler.java | 6 +-
.../ignite/internal/network/netty/NettySender.java | 4 +-
.../internal/network/netty/PipelineUtils.java | 9 +-
.../network/recovery/HandshakeManagerUtils.java | 4 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 20 +-
.../RecoveryInitiatorHandshakeManager.java | 22 +-
.../RecoveryInitiatorHandshakeManagerFactory.java | 4 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 10 +-
.../scalecube/ScaleCubeTopologyService.java | 74 +--
.../network/DefaultMessagingServiceTest.java | 68 +--
.../handshake/NoOpHandshakeEventLoopSwitcher.java | 4 +-
.../network/netty/RecoveryHandshakeTest.java | 40 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 15 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 19 +-
.../scalecube/ScaleCubeTopologyServiceTest.java | 14 +-
.../replicator/ItZoneDataReplicationTest.java | 4 +-
.../replicator/fixtures/TestPlacementDriver.java | 6 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 4 +-
.../PartitionReplicaLifecycleManager.java | 4 +-
.../partition/replicator/ReplicaPrimacyEngine.java | 6 +-
.../partition/replicator/TxRecoveryEngine.java | 6 +-
.../replicator/ZonePartitionReplicaListener.java | 6 +-
...xStateCommitPartitionReplicaRequestHandler.java | 6 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 14 +-
.../outgoing/OutgoingSnapshotsManager.java | 6 +-
.../PartitionReplicaLifecycleManagerTest.java | 5 +-
.../incoming/IncomingSnapshotCopierTest.java | 12 +-
.../placementdriver/TestPlacementDriver.java | 15 +-
.../placementdriver/TestReplicaMetaImpl.java | 12 +-
.../ItPrimaryReplicaChoiceTest.java | 11 +-
.../PlacementDriverManagerTest.java | 4 +-
.../internal/placementdriver/LeaseUpdater.java | 20 +-
.../placementdriver/PlacementDriverManager.java | 4 +-
.../internal/placementdriver/TopologyTracker.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 18 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 1 +
.../platforms/cpp/ignite/client/ignite_client.cpp | 7 -
.../ignite_client_configuration.cpp} | 17 +-
.../ignite/client/ignite_client_configuration.h | 38 +-
modules/platforms/cpp/ignite/client/ssl_mode.h | 2 +-
.../cpp/ignite/network/detail/win/sockets.cpp | 1 -
.../cpp/tests/client-test/ignite_client_test.cpp | 60 +++
.../cpp/tests/client-test/ignite_runner_suite.h | 4 +-
.../CurrentClientWithOldServerCompatibilityTest.cs | 7 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 106 ++--
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 3 -
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 2 +-
modules/platforms/python/tests/test_fetch_table.py | 3 +-
.../internal/raft/LeaderElectionListener.java | 4 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 8 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 8 +-
.../server/impl/RaftServiceEventInterceptor.java | 10 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 4 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 5 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 14 +-
.../rpc/impl/RaftGroupEventsClientListener.java | 4 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 48 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 8 +-
.../ItPlacementDriverReplicaSideTest.java | 4 +-
.../raft/client/TopologyAwareRaftGroupService.java | 27 +-
.../PlacementDriverMessageProcessor.java | 14 +-
.../ignite/internal/replicator/ReplicaImpl.java | 6 +-
.../ignite/internal/replicator/ReplicaManager.java | 14 +-
.../ignite/internal/replicator/ReplicaService.java | 8 +-
.../exception/ReplicaStoppingException.java | 4 +-
.../exception/ReplicaUnavailableException.java | 4 +-
.../replicator/PlacementDriverReplicaSideTest.java | 18 +-
.../internal/replicator/ReplicaManagerTest.java | 4 +-
.../AbstractTopologyAwareGroupServiceTest.java | 24 +-
.../internal/replicator/ReplicaTestUtils.java | 6 +-
.../topology/TestLogicalTopologyService.java | 4 +-
modules/rest/build.gradle | 1 +
.../internal/rest/cluster/TopologyController.java | 5 +-
.../apache/ignite/internal/ItIgniteStartTest.java | 6 +-
.../ItTruncateRaftLogAndRestartNodesTest.java | 4 +-
.../management/ItDuplicateNodeNamesTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 8 +-
.../app/client/ItThinClientTransactionsTest.java | 9 +-
.../app/compute/ItEmbeddedMarshallingTest.java | 24 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
.../internal/table/ItReadOnlyTransactionTest.java | 22 +-
.../ignite/internal/table/ItReplicasTest.java | 10 +-
.../ignite/internal/table/ItTableScanTest.java | 21 +-
.../partition/ItAbstractPartitionManagerTest.java | 6 +-
.../main/java/org/apache/ignite/IgniteServer.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
.../ConfigurationCompatibilityTest.java | 6 +-
.../configuration/ignite-snapshot.bin | Bin 5511 -> 5581 bytes
.../internal/ClusterPerClassIntegrationTest.java | 3 +-
.../internal/ClusterPerTestIntegrationTest.java | 13 +-
.../internal/sql/engine/ItAggregatesTest.java | 72 ++-
.../internal/sql/engine/ItSecondaryIndexTest.java | 17 +
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 1 -
.../systemviews/ItTransactionsSystemViewTest.java | 4 +-
.../engine/systemviews/ItZonesSystemViewTest.java | 1 -
.../group1/aggregate/group/test_grouping_sets.test | 149 ++++++
.../group/test_multicolumn_grouping_sets.test | 106 ++++
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 6 +-
.../internal/sql/engine/exec/ExecutionContext.java | 8 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 24 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 6 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 3 +
.../sql/engine/exec/exp/agg/Accumulators.java | 65 +++
.../engine/exec/exp/agg/AccumulatorsFactory.java | 19 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 21 +-
.../sql/engine/exec/kill/KillCommandHandler.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 2 +-
.../sql/engine/message/MessageListener.java | 4 +-
.../sql/engine/message/MessageServiceImpl.java | 12 +-
.../sql/engine/metadata/IgniteMdRowCount.java | 98 +++-
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 27 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 1 +
.../internal/sql/engine/util/IgniteResource.java | 5 +
.../ignite/internal/sql/engine/util/RexUtils.java | 230 ++++----
.../ignite/internal/sql/docs/OperatorListTest.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 24 +-
.../sql/engine/exec/PartitionProvidersTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../exec/exp/agg/GroupingAccumulatorTest.java | 189 +++++++
.../engine/exec/kill/KillCommandHandlerTest.java | 24 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 28 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 18 +-
.../exec/rel/TableScanNodeExecutionTest.java | 10 +-
.../engine/framework/ClusterServiceFactory.java | 52 +-
.../sql/engine/framework/NoOpTransaction.java | 10 +-
.../sql/engine/framework/TestBuilders.java | 8 +-
.../planner/AbstractAggregatePlannerTest.java | 35 +-
.../sql/engine/planner/AggregatePlannerTest.java | 12 +
.../planner/ColocatedHashAggregatePlannerTest.java | 12 +
.../planner/ColocatedSortAggregatePlannerTest.java | 12 +
.../sql/engine/planner/DmlPlannerTest.java | 6 +-
.../planner/IndexSearchBoundsPlannerTest.java | 91 +++-
.../engine/planner/JoinRowCountEstimationTest.java | 210 +++++++-
.../planner/MapReduceHashAggregatePlannerTest.java | 12 +
.../planner/MapReduceSortAggregatePlannerTest.java | 12 +
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 4 +-
.../DistributionZoneSqlToCommandConverterTest.java | 4 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 4 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 581 +++++++++++++++++++++
.../engine/util/IgniteSqlDateTimeUtilsTest.java | 4 +-
.../src/test/resources/docs/operator_list.txt | 3 +
.../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/q27.plan | 68 +++
.../test/resources/tpcds/plan/q27_colocated.plan | 68 +++
.../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 +-
.../disaster/system/MetastorageRepairImpl.java | 4 +-
.../system/SystemDisasterRecoveryManagerImpl.java | 34 +-
.../disaster/system/MetastorageRepairImplTest.java | 14 +-
.../SystemDisasterRecoveryManagerImplTest.java | 44 +-
.../internal/systemview/SystemViewManagerTest.java | 6 +-
.../ItAbstractInternalTableScanTest.java | 12 +-
.../ItInternalTableReadOnlyOperationsTest.java | 18 +-
.../ItInternalTableReadOnlyScanTest.java | 4 +-
.../ItInternalTableReadWriteScanTest.java | 4 +-
.../apache/ignite/distributed/ItLockTableTest.java | 4 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 6 +-
.../ItTxObservableTimePropagationTest.java | 4 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 4 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 10 +-
.../ignite/internal/table/ItColocationTest.java | 8 +-
.../ignite/internal/table/InternalTable.java | 20 +-
.../internal/table/StreamerReceiverRunner.java | 6 +-
.../apache/ignite/internal/table/TableImpl.java | 8 +-
.../ignite/internal/table/TableViewInternal.java | 10 +
.../PartitionReplicatorNodeRecovery.java | 12 +-
.../internal/table/distributed/TableManager.java | 82 +--
.../disaster/DisasterRecoveryManager.java | 21 +-
.../replicator/PartitionReplicaListener.java | 6 +-
.../replicator/TransactionStateResolver.java | 4 +-
.../distributed/storage/InternalTableImpl.java | 22 +-
.../table/partition/HashPartitionManagerImpl.java | 9 +-
.../ignite/internal/utils/PrimaryReplica.java | 8 +-
.../distributed/TableManagerRecoveryTest.java | 12 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../PartitionReplicaListenerIndexLockingTest.java | 8 +-
...itionReplicaListenerSortedIndexLockingTest.java | 8 +-
.../replication/PartitionReplicaListenerTest.java | 14 +-
.../ZonePartitionReplicaListenerTest.java | 14 +-
.../storage/InternalTableEstimatedSizeTest.java | 6 +-
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 24 +-
.../ignite/internal/table/TxAbstractTest.java | 6 +-
.../internal/table/TxInfrastructureTest.java | 8 +-
.../table/impl/DummyInternalTableImpl.java | 28 +-
.../tx/distributed/ItTransactionRecoveryTest.java | 7 +-
.../impl/FinishedReadOnlyTransactionTracker.java | 4 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 4 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 6 +-
.../tx/impl/RemoteReadWriteTransaction.java | 4 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 12 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 4 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 12 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 14 +-
...FinishedTransactionBatchRequestHandlerTest.java | 4 +-
.../internal/tx/impl/OrphanDetectorTest.java | 16 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 6 +-
.../internal/worker/ThreadAssertingCursor.java | 1 -
settings.gradle | 2 +-
453 files changed, 7060 insertions(+), 2861 deletions(-)
rename examples/{ => java}/.gitignore (100%)
rename examples/{ => java}/README.md (100%)
rename examples/{ => java}/build.gradle (100%)
rename examples/{ => java}/config/ignite-config.conf (100%)
rename examples/{ => java}/config/java.util.logging.properties (100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/AbstractExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/ExampleTestUtils.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/sql/ItSqlExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/storage/ItPageMemoryStorageExampleTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/storage/ItRocksdbStorageExampleTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/table/ItTableExamplesTest.java
(100%)
rename examples/{ =>
java}/src/integrationTest/java/org/apache/ignite/example/tx/ItTransactionsExamplesTest.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/client/IgniteClientExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/client/IgniteClientWithConfigExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/CodeDeploymentExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/MyJob.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/code/deployment/resources/script.sh
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeAsyncExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeBroadcastExample.java
(83%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeCancellationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeColocatedExample.java
(100%)
copy examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeExample.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeJobPriorityExample.java
(99%)
rename
examples/{src/main/java/org/apache/ignite/example/compute/ComputeExample.java
=>
java/src/main/java/org/apache/ignite/example/compute/ComputeJobStateExample.java}
(64%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeMapReduceExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeWithCustomResultMarshallerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/compute/ComputeWithResultExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/AutoSerializableArg.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/AutoSerializableResult.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/IntegerDecrementJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonArg.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonArgMarshaller.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonResult.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/JsonResultMarshaller.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/NativeTypeSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/SerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/TupleSerializationExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/serialization/TupleTransformJob.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/sql/SqlApiExample.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/sql/jdbc/SqlJdbcExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/PersistentPageMemoryStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/RocksDbStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/StorageEngineExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/storage/VolatilePageMemoryStorageExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/Account.java (100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/DistributedComputeWithReceiverExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/MultiTableDataStreamerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/KeyValueViewExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/KeyValueViewPojoExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/RecordViewExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/table/RecordViewPojoExample.java
(100%)
rename examples/{ =>
java}/src/main/java/org/apache/ignite/example/tx/TransactionsExample.java (100%)
rename examples/{ => java}/src/main/resources/tradesData.csv (100%)
create mode 100644 examples/python/db_api_example.py
delete mode 100644
modules/api/src/main/java/org/apache/ignite/marshalling/JavaSerializationByteArrayMarshalling.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/MixinTest.java
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
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/ClusterNodeImpl.java
=>
core/src/main/java/org/apache/ignite/internal/network/PublicClusterNodeImpl.java}
(90%)
copy modules/{api/src/main/java/org/apache/ignite/network/ClusterNode.java =>
network-api/src/main/java/org/apache/ignite/internal/network/InternalClusterNode.java}
(82%)
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterNodeImpl.java
=> InternalClusterNodeImpl.java} (81%)
rename
modules/network-api/src/test/java/org/apache/ignite/internal/network/{ClusterNodeSerializerTest.java
=> InternalClusterNodeSerializerTest.java} (88%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/configuration/{FileTransferConfigurationSchema.java
=> AckConfigurationSchema.java} (59%)
copy modules/platforms/cpp/ignite/{common/uuid.cpp =>
client/ignite_client_configuration.cpp} (72%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_grouping_sets.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_multicolumn_grouping_sets.test
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/GroupingAccumulatorTest.java
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q27.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q27_colocated.plan
