This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-26037
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 3b2ce6c7cf8 IGNITE-26037 after review #1.0
add 410550d947f IGNITE-25874 Sql. Make it possible to run multi-statement
Tpcds queries (#6326)
add 97bb0b78dea IGNITE-26014 Sql. ArrayIndexOutOfBoundsException when
converting MERGE with join (#6335)
add d0388362682 IGNITE-25877 Critical system error caused by failure in
updating data nodes history and timers on scale up timer trigger (#6349)
add e91a86fcfaa IGNITE-25588 Sql. Support CURRENT_USER function (#6314)
add 929c9d370c7 IGNITE-25938 Add the metric log exporter to the default
configuration (#6350)
add da542549313 IGNITE-26097 Duplicate events in the log inspector (#6355)
add b9553f2f3cb IGNITE-26113 Create noop event log (#6359)
add 352da58f2e8 IGNITE-26114 Extract common thin client testing
functionality (#6360)
add dd5e635c4be IGNITE-26051 Ignore destroyed tables in write intent
switch command (#6362)
add a584943a8d8 IGNITE-24116 Create compute task events (#6358)
add 084d850d6d2 IGNITE-26128 Add to IgniteTestUtils#runRace suspended
exceptions of operations if the race did not end by timeout (#6368)
add 2c586ec04d4 IGNITE-26117 Use non-durable Raft storages destruction for
table destruction (#6363)
add b9049ade572 IGNITE-26115 Create compute task events for thin client
(#6361)
add ab8a6b82839 IGNITE-25488 C++ Client: Add transaction timeouts (#6352)
add 84646bbf7f2 IGNITE-25457 IGNITE_SENSITIVE_DATA_LOGGING property has
been moved from a system property to configuration (#6365)
add 2f613916bc2 IGNITE-26131 Fix avgWriteSpeed logging at checkpoint
finish (#6369)
add 6c2cec86555 IGNITE-26136 Disable
ItCmgDisasterRecoveryTest#repairWorksWhenCmgMajorityIsOnline (#6372)
add 2d36bfbcb5d IGNITE-26154 Reduce `byte[]` allocation rate (#6375)
add ad38bf0af57 IGNITE-26078 Update transactions Java example (#6346)
add 8a93cd8318c IGNITE-26082 Update Streaming API examples (#6348)
add 5b328d66dd9 IGNITE-26132 Improve retry writing of dirty pages (#6382)
add 55bec6e74cc IGNITE-26021 Support prefixes in JitComparator (#6377)
add fffbc662d7e IGNITE-21553 fixed test: compute broadcast when using
incorrect node. (#6381)
add 1ecc1b64643 IGNITE-26162 make compatibility tests more extensible &
fix hardcode (#6386)
add 1bd6475444f IGNITE-25811 Sql. Forbid use of an expression as interval
string (#6364)
add aad0f8a9677 IGNITE-26165 Fix event log configuration usage (#6388)
add e6792e23313 IGNITE-26167 Fix testExecuteMapReduceExceptionPropagation
(#6390)
add ab8b8bb3f2a IGNITE-26112 Disable multiline separators (#6367)
add 7c26060d20c IGNITE-26171 Fix NullPointerException on write retry pages
at checkpoint (#6394)
add 1e6487e7f02 IGNITE-26075 Fix refreshAndGetLeaderWithTerm in order not
to return stale leader (#6344)
add 4c92cf4262c IGNITE-26002 Network thread even distribution (#6370)
add 7179bc254b5 Bump spring-boot from 3.5.3 to 3.5.4 (#6319)
add f9b0045378a Bump org.junit.platform:junit-platform-console from 1.13.3
to 1.13.4 (#6292)
add 127e0dbecf4 IGNITE-25191 Fix Vacuum silently fails in ItSqlLogicTest
(#6373)
add e7ff1c9390e Bump io.swagger.core.v3:swagger-annotations from 2.2.34 to
2.2.35 (#6351)
add b2bf5f6ffa4 IGNITE-26033 Sql. Fix
TestClusterTest.testHybridTimestampPropagationToInitiator (#6392)
add e0c472d2116 IGNITE-26135 Sql. Support DELETE operation in optimized
plans (#6378)
add 41fecc1dc4d IGNITE-26029 Sql. Ensure that integration tests that use
index value lookups use a plan with search bounds (#6380)
add dbda22fc6af Revert "Bump io.swagger.core.v3:swagger-annotations from
2.2.34 to 2.2.35 (#6351)"
add 6597998baa4 IGNITE-26188 Fix potential memory leak in
DelayedPageReplacementTracker (#6407)
add 0ac1e575f6b IGNITE-26193 Reduce the number of TxPriority[] allocations
(#6411)
add 3c03e789b23 IGNITE-26170 Update criteria query example (#6393)
add 4db00b0b477 IGNITE-26195 Reduce the number of lambda allocations in
BinaryRowConverter (#6412)
add 5a331a01034 IGNITE-21632 Upgrade to PMD 7.0 (#6357)
add a2f79d1b985 IGNITE-25693 Reduce client connector logging level on SSL
and handhsake errors (#6415)
add 2e5f3cc39f1 IGNITE-25903 Sql. Support literals in PA metadata builder
(#6406)
add 339709ec4e8 IGNITE-26138 Sql. Partition awareness. Prepare partition
pruning metadata after planning (#6374)
add 3487e50d3e7 IGNITE-26163 Improve MT error logging (#6387)
add e4e6618c9e5 IGNITE-26031 Fix
ItConnectionErrorTest.testStopLeader/Follower (#6419)
add 4235b2880a4 IGNITE-26201 Stop persisting calculated default storage
profile size (#6422)
add c0a3e9f0a0b IGNITE-26197 Add configuration information into the
message about critical thread being blocked (#6426)
add b19d0dc0f39 IGNITE-26205 Raise maxAllowedLagMillis default to 5
seconds (#6427)
add 20a5873c8d3 IGNITE-26198 Sql. Added SQL property to optionally
restrict query execution with multiple statements (#6420)
add 0f57457c220 IGNITE-25953 Report to log TimeoutExceptions during safe
time sync (#6389)
add 32a6c467699 IGNITE-26196 Make node staleness status volatile (#6424)
add fd673559831 IGNITE-26207 Fix flaky ItMetaStorageWatchTest (#6428)
add 9b7507441e6 IGNITE-26030 Fix critical system error on raft client stop
(#6432)
add e684b67e71b IGNITE-25899 Add group name to the raft logs (#6410)
add c02569ccb34 IGNITE-25493 Fix
ItReplicaLifecycleTest.testAlterReplicaTriggerDefaultZone (#6435)
add b0698a359e5 IGNITE-26121 Print warning message if MAX_CLOCK_SKEW
exceeded (#6376)
add 64630e192c4 IGNITE-26191 Do not persist defaults to node config file
(#6409)
add 7faf6322f39 IGNITE-26217 Update checkstyle plugin to 11.0.0 (#6431)
add d2c3b3ac3ab IGNITE-26176 Close result set (#6396)
add 2f0e17df400 IGNITE-25724 Add rebalance metrics (#6416)
add 2b2c8d75fb0 IGNITE-26227 Fix server shutdown in case of an error
(#6441)
add 543544b5dc6 IGNITE-26224 Improve tuple map handling (#6438)
add ca1eef16ea8 IGNITE-26216 Add partition generation to in-memory page
header for PersistentPageMemory (#6442)
add 661afbdd2ac IGNITE-26199 Sql. Expand usage of HashJoin with non-equi
predicate to LEFT joins (#6423)
add 472c705d818 IGNITE-26231 Update page header documentation in
PersistentPageMemory (#6444)
add a92d1a54f53 IGNITE-26229 Fix wrong default profile size usage in
"aipersist" (#6443)
add a86b59014cb IGNITE-26116 Create compute task events for remote
execution (#6391)
add 337722d28b5 IGNITE-26232 Minor refactoring for PageHeader (#6445)
add 94264880db1 IGNITE-26200 Migration Tools: Fix error in windows startup
scripts (#6421)
add 337bcf7257d IGNITE-26234: Add node autocompletion (#6447)
add 30849b81ac8 IGNITE-25112 Bump Netty from 4.1.119.Final to 4.2.4.Final
(#6450)
add c5969bd3577 IGNITE-26236 Downgrade checkstyle plugin to 10.26.1 (#6448)
add 26516f65841 IGNITE-26122 Add metric for clock drift (#6440)
add 0caa71927b6 IGNITE-17232 Optimize DeltaFilePageStore by write new
pages directly to FilePageStore (#6343)
add 23cb3ea085e IGNITE-25823 Increase test coverage for restarting
partitions with cleanup feature (#6414)
add 50d930fd3dd IGNITE-26184 Bump swagger from 2.2.34 to 2.2.36 (#6451)
add d250e635e35 IGNITE-25560 Sql. Partition awareness cover extension
(#6418)
add a2daba430e2 IGNITE-26218 Sql. Fixed flaky test
ItSqlMultiStatementTest.statementRestrictedByQueryType (#6434)
add 9ff0dfa63ee IGNITE-25952 Sql. Fixed TIME to VARCHAR conversion using a
format with fractions (#6439)
add e88558f0863 IGNITE-26184 Fix client connector Netty buffer leaks
(#6453)
add 7cc0779a926 IGNITE-25590 Add node name to checkpointer thread names
(#6454)
add 93e47e436d7 IGNITE-26252 Minor code refactoring related to partition
generation in PersistentPageMemory (#6457)
add 6bc4dccdfe0 IGNITE-22818 Fix cmg reordering (#6408)
add 00a2189d837 IGNITE-26251 Fix event sink leak (#6455)
add 2b5b6720cd8 IGNITE-26255 Testing checkpoint after partition
destruction in PersistentPageMemory (#6460)
add a114067fc63 IGNITE-26064 Update metric log exporter config params
(#6417)
add 14ab3b77c8a IGNITE-26144 Do not fail node on node stop in
PlacementDriverManager (#6462)
add 128fcc89c5f IGNITE-26204 Add step to create configuration snapshot to
release procedure (#6425)
add d21a78052d2 IGNITE-26273 Make DDL converter API asynchronous (#6468)
add e847e4d32b8 IGNITE-26230 Introduce MessageFormat (#6466)
add 2c80e497793 IGNITE-26265 Fix flaky testTwoPhaseResetEqualLogIndex
(#6465)
add db6f21a4e13 Bump io.opentelemetry:opentelemetry-exporter-otlp from
1.52.0 to 1.53.0 (#6404)
add 47cfe883c23 IGNITE-25859 Implement pessimistic case of create zone on
unstable topology (#6430)
add af94f7df4d2 IGNITE-26253 Make the cluster init failures more verbose
(#6459)
add 2e485dc809d IGNITE-20754 Remove TODO (#6475)
add 1d68c78e43d Bump org.junit.platform:junit-platform-testkit from 1.13.3
to 1.13.4 (#6293)
add 29bd72ab542 IGNITE-26287 Upgrade Spotbugs to 4.9.4 (#6477)
add b9cb80d7905 IGNITE-25627 Remove invalid pages from AI3 documentation
and fix TOC (#6013)
add 0100d83349d IGNITE-25682 Document C++ client heartbeats support (#6051)
add 9e0070243fb IGNITE-23779 Decrease contention on attachment lock (#6472)
add e7be9dccada Bump spring-boot from 3.5.4 to 3.5.5 (#6486)
add 3f60b5f2591 Bump com.github.spotbugs from 6.2.2 to 6.2.5 (#6485)
add 668698acade Bump mockito from 5.18.0 to 5.19.0 (#6484)
add c7b6db31d7f IGNITE-26210 Update serialization examples (#6437)
add 18de26710c7 IGNITE-25806 Add cancellation query examples (#6201)
add dbeb2399bd9 IGNITE-26303 mute
testRestartTablePartitionsWithCleanUpConcurrentRebalance (#6480)
add 10d5e35d287 Bump value from 2.11.1 to 2.11.3 (#6482)
add 73cba3e2d28 IGNITE-26172 Log job failed event when failover fails
(#6461)
add 885de79599f IGNITE-26169 Update code deployment example (#6398)
add 8fcd8d562e3 IGNITE-25979 Support
DisasterRecoveryManager#restartPartitionWithCleanup in Colocation track (#6458)
add e31b4b0b265 IGNITE-26233 Fix issues after increasing partition
generation and checkpoint (#6463)
add a768ca87ebf Merge branch 'main' into ignite-26037
No new revisions were added by this update.
Summary of changes:
.idea/checkstyle-idea.xml | 6 +-
RELEASE.md | 11 +-
check-rules/checkstyle-rules.xml | 2 +
check-rules/pmd-rules.xml | 3 +-
check-rules/spotbugs-excludes.xml | 13 +-
docs/_data/toc.yaml | 28 +-
.../administrators-guide/config/node-config.adoc | 12 +-
.../metrics/configuring-metrics.adoc | 37 +-
docs/_docs/developers-guide/clients/overview.adoc | 2 +-
docs/_docs/developers-guide/compute/compute.adoc | 4 +-
docs/_docs/developers-guide/sql/sql-api.adoc | 49 +-
docs/_docs/ignite-cli-tool.adoc | 10 +-
docs/_docs/limitations.adoc | 100 --
.../sql-reference/explain-operators-list.adoc | 5 +-
examples/build.gradle | 2 +
.../code/deployment/CodeDeploymentExample.java | 58 +
.../ignite/example/code/deployment/MyJob.java | 71 ++
.../example/code/deployment/resources/script.sh | 3 +
.../example/serialization/AutoSerializableArg.java | 18 +-
.../serialization/AutoSerializableResult.java | 8 +-
.../CustomPojoSerializationExample.java | 85 ++
.../serialization/CustomPojoSerializationJob.java | 42 +-
.../example/serialization/IntegerDecrementJob.java | 10 +-
.../ignite/example/serialization/JsonArg.java | 15 +-
.../example/serialization/JsonArgMarshaller.java | 33 +-
.../ignite/example/serialization/JsonResult.java | 8 +-
.../serialization/JsonResultMarshaller.java | 32 +-
.../NativeTypeSerializationExample.java | 43 +
.../PojoAutoSerializationExample.java | 52 +
.../serialization/PojoAutoSerializationJob.java | 23 +-
.../SerializationExample.java} | 28 +-
.../serialization/TupleSerializationExample.java | 45 +
.../example/serialization/TupleTransformJob.java | 15 +-
.../{pojo/AccountValue.java => Account.java} | 79 +-
.../streaming/DetectFailedEntriesExample.java | 96 ++
.../DistributedComputeWithReceiverExample.java | 144 +++
.../streaming/KeyValueViewDataStreamerExample.java | 219 ----
.../KeyValueViewPojoDataStreamerExample.java | 219 ----
.../streaming/MultiTableDataStreamerExample.java | 97 ++
.../streaming/RecordViewDataStreamerExample.java | 217 ----
.../RecordViewPojoDataStreamerExample.java | 213 ----
.../streaming/SingleTableDataStreamerExample.java | 132 +++
.../ignite/example/streaming/TwoTableReceiver.java | 44 +
.../ignite/example/streaming/pojo/Account.java | 98 --
.../ignite/example/streaming/pojo/AccountKey.java | 50 -
.../ignite/example/streaming/pojo/Trade.java | 118 --
.../receiver/ReceiverStreamProcessingExample.java | 276 -----
...treamProcessingWithResultSubscriberExample.java | 342 ------
...iverStreamProcessingWithTableUpdateExample.java | 379 ------
.../ignite/example/tx/TransactionsExample.java | 133 +--
gradle/libs.versions.toml | 25 +-
.../exceptions/DataStreamerExceptionHandler.java | 24 +-
...cordAndTableSchemaMismatchExceptionHandler.java | 37 +-
.../cli/persistence/params/MigrationMode.java | 1 +
.../tests/clusters/FullSampleCluster.java | 6 +-
.../tests/containers/Ignite2ClusterContainer.java | 3 +
.../tests/containers/Ignite3ClusterContainer.java | 1 -
.../ignite/migrationtools/sql/SqlDdlGenerator.java | 2 +
.../types/converters/IdentityConverter.java | 2 +-
.../sql/sql/SqlDdlGeneratorTest.java | 48 +-
.../converters/ClientConnectorConverter.java | 1 -
.../persistence/Ignite2PersistentCacheTools.java | 22 +
.../persistence/MigrationCacheProcessor.java | 15 +-
.../persistence/MigrationKernalContext.java | 6 +-
.../exceptions/MigrateCacheException.java | 56 +
.../utils/pubsub/RateLimiterProcessorTest.java | 5 +-
migration-tools/packaging/cli/start.bat | 11 +-
.../packaging/common/windows/setup-java.bat | 2 +-
.../catalog/definitions/TableDefinition.java | 1 -
.../apache/ignite/deployment/version/Version.java | 1 -
.../org/apache/ignite/marshalling/Marshaller.java | 1 -
.../UnsupportedObjectTypeMarshallingException.java | 1 -
.../exception/InvalidCredentialsException.java | 1 -
.../UnsupportedAuthenticationTypeException.java | 1 -
.../java/org/apache/ignite/table/TupleImpl.java | 19 +-
.../org/apache/ignite/table/criteria/Criteria.java | 4 +-
.../org/apache/ignite/tx/TransactionException.java | 1 -
.../marshalling/ByteArrayMarshallerTest.java | 2 -
.../internal/binarytuple/BinaryTupleParser.java | 4 +-
.../inlineschema/TupleWithSchemaMarshalling.java | 2 -
.../ignite/internal/catalog/ItCatalogDslTest.java | 1 -
.../catalog/sql/CreateFromDefinitionTest.java | 1 -
.../internal/catalog/CatalogApplyResult.java | 1 -
.../internal/catalog/commands/CatalogUtils.java | 1 -
.../catalog/commands/CreateSystemViewCommand.java | 1 -
.../SchemaSynchronizationConfigurationSchema.java | 1 +
.../descriptors/CatalogSortedIndexDescriptor.java | 1 -
.../catalog/descriptors/ConsistencyMode.java | 1 -
.../internal/catalog/storage/UpdateLogImpl.java | 4 +-
.../ignite/internal/catalog/CatalogIndexTest.java | 1 -
.../ignite/internal/catalog/CatalogSchemaTest.java | 1 -
.../internal/catalog/CatalogSystemViewTest.java | 1 -
.../ignite/internal/catalog/CatalogZoneTest.java | 1 -
.../catalog/storage/UpdateLogImplTest.java | 2 +-
.../ignite/internal/cli/CliIntegrationTest.java | 4 +-
.../configuration/ItConfigCommandTest.java | 2 -
...tConnectWithBasicAuthenticationCommandTest.java | 1 -
.../repl/executor/ItIgnitePicocliCommandsTest.java | 1 -
.../java/org/apache/ignite/internal/cli/Main.java | 1 -
.../cli/call/cliconfig/profile/ProfileList.java | 1 -
.../call/recovery/states/PartitionStatesCall.java | 8 +-
.../internal/cli/commands/CommandConstants.java | 1 -
.../ignite/internal/cli/commands/Options.java | 5 +-
.../cluster/init/ClusterInitReplCommand.java | 1 -
.../cluster/init/ConfigFileParseException.java | 1 -
.../cluster/unit/ClusterUnitDeployCommand.java | 1 -
.../cluster/unit/ClusterUnitDeployReplCommand.java | 1 -
.../cluster/unit/ClusterUnitListCommand.java | 1 -
.../cluster/unit/ClusterUnitListReplCommand.java | 1 -
.../cluster/unit/ClusterUnitUndeployCommand.java | 1 -
.../unit/ClusterUnitUndeployReplCommand.java | 1 -
.../commands/node/unit/NodeUnitListCommand.java | 1 -
.../node/unit/NodeUnitListReplCommand.java | 1 -
.../questions/ConnectToClusterQuestion.java | 1 -
.../cli/commands/treesitter/parser/Parser.java | 1 -
.../ignite/internal/cli/config/ini/IniParser.java | 1 -
.../internal/cli/core/call/DefaultCallOutput.java | 14 +-
.../cli/core/call/SingleCallExecutionPipeline.java | 1 -
.../cli/core/decorator/DecoratorRegistry.java | 2 +
.../cli/core/exception/ExceptionWriter.java | 1 -
.../core/exception/UnitAlreadyExistsException.java | 1 -
.../handler/EndOfFileExceptionHandler.java | 5 +-
.../completer/DynamicCompleterActivationPoint.java | 25 +-
.../repl/completer/DynamicCompletionInsider.java | 7 +-
.../completer/hocon/HoconDynamicCompleter.java | 1 -
.../repl/executor/RegistryCommandExecutor.java | 1 -
.../apache/ignite/internal/cli/sql/SqlSchema.java | 1 -
.../ignite/internal/cli/sql/SqlSchemaLoader.java | 1 -
.../cli/commands/cluster/ClusterInitTest.java | 1 -
.../partitions/restart/RestartPartitionsTest.java | 1 -
.../repl/completer/HoconDynamicCompleterTest.java | 1 -
.../repl/completer/StringDynamicCompleterTest.java | 1 -
.../filter/DeployUnitsOptionsFilterTest.java | 1 -
.../style/component/MessageUiComponentTest.java | 1 -
.../ignite/internal/cli/util/ArrayUtilsTest.java | 1 -
.../client/proto/ClientComputeJobUnpacker.java | 12 +
.../internal/client/proto/ClientMessagePacker.java | 13 +
.../client/proto/ClientMessageUnpacker.java | 13 +-
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../client/proto/StreamerReceiverSerializer.java | 1 -
.../internal/compute/SharedComputeUtils.java | 1 -
.../internal/jdbc/proto/JdbcQueryEventHandler.java | 4 +-
.../jdbc/proto/event/JdbcQuerySingleResult.java | 1 -
.../proto/ClientMessagePackerUnpackerTest.java | 1 -
.../client/proto/pojo/PojoConverterTest.java | 2 +
.../ignite/client/handler/ItClientHandlerTest.java | 2 +-
.../apache/ignite/client/handler/TestServer.java | 14 +-
.../ignite/client/handler/ClientContext.java | 14 +-
.../ignite/client/handler/ClientHandlerModule.java | 17 +-
.../handler/ClientInboundMessageHandler.java | 150 ++-
.../client/handler/JdbcConnectionContext.java | 10 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 18 +-
.../ClientComputeExecuteColocatedRequest.java | 21 +-
.../ClientComputeExecutePartitionedRequest.java | 24 +-
.../compute/ClientComputeExecuteRequest.java | 24 +-
.../requests/jdbc/ClientJdbcConnectRequest.java | 6 +-
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 5 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 6 +-
.../requests/sql/ClientSqlExecuteRequest.java | 9 +-
.../sql/ClientSqlExecuteScriptRequest.java | 9 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 4 +-
.../apache/ignite/internal/client/ClientUtils.java | 4 +-
.../ignite/internal/client/TcpClientChannel.java | 1 +
.../internal/client/compute/ClientCompute.java | 31 +-
.../client/compute/ClientJobExecution.java | 1 -
.../io/netty/NettyClientConnectionMultiplexer.java | 3 +
.../ignite/internal/client/sql/ClientSql.java | 1 -
.../ignite/internal/client/table/ClientTuple.java | 1 -
.../ignite/client/AbstractClientTableTest.java | 4 +-
.../apache/ignite/client/AbstractClientTest.java | 3 +
.../apache/ignite/client/ClientMetricsTest.java | 1 -
.../ignite/client/TestClientHandlerModule.java | 32 +-
.../ignite/client/fakes/FakeColumnMetadata.java | 10 +-
.../apache/ignite/client/fakes/FakeCompute.java | 8 +-
.../ignite/client/fakes/FakeIgniteTables.java | 1 -
.../cluster/management/ItClusterManagerTest.java | 199 +++-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../cluster/management/ClusterInitializer.java | 53 +-
.../management/ClusterManagementGroupManager.java | 129 ++-
.../management/raft/CmgRaftGroupListener.java | 12 +-
.../cluster/management/raft/CmgRaftService.java | 15 +
.../cluster/management/ClusterInitializerTest.java | 1 -
.../management/raft/CmgRaftGroupListenerTest.java | 3 +-
.../management/BaseItClusterManagementTest.java | 20 +-
.../internal/cluster/management/MockNode.java | 9 +-
.../internal/deployment/ItDeploymentUnitTest.java | 1 -
.../internal/deployunit/FileDeployerService.java | 1 -
.../exception/DeploymentUnitNotFoundException.java | 1 -
.../deployunit/message/DeployUnitMessageTypes.java | 1 -
.../metastore/DeploymentUnitStoreImpl.java | 1 -
modules/compatibility-tests/build.gradle | 12 +-
.../ignite/internal/ItCompatibilityTest.java | 4 +-
...ldClientWithCurrentServerCompatibilityTest.java | 2 +-
.../ignite/internal/CompatibilityTestBase.java | 38 +-
.../org/apache/ignite/internal/IgniteCluster.java | 24 +-
.../PlatformCompatibilityTestNodeRunner.java | 3 +-
modules/compute/build.gradle | 5 +
.../internal/compute/ItComputeTestClient.java | 22 +-
...> ItFailoverCandidateNotFoundEmbeddedTest.java} | 18 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 156 ++-
...ItFailoverCandidateNotFoundThinClientTest.java} | 30 +-
.../compute/ItThinClientComputeErrorsTest.java | 22 +-
...Test.java => ItWorkerShutdownEmbeddedTest.java} | 2 +-
.../internal/compute/ItWorkerShutdownTest.java | 22 +-
...st.java => ItWorkerShutdownThinClientTest.java} | 15 +-
.../internal/compute/events/EventMatcher.java | 279 +++++
.../internal/compute/events/EventMatcherTest.java | 109 ++
.../ItComputeEventsEmbeddedTest.java} | 17 +-
.../compute/events/ItComputeEventsTest.java | 383 ++++++
.../ItComputeEventsThinClientTest.java} | 35 +-
.../Clients.java} | 35 +-
.../compute/utils/MismatchesDescriptor.java | 57 +
.../compute/ClassLoaderExceptionsMapper.java | 1 -
.../ignite/internal/compute/ComputeComponent.java | 15 +-
.../internal/compute/ComputeComponentImpl.java | 41 +-
.../internal/compute/ComputeJobFailover.java | 85 +-
.../internal/compute/ComputeMessageTypes.java | 5 +
.../internal/compute/FailSafeJobExecution.java | 5 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 80 +-
.../internal/compute/IgniteComputeInternal.java | 7 +
.../apache/ignite/internal/compute/JobStarter.java | 3 +
.../internal/compute/RemoteExecutionContext.java | 11 +-
.../compute/events/ComputeEventMetadata.java | 141 +++
.../events/ComputeEventMetadataBuilder.java | 107 ++
.../compute/events/ComputeEventsFactory.java | 143 +++
.../internal/compute/executor/ComputeExecutor.java | 5 +-
.../compute/executor/ComputeExecutorImpl.java | 31 +-
...obStatesResponse.java => ExecuteRequestV2.java} | 24 +-
.../compute/messaging/ComputeMessaging.java | 18 +-
.../queue/BoundedPriorityBlockingQueue.java | 1 -
.../compute/queue/PriorityQueueExecutor.java | 50 +-
.../internal/compute/queue/QueueExecutionImpl.java | 31 +-
.../compute/state/ComputeStateMachine.java | 5 +-
.../compute/state/InMemoryComputeStateMachine.java | 14 +-
.../internal/compute/ComputeComponentImplTest.java | 17 +-
.../internal/compute/IgniteComputeImplTest.java | 17 +-
.../compute/executor/ComputeExecutorTest.java | 10 +-
.../compute/loader/JobContextManagerTest.java | 1 -
.../compute/queue/PriorityQueueExecutorTest.java | 5 +-
.../notifications/ConfigurationListener.java | 5 +
.../storage/LocalFileConfigurationStorage.java | 51 +-
.../storage/LocalFileConfigurationStorageTest.java | 101 +-
.../configuration/ConfigurationChanger.java | 37 +-
.../ConfigurationDynamicDefaultsPatcherImpl.java | 1 -
.../configuration/ConfigurationListenerHolder.java | 3 +
.../configuration/ConfigurationTreeGenerator.java | 1 -
.../configuration/asm/InnerNodeAsmGenerator.java | 1 -
.../storage/ConfigurationStorage.java | 4 +
.../configuration/util/ConfigurationUtil.java | 2 +-
.../asm/ConfigurationTreeGeneratorTest.java | 1 -
.../notifications/ConfigurationListenerTest.java | 12 +-
.../tree/ConstructableTreeNodeTest.java | 1 -
.../tree/ConverterToMapVisitorTest.java | 1 -
.../configuration/tree/InternalIdTest.java | 1 -
.../tree/TraversableTreeNodeTest.java | 14 +-
.../extension/ExtendedTraversableTreeNodeTest.java | 8 +-
.../PolymorphicTraversableTreeNodeTest.java | 12 +-
.../ignite/internal/hlc/ClockServiceImpl.java | 37 +-
.../internal/lang/IgniteExceptionMapper.java | 4 +-
.../ignite/internal/lang/IgniteStringBuilder.java | 1 -
.../internal/lang/IgniteStringFormatter.java | 5 +-
.../internal/lang/IgniteSystemProperties.java | 12 -
.../ignite/internal/sql/SyncResultSetAdapter.java | 2 +-
.../ignite/internal/thread/IgniteThread.java | 4 +-
.../internal/thread/IgniteThreadFactory.java | 17 +-
.../internal/tostring/IgniteToStringBuilder.java | 70 +-
.../ignite/internal/util/ExceptionUtils.java | 12 +-
.../apache/ignite/internal/util/GridUnsafe.java | 47 +-
.../org/apache/ignite/internal/util/HashUtils.java | 10 +-
.../apache/ignite/internal/util/IgniteUtils.java | 1 -
.../ignite/internal/util/PointerWrapping.java | 1 -
.../util/StripedVersatileReadWriteLock.java | 229 ++++
.../apache/ignite/internal/util/VarIntUtils.java | 9 +
.../internal/util/VersatileReadWriteLock.java | 4 +-
.../internal/util/io/IgniteUnsafeDataInput.java | 2 +-
.../util/subscription/AccumulatorSubscriber.java | 1 -
.../util/subscription/ConcatenatedPublisher.java | 1 -
.../internal/future/InFlightFuturesTest.java | 1 -
.../ignite/internal/future/OrderingFutureTest.java | 2 -
.../ignite/internal/hlc/ClockServiceTest.java | 116 ++
.../tostring/IgniteToStringBuilderSelfTest.java | 15 +-
.../tostring/SensitiveDataToStringTest.java | 28 +-
.../ignite/internal/util/CollectionUtilsTest.java | 2 +
.../util/IgniteConcurrentMultiPairQueueTest.java | 8 +-
.../util/PendingComparableValuesTrackerTest.java | 10 +-
...java => StripedVersatileReadWriteLockTest.java} | 141 +--
...k.java => VersatileReadWriteLockBenchmark.java} | 44 +-
.../internal/util/VersatileReadWriteLockTest.java | 48 +-
.../ignite/internal/util/io/IgniteTestIoUtils.java | 7 +-
.../testframework/BaseIgniteAbstractTest.java | 8 +-
.../internal/testframework/IgniteTestUtils.java | 16 +-
.../testframework/log4j2/EventLogInspector.java} | 40 +-
.../testframework/log4j2/LogInspector.java | 31 +-
.../testframework/matchers/TaskStateMatcher.java | 1 -
modules/distribution-zones/build.gradle | 2 +
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 23 +-
.../internal/rebalance/ItRebalanceMetricsTest.java | 200 ++++
.../distributionzones/DistributionZoneManager.java | 89 +-
.../distributionzones/ZoneMetricSource.java | 169 +++
.../distributionzones/rebalance/RebalanceUtil.java | 1 -
.../utils/CatalogAlterZoneEventListener.java | 15 +
.../BaseDistributionZoneManagerTest.java | 4 +-
.../rebalance/ZoneMetricSourceTest.java | 102 ++
.../utils/CatalogAlterZoneEventListenerTest.java | 1 -
.../DistributionZonesTestUtil.java | 1 -
.../error/code/annotations/ErrorCodeGroup.java | 7 +-
.../eventlog/impl/ItEventLogConfigurationTest.java | 12 +-
.../ignite/internal/eventlog/api/EventLog.java | 13 +
.../internal/eventlog/api/IgniteEventType.java | 8 +
.../internal/eventlog/impl/ChannelRegistry.java | 10 +
.../impl/ConfigurationBasedChannelRegistry.java | 56 +-
.../impl/ConfigurationBasedSinkRegistry.java | 53 +-
.../internal/eventlog/impl/EventLogImpl.java | 19 +-
.../internal/eventlog/impl/SinkRegistry.java | 10 +
.../eventlog/ser/JacksonBasedJsonSerializer.java | 11 +-
.../internal/eventlog/event/IgniteEventsTest.java | 1 -
.../ConfigurationBasedChannelRegistryTest.java | 7 +
.../impl/ConfigurationBasedSinkRegistryTest.java | 7 +
.../internal/eventlog/impl/EventLogTest.java | 16 +
.../FailureProcessorThreadDumpThrottlingTest.java | 8 +-
.../network/file/FileChunkMessagesStream.java | 1 -
.../ignite/internal/network/file/FileReceiver.java | 1 -
.../network/file/FileTransferServiceImpl.java | 1 -
.../internal/network/file/messages/FileHeader.java | 2 +-
.../internal/network/file/FileSenderTest.java | 1 -
.../network/file/FileTransferServiceImplTest.java | 1 -
.../ignite/jdbc/ItJdbcAuthenticationTest.java | 58 +
.../ignite/jdbc/ItJdbcConnectionSelfTest.java | 14 +
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 1 -
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 32 +-
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 1 -
.../internal/jdbc/JdbcClientQueryEventHandler.java | 5 +-
.../ignite/internal/jdbc/JdbcConnection.java | 14 +-
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 8 +-
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 2 +-
.../ignite/internal/marshaller/Marshaller.java | 1 -
.../internal/marshaller/FieldAccessorTest.java | 2 +-
.../metastorage/dsl/CompoundConditionType.java | 1 -
.../internal/metastorage/dsl/ConditionType.java | 1 -
.../impl/ItIdempotentCommandCacheTest.java | 3 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 70 +-
.../internal/metastorage/server/Statement.java | 1 -
.../metastorage/server/WatchProcessor.java | 11 +-
.../server/persistence/RocksDbKeyValueStorage.java | 4 +-
.../server/BasicOperationsKeyValueStorageTest.java | 3 +
.../metrics/exporters/ItOtlpMetricsTest.java | 4 +-
modules/metrics/build.gradle | 2 +
.../metrics/exporters/ItJvmMetricSourceTest.java | 1 -
...java => ItLogPushExporterEnabledByDefault.java} | 32 +-
.../exporters/ItMetricExportersLoadingTest.java | 2 -
.../internal/metrics/AbstractMetricSource.java | 2 +-
.../ignite/internal/metrics/HitRateMetric.java | 3 +
.../ignite/internal/metrics/MetricManagerImpl.java | 49 +-
.../LogPushExporterConfigurationSchema.java | 11 +-
.../metrics/exporters/log/LogPushExporter.java | 11 +-
.../metrics/sources/ClockServiceMetricSource.java | 74 ++
.../sources/ClockServiceMetricSourceTest.java | 85 ++
.../internal/network/MapChannelTypeRegistry.java | 2 +
.../network/TrackableNetworkMessageHandler.java | 11 +-
...ageMappingException.java => MessageFormat.java} | 23 +-
modules/network/build.gradle | 1 +
.../node/ItNodeStalenessAndRestartTest.java | 77 ++
.../internal/network/DefaultMessagingService.java | 24 +-
.../network/MapStripedExecutorByChannelTypeId.java | 2 +
.../internal/network/NaiveMessageFormat.java | 42 +
.../internal/network/NettyBootstrapFactory.java | 19 +-
.../stream/DirectByteBufferStreamImplV1.java | 9 +-
.../handshake/HandshakeEventLoopSwitcher.java | 205 ++++
.../network/netty/ChannelEventLoopsSource.java | 33 -
.../ignite/internal/network/netty/ChannelKey.java | 2 +-
.../internal/network/netty/ConnectionManager.java | 13 +-
.../internal/network/netty/InboundDecoder.java | 9 +-
.../internal/network/netty/OutboundEncoder.java | 11 +-
.../internal/network/netty/PipelineUtils.java | 8 +-
.../network/recovery/HandshakeManagerUtils.java | 57 -
.../network/recovery/InMemoryStaleIds.java | 3 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 12 +-
.../RecoveryInitiatorHandshakeManager.java | 11 +-
.../internal/network/recovery/VaultStaleIds.java | 107 --
.../scalecube/ScaleCubeClusterServiceFactory.java | 3 +-
.../network/serialization/BuiltInType.java | 4 +-
.../PerSessionSerializationService.java | 1 -
.../network/serialization/SerializationType.java | 2 +-
.../marshal/BuiltInNonContainerMarshallers.java | 1 -
.../serialization/marshal/LittleEndianBits.java | 2 +
.../serialization/marshal/ProtocolMarshalling.java | 1 -
.../internal/network/ssl/SslContextProvider.java | 3 +
.../network/DefaultMessagingServiceTest.java | 4 +-
.../network/SerializationMicroBenchmark.java | 7 +-
.../ignite/internal/network/UosProfilerTarget.java | 2 +-
.../handshake/NoOpHandshakeEventLoopSwitcher.java | 56 +
.../internal/network/netty/InboundDecoderTest.java | 16 +-
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../network/recovery/InMemoryStaleIdsTest.java} | 36 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 4 +-
.../network/recovery/VaultStaleIdsTest.java | 124 --
.../network/serialization/MarshallableTest.java | 7 +-
...shallerWithSerializableOverrideStreamsTest.java | 6 +-
...ltUserObjectMarshallerWithSerializableTest.java | 2 +
.../internal/network/messages/NetworkMessage1.java | 1 -
.../internal/network/messages/NetworkMessage2.java | 1 -
.../ItBplusTreePersistentPageMemoryTest.java | 3 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 3 +-
.../ignite/internal/pagememory/FullPageId.java | 8 +-
.../internal/pagememory/freelist/FreeListImpl.java | 1 -
.../ignite/internal/pagememory/io/DataPageIo.java | 2 +-
.../pagememory/persistence/DirtyFullPageId.java | 90 ++
.../pagememory/persistence/PageHeader.java | 172 ++-
.../internal/pagememory/persistence/PagePool.java | 4 +-
.../pagememory/persistence/PageStoreWriter.java | 5 +-
.../pagememory/persistence/PartitionMeta.java | 14 +-
.../persistence/PartitionMetaFactory.java | 3 +-
.../persistence/PartitionMetaManager.java | 13 +-
.../persistence/PersistentPageMemory.java | 432 +++----
.../persistence/WriteSpeedFormatter.java | 61 +-
.../checkpoint/CheckpointDirtyPages.java | 42 +-
.../persistence/checkpoint/CheckpointManager.java | 52 +-
.../checkpoint/CheckpointPageReplacement.java | 16 +-
.../persistence/checkpoint/CheckpointPages.java | 38 +-
.../checkpoint/CheckpointPagesWriter.java | 102 +-
.../checkpoint/CheckpointProgressImpl.java | 18 +-
.../checkpoint/CheckpointReadWriteLock.java | 2 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 35 +-
.../persistence/checkpoint/Checkpointer.java | 61 +-
.../checkpoint/DataRegionsDirtyPages.java | 6 +-
.../checkpoint/DirtyPagesAndPartitions.java | 6 +-
.../checkpoint/IgniteCheckpointThread.java} | 33 +-
.../checkpoint/IgniteCheckpointThreadFactory.java | 61 +
.../persistence/compaction/Compactor.java | 7 +-
.../replacement/ClockPageReplacementPolicy.java | 5 +-
.../replacement/DelayedDirtyPageWrite.java | 8 +-
.../replacement/DelayedPageReplacementTracker.java | 20 +-
.../RandomLruPageReplacementPolicy.java | 17 +-
.../SegmentedLruPageReplacementPolicy.java | 5 +-
.../persistence/store/FilePageStore.java | 22 +-
.../internal/pagememory/freelist/TestDataRow.java | 1 -
.../pagememory/persistence/PageHeaderTest.java | 134 +++
.../persistence/WriteSpeedFormatterTest.java | 82 ++
.../checkpoint/CheckpointDirtyPagesTest.java | 20 +-
.../checkpoint/CheckpointManagerTest.java | 77 +-
.../checkpoint/CheckpointPageReplacementTest.java | 46 +-
.../checkpoint/CheckpointPagesTest.java | 52 +-
.../checkpoint/CheckpointPagesWriterTest.java | 59 +-
.../checkpoint/CheckpointReadWriteLockTest.java | 31 +-
.../persistence/checkpoint/CheckpointTest.java | 4 +-
.../checkpoint/CheckpointWorkflowTest.java | 38 +-
.../persistence/checkpoint/CheckpointerTest.java | 30 +-
.../checkpoint/TestCheckpointUtils.java | 10 +-
.../replacement/AbstractPageReplacementTest.java | 38 +-
.../RandomLruPageReplacementPolicySelfTest.java | 7 +-
.../persistence/store/FilePageStoreTest.java | 4 +-
.../throttling/PageMemoryThrottlingTest.java | 18 +-
.../throttling/ProgressSpeedCalculationTest.java | 1 -
.../pagememory/persistence/FakePartitionMeta.java | 20 +-
.../checkpoint/CheckpointTestUtils.java | 4 +-
.../AssignmentsChainSerializer.java | 1 -
.../RendezvousDistributionFunction.java | 9 +-
.../replicator/ItAbstractColocationTest.java | 4 +-
.../replicator/ItReplicaLifecycleTest.java | 2 +
.../partition/replicator/fixtures/Node.java | 22 +-
.../PartitionReplicaLifecycleManager.java | 54 +
.../handlers/TxFinishReplicaRequestHandler.java | 1 -
.../PartitionCommandsMarshallerImpl.java | 2 +-
.../network/disaster/LocalPartitionStateEnum.java | 1 -
.../network/replication/RequestType.java | 3 -
.../handlers/WriteIntentSwitchCommandHandler.java | 27 +-
.../raft/snapshot/PartitionDataStorage.java | 2 +
.../raft/snapshot/PartitionMvStorageAccess.java | 1 +
.../network/replication/RequestTypeTest.java | 1 -
.../raft/ZonePartitionRaftListenerTest.java | 2 -
.../SnapshotAwarePartitionDataStorageTest.java | 8 +-
.../MultiActorPlacementDriverTest.java | 1 -
.../placementdriver/PlacementDriverManager.java | 5 +-
.../placementdriver/LeaseNegotiationTest.java | 3 +-
.../client/detail/transaction/transactions_impl.h | 10 +-
.../client/transaction/transaction_options.h | 63 +
.../cpp/ignite/client/transaction/transactions.cpp | 6 +-
.../cpp/ignite/client/transaction/transactions.h | 21 +-
.../cpp/tests/client-test/compute_test.cpp | 21 +-
.../cpp/tests/client-test/transactions_test.cpp | 52 +
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 1 +
.../ignite/raft/server/ItConnectionErrorTest.java | 3 +-
.../server/snasphot/UpdateCountRaftListener.java | 1 -
.../ignite/internal/raft/RaftGroupServiceImpl.java | 4 +-
.../server/impl/RaftServiceEventInterceptor.java | 2 +-
.../storage/impl/StorageDestructionIntent.java | 1 -
.../apache/ignite/raft/jraft/RaftGroupService.java | 6 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 13 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 250 +++-
.../ignite/raft/jraft/core/NotLeaderException.java | 11 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 65 +-
.../raft/jraft/core/ReplicatorGroupImpl.java | 19 +-
.../ignite/raft/jraft/rpc/RaftClientService.java | 12 +
.../ignite/raft/jraft/rpc/RaftServerService.java | 10 +
.../ignite/raft/jraft/rpc/RpcRequestProcessor.java | 24 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 2 +-
.../rpc/impl/cli/GetLeaderRequestProcessor.java | 68 +-
.../rpc/impl/core/DefaultRaftClientService.java | 12 +-
.../jraft/storage/impl/LocalRaftMetaStorage.java | 12 +-
.../storage/logit/storage/LogitLogStorage.java | 1 -
.../storage/snapshot/SnapshotExecutorImpl.java | 59 +-
.../ignite/disruptor/StripedDisruptorTest.java | 2 +
.../internal/raft/storage/TermCacheTest.java | 1 -
.../ItPlacementDriverReplicaSideTest.java | 9 +-
.../ignite/internal/replicator/ReplicaManager.java | 61 +-
.../ignite/internal/replicator/ReplicaService.java | 23 +-
.../internal/replicator/ReplicaStateManager.java | 1 +
...tion.java => AwaitReplicaTimeoutException.java} | 20 +-
.../replicator/exception/ReplicationException.java | 2 +-
.../exception/ReplicationTimeoutException.java | 2 +-
.../internal/replicator/ReplicaManagerTest.java | 16 +-
.../rest/api/deployment/UnitVersionStatus.java | 1 -
.../internal/rest/matcher/RestJobStateMatcher.java | 2 -
.../ignite/internal/rest/ItRestPortsTest.java | 1 -
.../rest/metrics/ItMetricControllerTest.java | 4 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 1 -
.../ignite/internal/rest/RestComponentTest.java | 13 +-
...onfigurationValidationExceptionHandlerTest.java | 1 -
.../rocksdb/snapshot/RocksSnapshotManager.java | 7 +-
modules/runner/build.gradle | 18 +
.../benchmark/AbstractMultiNodeBenchmark.java | 4 +
...sertBenchmark.java => BulkDeleteBenchmark.java} | 257 ++---
.../internal/benchmark/BulkLoadBenchmark.java | 28 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 1 -
.../ignite/internal/benchmark/SelectBenchmark.java | 6 +-
.../benchmark/SqlMultiStatementBenchmark.java | 6 +-
.../configuration/ItClusterConfigurationTest.java | 26 +
.../ItNodeBootstrapConfigurationTest.java | 62 +
.../runner/app/ItIgniteNodeRestartTest.java | 64 +-
.../app/client/ItThinClientAuthenticationTest.java | 58 +
.../client/ItThinClientComputeMarshallingTest.java | 1 -
.../runner/app/client/ItThinClientComputeTest.java | 25 +-
.../runner/app/client/ItThinClientSqlTest.java | 83 +-
.../storageprofile/ItStorageProfilesTest.java | 102 --
.../ignite/internal/table/ItInternalTableTest.java | 1 -
.../partition/ItAbstractPartitionManagerTest.java | 1 -
.../org/apache/ignite/internal/app/IgniteImpl.java | 46 +-
.../internal/app/SystemPropertiesComponent.java | 64 +
.../ignite/internal/configuration/IgnitePaths.java | 1 -
.../internal/restart/IgniteAttachmentLock.java | 6 +-
.../internal/restart/RestartProofKeyValueView.java | 9 +-
.../threading/PublicApiThreadingIgniteCatalog.java | 1 -
.../GenerateConfigurationSnapshot.java | 9 +-
.../framework/ConfigAnnotationValue.java | 1 -
.../framework/ConfigurationTreeComparator.java | 1 -
.../ConfigurationTreeComparatorSelfTest.java | 1 -
.../java/org/apache/ignite/internal/Cluster.java | 31 +-
.../ignite/internal/ClusterConfiguration.java | 1 -
.../internal/ClusterPerClassIntegrationTest.java | 1 -
.../testframework/TestIgnitionManager.java | 5 +-
.../ignite/internal/schema/BinaryRowConverter.java | 21 +-
.../ignite/internal/util/ColocationUtils.java | 33 +
.../ignite/internal/schema/SchemaManagerTest.java | 1 -
.../internal/schema/marshaller/MapperTest.java | 1 -
.../RecordMarshallerValidationsTest.java | 2 +
.../schema/BinaryTupleComparatorBaseTest.java | 6 +-
.../AuthenticationProviderConfigurationSchema.java | 1 -
.../authentication/AuthenticationManagerImpl.java | 1 -
.../AuthenticationManagerImplTest.java | 14 +-
.../ignite/IgniteClientAutoConfiguration.java | 1 -
.../ignite/IgniteClientAutoConfigurationTest.java | 1 -
.../org/apache/ignite/data/SpringDataJdbcTest.java | 1 -
.../org/apache/ignite/data/repository/Person.java | 7 +-
modules/sql-engine/build.gradle | 1 +
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 4 +-
.../internal/sql/api/ItSqlCreateZoneTest.java | 55 +
.../sql/engine/BaseSqlMultiStatementTest.java | 39 +-
.../sql/engine/ItAlterTableAlterColumnTest.java | 1 -
.../internal/sql/engine/ItAlterTableDdlTest.java | 1 -
.../internal/sql/engine/ItDataTypesTest.java | 5 -
.../ignite/internal/sql/engine/ItDmlTest.java | 5 +-
.../sql/engine/ItDynamicParameterTest.java | 52 +-
.../internal/sql/engine/ItFunctionsTest.java | 10 +
.../ignite/internal/sql/engine/ItIntervalTest.java | 203 ++--
.../ignite/internal/sql/engine/ItJoinTest.java | 23 +-
.../internal/sql/engine/ItMixedQueriesTest.java | 10 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 13 +-
.../sql/engine/ItSqlMultiStatementTest.java | 26 +
.../internal/sql/engine/ItSqlOperatorsTest.java | 35 +-
...tTest.java => ItSqlUsesKeyValueDeleteTest.java} | 76 +-
...tTest.java => ItSqlUsesKeyValueInsertTest.java} | 2 +-
.../internal/sql/engine/ItTemporalIndexTest.java | 36 +-
.../engine/datatypes/ItDateTimeCastFormatTest.java | 179 ++-
.../engine/datatypes/ItDivisionDecimalTest.java | 2 -
.../engine/datatypes/tests/TestTypeArguments.java | 3 -
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 1 -
.../datatypes/varbinary/ItVarBinaryJoinTest.java | 1 -
.../datatypes/varbinary/ItVarBinaryQueryTest.java | 1 -
.../datatypes/varbinary/ItVarBinarySetOpTest.java | 1 -
.../engine/systemviews/ItLocksSystemViewTest.java | 1 -
.../apache/ignite/internal/sql/sqllogic/For.java | 1 -
.../internal/sql/sqllogic/ItSqlLogicTest.java | 3 -
.../apache/ignite/internal/sql/sqllogic/Loop.java | 1 -
.../apache/ignite/internal/sql/sqllogic/Query.java | 2 +
.../ignite/internal/sql/sqllogic/Script.java | 2 +-
.../internal/sql/sqllogic/ScriptException.java | 1 -
.../sql/group1/cast/test_cast_bigint.test | 2 +-
.../sql/group1/cast/test_cast_decimal.test | 6 +-
.../sql/group1/cast/test_cast_float.test | 2 +-
.../sql/group1/cast/test_cast_format.test | 62 +-
.../sql/group1/cast/test_cast_int.test | 2 +-
.../sql/group1/cast/test_cast_interval_day.test | 2 +-
.../sql/group1/cast/test_cast_interval_year.test | 2 +-
.../sql/group1/cast/test_cast_smallint.test | 2 +-
.../sql/group1/cast/test_cast_tinyint.test | 2 +-
.../sql/group1/explain/mapping.test | 42 +-
.../integrationTest/sql/group1/explain/modify.test | 27 -
.../sql/group1/explain/specialized_operators.test | 26 +-
.../group1/function/date/test_extract_month.test | 750 +-----------
.../group1/function/date/test_extract_year.test | 644 +----------
.../generic/test_in_list_of_single_element.test | 2 +-
.../group1/types/date/test_incorrect_dates.test | 8 +-
.../group1/types/interval/interval_constants.test | 54 +-
.../types/timestamp/test_incorrect_timestamp.test | 18 +-
.../timestamp/test_incorrect_timestamp_ltz.test | 18 +-
.../ignite/internal/sql/api/IgniteSqlImpl.java | 12 +-
.../internal/sql/engine/SqlOperationContext.java | 19 +-
.../ignite/internal/sql/engine/SqlProperties.java | 23 +
.../internal/sql/engine/exec/ExecutionContext.java | 10 +-
.../engine/exec/ExecutionDependencyResolver.java | 1 -
.../sql/engine/exec/ExecutionServiceImpl.java | 28 +-
.../internal/sql/engine/exec/UpdatableTable.java | 17 +
.../sql/engine/exec/UpdatableTableImpl.java | 11 +
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 4 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 63 +-
.../sql/engine/exec/exp/RexExecutorImpl.java | 13 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 55 +-
.../engine/exec/exp/SearchBoundsImplementor.java | 2 -
.../sql/engine/exec/exp/agg/Accumulators.java | 2 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../sql/engine/exec/fsm/MultiStatementHandler.java | 3 +
.../engine/exec/fsm/OptimizingPhaseHandler.java | 2 +
.../sql/engine/exec/fsm/ValidationHelper.java | 18 +-
.../sql/engine/exec/mapping/ColocationGroup.java | 22 +
.../sql/engine/exec/mapping/FragmentPrinter.java | 51 +-
.../sql/engine/exec/mapping/MappedFragment.java | 22 +-
.../engine/exec/mapping/MappingServiceImpl.java | 17 +-
.../sql/engine/exec/mapping/QuerySplitter.java | 16 +-
.../exec/mapping/smallcluster/AbstractTarget.java | 1 -
.../sql/engine/exec/rel/AbstractSetOpNode.java | 2 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 4 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 11 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 5 +-
.../sql/engine/externalize/RelJsonReader.java | 2 +-
.../sql/engine/message/QueryStartRequest.java | 5 +
.../internal/sql/engine/prepare/DdlPlan.java | 13 +
.../internal/sql/engine/prepare/ExplainPlan.java | 13 +
.../sql/engine/prepare/IgniteAliasNamespace.java | 4 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 42 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 17 +-
.../prepare/IgniteSqlValidatorErrorMessages.java | 1 -
.../sql/engine/prepare/KeyValueGetPlan.java | 19 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 66 +-
.../internal/sql/engine/prepare/KillPlan.java | 13 +
.../internal/sql/engine/prepare/MultiStepPlan.java | 29 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 2 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 8 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 114 +-
.../internal/sql/engine/prepare/QueryPlan.java | 11 +
.../sql/engine/prepare/RelWithSources.java | 67 ++
.../sql/engine/prepare/SelectCountPlan.java | 11 +
.../ddl/ClusterWideStorageProfileValidator.java | 44 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 97 +-
.../prepare/ddl/StorageProfileValidator.java | 3 +-
.../PartitionAwarenessMetadata.java | 3 +-
.../PartitionAwarenessMetadataExtractor.java | 187 ++-
.../engine/prepare/pruning/PartitionPruner.java | 3 +-
.../prepare/pruning/PartitionPrunerImpl.java | 28 +-
.../prepare/pruning/PartitionPruningMetadata.java | 25 +
.../pruning/PartitionPruningMetadataExtractor.java | 1 -
.../prepare/pruning/PartitionPruningPredicate.java | 6 +-
.../sql/engine/rel/IgniteKeyValueModify.java | 23 +-
.../internal/sql/engine/rel/IgniteMergeJoin.java | 1 -
.../internal/sql/engine/rel/IgniteTableModify.java | 2 +-
.../sql/engine/rel/agg/MapReduceAggregates.java | 1 -
.../engine/rel/explain/RelTreeToTextWriter.java | 11 +-
.../rel/logical/IgniteLogicalSystemViewScan.java | 1 -
.../internal/sql/engine/rex/IgniteRexBuilder.java | 34 +
.../engine/rule/CorrelatedNestedLoopJoinRule.java | 2 +-
.../sql/engine/rule/HashJoinConverterRule.java | 6 +-
.../sql/engine/rule/LogicalScanConverterRule.java | 1 -
.../rule/TableModifyToKeyValueDeleteRule.java | 128 ++
...e.java => TableModifyToKeyValueInsertRule.java} | 39 +-
.../engine/rule/TableScanToKeyValueGetRule.java | 50 +-
.../IgniteProjectCorrelateTransposeRule.java | 1 -
.../engine/rule/logical/ProjectScanMergeRule.java | 1 -
.../engine/schema/AbstractIgniteDataSource.java | 1 -
.../sql/engine/schema/IgniteDataSource.java | 1 -
.../sql/engine/schema/SqlSchemaManagerImpl.java | 1 -
.../sql/engine/sql/IgniteAbstractSqlAlterZone.java | 4 +-
.../sql/engine/sql/IgniteSqlCreateIndex.java | 1 -
.../internal/sql/engine/sql/IgniteSqlExplain.java | 1 -
.../internal/sql/engine/sql/IgniteSqlParser.java | 1 -
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 3 +
.../engine/statistic/SqlStatisticManagerImpl.java | 4 +-
.../sql/engine/type/IgniteTypeFactory.java | 1 -
.../ignite/internal/sql/engine/util/Cloner.java | 87 +-
.../ignite/internal/sql/engine/util/Commons.java | 8 +-
.../sql/engine/util/ExtendedProjectedTuple.java | 1 -
.../internal/sql/engine/util/IgniteMath.java | 2 +-
.../internal/sql/engine/util/IgniteMethod.java | 21 +
.../ignite/internal/sql/engine/util/RexUtils.java | 38 +-
.../internal/sql/engine/util/format/Formatter.java | 208 ++++
...teTimeParser.java => SqlDateTimeFormatter.java} | 52 +-
.../ignite/internal/sql/docs/OperatorListTest.java | 4 +-
.../sql/engine/exec/DummyUpdatableTable.java | 5 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 29 +-
.../sql/engine/exec/QueryRecoveryTest.java | 1 -
.../internal/sql/engine/exec/QueryTimeoutTest.java | 1 -
.../sql/engine/exec/RuntimeSortedIndexTest.java | 21 +-
.../exec/coercion/BaseTypeCheckExecutionTest.java | 2 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 19 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 60 +-
.../exec/mapping/MappingServiceImplTest.java | 2 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 28 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 5 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 2 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 3 +-
.../sql/engine/exec/rel/HashJoinExecutionTest.java | 27 +
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 1 -
.../sql/engine/exec/rel/SingleRangeIterable.java | 2 +-
.../sql/engine/framework/DataProvider.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 27 +-
.../sql/engine/framework/TestClusterTest.java | 19 +-
.../internal/sql/engine/framework/TestNode.java | 34 +-
.../planner/AbstractAggregatePlannerTest.java | 3 +-
.../sql/engine/planner/AbstractPlannerTest.java | 22 +-
.../planner/AbstractTpcQueryPlannerTest.java | 41 +-
.../sql/engine/planner/AggregatePlannerTest.java | 2 -
.../sql/engine/planner/CastResolutionTest.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 94 +-
.../sql/engine/planner/DynamicParametersTest.java | 2 -
.../sql/engine/planner/HashJoinPlannerTest.java | 4 +-
.../sql/engine/planner/ImplicitCastsTest.java | 1 -
.../engine/planner/KeyValueModifyPlannerTest.java | 15 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 1 -
.../planner/PartitionPruningMetadataTest.java | 5 +-
.../sql/engine/planner/PartitionPruningTest.java | 22 +
.../internal/sql/engine/planner/PlannerTest.java | 2 -
.../planner/PrimaryKeyDeletePlannerTest.java | 231 ++++
.../sql/engine/planner/SetOpPlannerTest.java | 2 -
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 7 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 2 -
.../DateTimeComparisonTypeCoercionTest.java | 2 -
.../DateTimeFunctionsTypeCoercionTest.java | 1 -
.../DateTimeInsertSourcesTypeCoercionTest.java | 2 -
.../DateTimeMergeSourcesCoercionTest.java | 2 -
.../datatypes/DateTimeQualifyCoercionTest.java | 2 -
.../datatypes/DateTimeSetOperatorCoercionTest.java | 2 -
.../DateTimeUpdateSourcesCoercionTest.java | 3 -
.../NumericBinaryOperationsTypeCoercionTest.java | 13 -
.../datatypes/NumericCaseTypeCoercionTest.java | 41 -
.../NumericComparisonTypeCoercionTest.java | 13 -
.../datatypes/NumericMergeSourcesCoercionTest.java | 1 -
.../NumericQuantifyOperatorTypeCoercionTest.java | 13 -
.../datatypes/NumericSetOperatorCoercionTest.java | 1 -
.../NumericUpdateSourcesCoercionTest.java | 1 -
.../datatypes/utils/CharacterStringPair.java | 1 -
.../datatypes/utils/DifferentFamiliesPair.java | 1 -
.../datatypes/utils/DifferentFamiliesPairTest.java | 1 -
.../planner/datatypes/utils/NumericPair.java | 1 -
.../sql/engine/prepare/PrepareServiceImplTest.java | 7 +-
.../ddl/AbstractDdlSqlToCommandConverterTest.java | 22 +
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 61 +-
.../DistributionZoneSqlToCommandConverterTest.java | 13 +-
.../PartitionAwarenessMetadataTest.java | 289 ++++-
.../pruning/PartitionPruningPredicateSelfTest.java | 15 +-
.../pruning/PruningMetadataSerializationTest.java | 2 -
.../engine/schema/SqlSchemaManagerImplTest.java | 1 -
.../internal/sql/engine/sql/SqlDdlParserTest.java | 3 +-
.../sql/engine/type/IgniteTypeSystemTest.java | 1 -
.../internal/sql/engine/util/StatementChecker.java | 2 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 1 -
.../sql/engine/util/format/FormatterSelfTest.java | 213 ++++
.../util/format/FormatterSimpleFieldsTest.java | 409 +++++++
...Test.java => SqlDateTimeFormatterSelfTest.java} | 82 +-
.../src/test/resources/docs/operator_list.txt | 3 +
.../src/test/resources/mapping/correlated.test | 191 +--
.../sql-engine/src/test/resources/mapping/dml.test | 57 +-
.../src/test/resources/mapping/hash_join.test | 73 +-
.../src/test/resources/mapping/merge_join.test | 23 +-
.../src/test/resources/mapping/set_ops.test | 35 +-
.../src/test/resources/mapping/table_affinity.test | 52 +-
.../test/resources/mapping/table_functions.test | 3 +-
.../src/test/resources/mapping/table_identity.test | 84 +-
.../resources/mapping/table_identity_single.test | 60 +-
.../src/test/resources/mapping/table_single.test | 36 +-
.../resources/mapping/test_backup_mapping.test | 160 ++-
.../resources/mapping/test_partition_pruning.test | 218 +++-
.../src/test/resources/mapping/union.test | 74 +-
.../src/test/resources/mapping/values.test | 6 +-
.../src/test/resources/tpcds/plan/q14.plan | 1219 ++++++++++++++++++++
.../test/resources/tpcds/plan/q14_colocated.plan | 1219 ++++++++++++++++++++
.../src/test/resources/tpcds/plan/q23.plan | 625 ++++++++++
.../test/resources/tpcds/plan/q23_colocated.plan | 625 ++++++++++
.../src/test/resources/tpcds/plan/q24.plan | 311 +++++
.../test/resources/tpcds/plan/q24_colocated.plan | 311 +++++
.../internal/sql/engine/util/QueryChecker.java | 24 +-
.../internal/sql/engine/util/QueryCheckerImpl.java | 4 +-
.../src/testFixtures/resources/tpcds/query12.sql | 2 +-
.../src/testFixtures/resources/tpcds/query16.sql | 2 +-
.../src/testFixtures/resources/tpcds/query20.sql | 2 +-
.../src/testFixtures/resources/tpcds/query21.sql | 4 +-
.../src/testFixtures/resources/tpcds/query32.sql | 4 +-
.../src/testFixtures/resources/tpcds/query37.sql | 2 +-
.../src/testFixtures/resources/tpcds/query40.sql | 4 +-
.../src/testFixtures/resources/tpcds/query5.sql | 6 +-
.../src/testFixtures/resources/tpcds/query72.sql | 2 +-
.../src/testFixtures/resources/tpcds/query77.sql | 12 +-
.../src/testFixtures/resources/tpcds/query80.sql | 6 +-
.../src/testFixtures/resources/tpcds/query82.sql | 2 +-
.../src/testFixtures/resources/tpcds/query92.sql | 4 +-
.../src/testFixtures/resources/tpcds/query94.sql | 2 +-
.../src/testFixtures/resources/tpcds/query95.sql | 2 +-
.../src/testFixtures/resources/tpcds/query98.sql | 2 +-
.../internal/storage/MvPartitionStorage.java | 2 +
.../storage/AbstractMvTableStorageTest.java | 1 -
.../AbstractPageMemoryStorageEngine.java | 1 -
.../pagememory/PersistentPageMemoryDataRegion.java | 37 +-
.../PersistentPageMemoryStorageEngine.java | 32 +-
.../PersistentPageMemoryTableStorage.java | 6 +-
.../storage/pagememory/StoragePartitionMeta.java | 5 +-
.../pagememory/StoragePartitionMetaFactory.java | 8 +-
.../storage/pagememory/StoragePartitionMetaIo.java | 1 -
.../pagememory/VolatilePageMemoryDataRegion.java | 40 +-
.../VolatilePageMemoryStorageEngine.java | 44 -
.../sorted/comparator/JitComparatorGenerator.java | 151 ++-
.../sorted/comparator/JitComparatorOptions.java | 133 +++
.../mv/PersistentPageMemoryMvPartitionStorage.java | 7 +-
.../storage/pagememory/mv/io/BlobFragmentIo.java | 2 +-
.../PersistentPageMemoryMvTableStorageTest.java | 32 +-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 122 +-
.../StoragePartitionMetaManagerTest.java | 4 +-
.../pagememory/StoragePartitionMetaTest.java | 2 +-
.../PersistentPageMemoryStorageEngineTest.java | 7 -
.../VolatilePageMemoryStorageEngineTest.java | 23 -
.../index/sorted/comparator/JitComparatorTest.java | 21 +-
.../pagememory/mv/FailedCheckpointTest.java | 329 ++++++
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 2 +
.../storage/rocksdb/RocksDbStorageEngine.java | 29 +-
.../storage/rocksdb/RocksDbStorageProfile.java | 35 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 2 +
.../rocksdb/index/RocksDbSortedIndexStorage.java | 2 +
.../rocksdb/engine/RocksDbStorageEngineTest.java | 7 -
.../instance/SharedRocksDbInstanceTest.java | 4 +-
.../disaster/system/ItCmgDisasterRecoveryTest.java | 2 +
.../ItAbstractInternalTableScanTest.java | 5 +-
.../ItInternalTableReadOnlyOperationsTest.java | 1 -
.../ignite/distributed/ReplicaUnavailableTest.java | 7 +-
.../partition/ItPartitionDestructionTest.java | 2 -
.../schema/marshaller/TupleMarshallerImpl.java | 16 +-
.../PartitionReplicatorNodeRecovery.java | 2 +-
.../internal/table/distributed/PartitionSet.java | 2 +-
.../internal/table/distributed/TableManager.java | 79 +-
.../disaster/DisasterRecoveryManager.java | 41 +-
.../disaster/ManualGroupRestartRequest.java | 262 +++--
.../marshaller/TupleMarshallerStatisticsTest.java | 2 +-
.../table/distributed/StorageCleanupTest.java | 2 -
.../internal/table/distributed/gc/MvGcTest.java | 2 +-
.../raft/PartitionCommandListenerTest.java | 6 +-
.../ZonePartitionReplicaListenerTest.java | 2 -
.../storage/InternalTableEstimatedSizeTest.java | 9 +-
.../table/type/NumericTypesSerializerTest.java | 2 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../disaster/DisasterRecoveryTestUtil.java | 149 +++
.../disaster/ItDisasterRecoveryManagerTest.java | 644 ++++++++++-
.../ItDisasterRecoveryReconfigurationTest.java | 129 +--
.../tx/distributed/ItTxResourcesVacuumTest.java | 1 -
.../ignite/internal/tx/PartitionEnlistment.java | 1 -
.../apache/ignite/internal/tx/TransactionIds.java | 2 +-
.../internal/tx/TransactionInternalException.java | 1 -
.../org/apache/ignite/internal/tx/TxState.java | 1 -
.../tx/impl/PersistentTxStateVacuumizer.java | 16 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 1 -
.../tx/impl/WaitDieDeadlockPreventionPolicy.java | 1 -
.../rocksdb/TxStateRocksDbPartitionStorage.java | 2 +
.../internal/tx/AbstractLockManagerTest.java | 2 -
.../internal/tx/CoarseGrainedLockManagerTest.java | 1 -
.../org/apache/ignite/internal/tx/TxStateTest.java | 2 -
.../worker/ItCriticalWorkerMonitoringTest.java | 3 +-
.../internal/worker/CriticalWorkerWatchdog.java | 24 +-
.../CriticalWorkersConfigurationSchema.java | 6 +-
887 files changed, 20337 insertions(+), 9072 deletions(-)
delete mode 100644 docs/_docs/limitations.adoc
create mode 100644
examples/src/main/java/org/apache/ignite/example/code/deployment/CodeDeploymentExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/code/deployment/MyJob.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/code/deployment/resources/script.sh
copy
modules/catalog-dsl/src/main/java/org/apache/ignite/internal/catalog/sql/Zone.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/AutoSerializableArg.java
(74%)
copy dev-utilities/build.gradle =>
examples/src/main/java/org/apache/ignite/example/serialization/AutoSerializableResult.java
(84%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationExample.java
copy
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/FailingJobOnFirstExecution.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/CustomPojoSerializationJob.java
(50%)
copy
modules/compute/src/unit1/java/org/apache/ignite/internal/compute/UnitJob.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/IntegerDecrementJob.java
(79%)
copy
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/flow/IntCallInput.java
=> examples/src/main/java/org/apache/ignite/example/serialization/JsonArg.java
(75%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/internal/ReflectionLongFieldUpdater.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/JsonArgMarshaller.java
(58%)
copy dev-utilities/build.gradle =>
examples/src/main/java/org/apache/ignite/example/serialization/JsonResult.java
(85%)
copy
modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/internal/ReflectionLongFieldUpdater.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/JsonResultMarshaller.java
(58%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/serialization/NativeTypeSerializationExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationExample.java
copy
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/FailingJobOnFirstExecution.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/PojoAutoSerializationJob.java
(63%)
copy
examples/src/main/java/org/apache/ignite/example/{storage/PersistentPageMemoryStorageExample.java
=> serialization/SerializationExample.java} (60%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/serialization/TupleSerializationExample.java
copy
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/TupleJob.java
=>
examples/src/main/java/org/apache/ignite/example/serialization/TupleTransformJob.java
(76%)
rename
examples/src/main/java/org/apache/ignite/example/streaming/{pojo/AccountValue.java
=> Account.java} (52%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/DistributedComputeWithReceiverExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/MultiTableDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewDataStreamerExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/RecordViewPojoDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/TwoTableReceiver.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Account.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/AccountKey.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/pojo/Trade.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithResultSubscriberExample.java
delete mode 100644
examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithTableUpdateExample.java
create mode 100644
migration-tools/modules/migration-tools-persistence/src/main/java/org/apache/ignite/migrationtools/persistence/exceptions/MigrateCacheException.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedComputeErrorsTest.java
=> ItFailoverCandidateNotFoundEmbeddedTest.java} (54%)
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItThinClientComputeErrorsTest.java
=> ItFailoverCandidateNotFoundThinClientTest.java} (53%)
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedWorkerShutdownTest.java
=> ItWorkerShutdownEmbeddedTest.java} (94%)
rename
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedWorkerShutdownTest.java
=> ItWorkerShutdownThinClientTest.java} (71%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/EventMatcher.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/EventMatcherTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedComputeErrorsTest.java
=> events/ItComputeEventsEmbeddedTest.java} (56%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/ItComputeEventsTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItThinClientComputeErrorsTest.java
=> events/ItComputeEventsThinClientTest.java} (50%)
rename
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItThinClientWorkerShutdownTest.java
=> utils/Clients.java} (65%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/utils/MismatchesDescriptor.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventMetadata.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventMetadataBuilder.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventsFactory.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatesResponse.java
=> ExecuteRequestV2.java} (63%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/StripedVersatileReadWriteLock.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/hlc/ClockServiceTest.java
copy
modules/core/src/test/java/org/apache/ignite/internal/util/{VersatileReadWriteLockTest.java
=> StripedVersatileReadWriteLockTest.java} (83%)
copy
modules/core/src/test/java/org/apache/ignite/internal/util/{WrapPointerBenchmark.java
=> VersatileReadWriteLockBenchmark.java} (56%)
copy
modules/{eventlog/src/testFixtures/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSink.java
=>
core/src/testFixtures/java/org/apache/ignite/internal/testframework/log4j2/EventLogInspector.java}
(53%)
create mode 100644
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/rebalance/ItRebalanceMetricsTest.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/ZoneMetricSource.java
create mode 100644
modules/distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/rebalance/ZoneMetricSourceTest.java
copy
modules/metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/{ItMetricsTest.java
=> ItLogPushExporterEnabledByDefault.java} (51%)
create mode 100644
modules/metrics/src/main/java/org/apache/ignite/internal/metrics/sources/ClockServiceMetricSource.java
create mode 100644
modules/metrics/src/test/java/org/apache/ignite/internal/metrics/sources/ClockServiceMetricSourceTest.java
copy
modules/network-api/src/main/java/org/apache/ignite/internal/network/serialization/{MessageMappingException.java
=> MessageFormat.java} (59%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/internal/network/node/ItNodeStalenessAndRestartTest.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/NaiveMessageFormat.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/handshake/HandshakeEventLoopSwitcher.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/netty/ChannelEventLoopsSource.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/VaultStaleIds.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/internal/network/handshake/NoOpHandshakeEventLoopSwitcher.java
copy
modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/engine/AbstractVolatileStorageEngineTest.java
=>
network/src/test/java/org/apache/ignite/internal/network/recovery/InMemoryStaleIdsTest.java}
(52%)
delete mode 100644
modules/network/src/test/java/org/apache/ignite/internal/network/recovery/VaultStaleIdsTest.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/DirtyFullPageId.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/IgniteMessageServiceThread.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/IgniteCheckpointThread.java}
(52%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/IgniteCheckpointThreadFactory.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/PageHeaderTest.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/WriteSpeedFormatterTest.java
create mode 100644
modules/platforms/cpp/ignite/client/transaction/transaction_options.h
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/{ReplicationTimeoutException.java
=> AwaitReplicaTimeoutException.java} (60%)
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{InsertBenchmark.java
=> BulkDeleteBenchmark.java} (51%)
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/storageprofile/ItStorageProfilesTest.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/SystemPropertiesComponent.java
copy
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItSqlUsesKeyValueGetTest.java
=> ItSqlUsesKeyValueDeleteTest.java} (59%)
rename
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/{ItSqlUsesKeyValuePutTest.java
=> ItSqlUsesKeyValueInsertTest.java} (99%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/RelWithSources.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/TableModifyToKeyValueDeleteRule.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/{TableModifyToKeyValuePutRule.java
=> TableModifyToKeyValueInsertRule.java} (80%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/format/Formatter.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/format/{SqlDateTimeParser.java
=> SqlDateTimeFormatter.java} (77%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/PrimaryKeyDeletePlannerTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/format/FormatterSelfTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/format/FormatterSimpleFieldsTest.java
rename
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/format/{SqlDateTimeParserSelfTest.java
=> SqlDateTimeFormatterSelfTest.java} (64%)
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q14.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q14_colocated.plan
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q23.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q23_colocated.plan
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q24.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q24_colocated.plan
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/sorted/comparator/JitComparatorOptions.java
create mode 100644
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv/FailedCheckpointTest.java
create mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/DisasterRecoveryTestUtil.java
