This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20503
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 92308eedca Minors after review.
omit 467bc46178 Drop ExecutionTarget.finalise method.
omit 9d8d693b69 add tests
omit 99cbd76bd3 Minor.
omit 9c29728730 Minor.
omit 1aaa88e441 Styles.
omit 82fbd5b870 revert unrelated change
omit 3b581b6329 wip
omit a5143ed9a6 wip
add adf91949fc IGNITE-22421: Sql. Interval type. DDL statements should
return a proper error (#3936)
add 3d83c35107 IGNITE-22435 Add JobTarget interface (#3950)
add d736a8bc53 IGNITE-22545 Get rid of
PageMemoryProfileConfigurationSchema#memoryAllocator (#3958)
add 82ce4a3ab0 IGNITE-22213 Enable processing of client requests only
after all components have started (#3951)
add c8657b8992 IGNITE-22550 Get rid of
RocksDbProfileConfigurationSchema#numShardBits (#3960)
add 75400bbe28 IGNITE-22231 Implement zone based replicas start on the
zone creation (#3858)
add 73d3bb8e7f Bump com.netflix.nebula.ospackage from 11.9.0 to 11.9.1
(#3840)
add 9f6d69fe4f IGNITE-22462 Add planner test to verify type coercion for
set operations like UNION, INTERSECT and EXCEPT (#3957)
add b02d6de645 IGNITE-22551 Remove ReuseListImpl class (#3963)
add d34486b099 IGNITE-21661 Add test that reset partition can use data
from a node outside of stable assignments (#3945)
add 2df3f3f03e IGNITE-22520 Use IndexMeta when building the index (#3946)
add dd5fe83212 IGNITE-22552 Add sync methods to IgniteCatalog (#3962)
add d5adf9ed95 IGNITE-22385 Make rest and cli api to declarative style
(#3968)
add c662935199 IGNITE-22441 Add parameter object to Data Streamer (#3971)
add 79aad62d34 IGNITE-22430 Rename JobStatus to JobState and vice versa
(#3942)
add f98f98e91b IGNITE-22467 Add getAssignments method to the
PlacementDriver (#3947)
add 914f942668 IGNITE-22436 Add tests for rebalance triggers (#3965)
add d9d9d4a515 IGNITE-19383 Add git last commit hash to version (#3925)
add 7f719f088f IGNITE-22548 Publish Javadocs as jar (#3959)
add 66a3d69e86 IGNITE-22558 Optimize sending to yourself in
DefaultMessagingService (#3974)
add 6969d1a0fa IGNITE-22544 Benchmark and optimize raft commands
serialization. (#3975)
add af9f165248 Bump com.github.spotbugs from 6.0.17 to 6.0.18 (#3978)
add 5342b4355c IGNITE-22422 C++ Fix compute_test.all_arg_types flakiness
(#3981)
add 4206daa4df IGNITE-22270 MarshallerException uses INTERNAL_ERR code
(#3948)
add f6bc76c658 IGNITE-22351 Add Doxyfile to C++ project (#3980)
add 79f6cfc21f IGNITE-17059 Java thin: Implement batch SQL API for java
thin client (#3964)
add 732cfddb0e IGNITE-22466 Sql. Support mapping to non-primary replicas
(#3972)
add 3317de5fa5 wip
add 58e1478c35 wip
add 1d7f9ccbfe revert unrelated change
add 94788b4871 Styles.
add c73c7c4cbc Minor.
add 981e71dee7 Minor.
add 8ca6c997be add tests
add 6c2a735f51 Drop ExecutionTarget.finalise method.
add ebc340aa1d Minors after review.
add bfcc6abb93 Minors after merge with master.
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 (92308eedca)
\
N -- N -- N refs/heads/ignite-20503 (bfcc6abb93)
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:
.../generate-version-file.gradle | 29 +-
buildscripts/java-core.gradle | 1 +
buildscripts/sql-parser-generator.gradle | 1 +
.../config/storage/persistent.adoc | 1 -
.../config/storage/rocksdb.adoc | 1 -
.../config/storage/volatile.adoc | 1 -
docs/_docs/general-tips.adoc | 3 -
.../ignite/example/sql/ItSqlExamplesTest.java | 2 +-
gradle/libs.versions.toml | 4 +-
.../ignite/internal/affinity/Assignments.java | 20 +
.../internal/affinity/TokenizedAssignments.java} | 18 +-
.../affinity/TokenizedAssignmentsImpl.java | 62 +
.../org/apache/ignite/catalog/IgniteCatalog.java | 55 +
.../apache/ignite/compute/AnyNodeJobTarget.java} | 37 +-
.../apache/ignite/compute/ColocatedJobTarget.java | 59 +
.../org/apache/ignite/compute/IgniteCompute.java | 136 +-
.../org/apache/ignite/compute/JobExecution.java | 14 +-
.../java/org/apache/ignite/compute/JobState.java | 46 +-
.../java/org/apache/ignite/compute/JobStatus.java | 46 +-
.../java/org/apache/ignite/compute/JobTarget.java | 109 +
.../apache/ignite/compute/task/MapReduceJob.java | 3 +-
.../apache/ignite/compute/task/TaskExecution.java | 16 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 14 +-
.../apache/ignite/lang/MarshallerException.java | 5 +-
.../org/apache/ignite/sql/BatchedArguments.java | 152 +-
.../org/apache/ignite/sql/SqlBatchException.java | 14 +
.../apache/ignite/table/DataStreamerReceiver.java | 4 +-
.../apache/ignite/table/DataStreamerTarget.java | 11 +-
.../apache/ignite/table/ReceiverDescriptor.java | 126 +
.../apache/ignite/sql/BatchedArgumentsTest.java | 107 +
.../internal/catalog/sql/IgniteCatalogSqlImpl.java | 53 +
.../commands/AlterTableAddColumnCommand.java | 1 +
.../internal/catalog/commands/CatalogUtils.java | 12 +
.../catalog/commands/CreateTableCommand.java | 2 +
.../internal/catalog/storage/UpdateLogImpl.java | 8 +-
.../serialization/CatalogMarshallerException.java} | 23 +-
.../serialization/UpdateLogMarshallerImpl.java | 5 +-
.../ignite/internal/catalog/CatalogTableTest.java | 8 +-
...AlterTableAlterColumnCommandValidationTest.java | 64 +-
.../commands/CreateTableCommandValidationTest.java | 59 +
.../reset}/ItResetPartitionsCommandTest.java | 6 +-
.../reset}/ItResetPartitionsReplCommandTest.java | 5 +-
.../reset}/ItResetPartitionsTest.java | 2 +-
.../restart/ItRestartPartitionsCommandTest.java | 5 +-
.../ItRestartPartitionsReplCommandTest.java | 2 +-
.../restart/ItRestartPartitionsTest.java | 2 +-
.../states}/ItPartitionStatesCommandTest.java | 6 +-
.../states}/ItPartitionStatesReplCommandTest.java | 5 +-
.../states}/ItPartitionStatesTest.java | 2 +-
.../call/recovery/PartitionStatesCallInput.java | 2 +-
.../recovery/reset/ResetPartitionsCallInput.java | 2 +-
.../restart/RestartPartitionsCallInput.java | 2 +-
.../cli/commands/recovery/RecoveryCommand.java | 10 +-
.../cli/commands/recovery/RecoveryReplCommand.java | 10 +-
.../PartitionsCommand.java} | 20 +-
.../PartitionsReplCommand.java} | 20 +-
.../reset/ResetPartitionsCommand.java | 4 +-
.../reset/ResetPartitionsMixin.java | 2 +-
.../reset/ResetPartitionsReplCommand.java | 4 +-
.../restart/RestartPartitionsCommand.java | 4 +-
.../restart/RestartPartitionsMixin.java | 2 +-
.../restart/RestartPartitionsReplCommand.java | 4 +-
.../{ => states}/PartitionStatesCommand.java | 4 +-
.../{ => states}/PartitionStatesMixin.java | 2 +-
.../{ => states}/PartitionStatesReplCommand.java | 4 +-
.../recovery/restart/RestartPartitionsTest.java | 33 +-
.../internal/client/proto/ClientMessagePacker.java | 34 +
.../client/proto/ClientMessageUnpacker.java | 27 +-
.../ignite/internal/client/proto/ClientOp.java | 4 +-
modules/client-handler/build.gradle | 1 +
.../apache/ignite/client/handler/TestServer.java | 1 +
.../ignite/client/handler/ClientHandlerModule.java | 13 +-
.../handler/ClientInboundMessageHandler.java | 6 +-
.../ClientComputeExecuteColocatedRequest.java | 4 +-
.../ClientComputeExecuteMapReduceRequest.java | 22 +-
.../compute/ClientComputeExecuteRequest.java | 10 +-
...uest.java => ClientComputeGetStateRequest.java} | 26 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 14 +-
.../requests/table/ClientHandlerTupleTests.java | 5 +-
.../ignite/client/handler/FakePlacementDriver.java | 12 +-
.../apache/ignite/client/ClientOperationType.java | 8 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 2 +-
.../apache/ignite/internal/client/ClientUtils.java | 4 +-
.../internal/client/compute/ClientCompute.java | 112 +-
.../client/compute/ClientJobExecution.java | 42 +-
.../client/compute/ClientTaskExecution.java | 49 +-
.../internal/client/sql/ClientAsyncResultSet.java | 7 +-
.../ignite/internal/client/sql/ClientSql.java | 107 +-
.../client/table/ClientKeyValueBinaryView.java | 15 +-
.../internal/client/table/ClientKeyValueView.java | 82 +-
.../client/table/ClientRecordBinaryView.java | 14 +-
.../client/table/ClientRecordSerializer.java | 49 +-
.../internal/client/table/ClientRecordView.java | 23 +-
.../apache/ignite/client/AbstractClientTest.java | 9 +-
.../apache/ignite/client/ClientComputeTest.java | 56 +-
.../org/apache/ignite/client/ConnectionTest.java | 69 +
.../org/apache/ignite/client/DataStreamerTest.java | 56 +-
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../ignite/client/PartitionAwarenessTest.java | 28 +-
.../java/org/apache/ignite/client/TestServer.java | 22 +-
.../apache/ignite/client/fakes/FakeCompute.java | 125 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 98 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 8 +-
.../internal/compute/ItComputeTestEmbedded.java | 78 +-
.../internal/compute/ItComputeTestStandalone.java | 14 +-
.../internal/compute/ItExecutionsCleanerTest.java | 4 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 4 +-
.../ignite/internal/compute/ItMapReduceTest.java | 116 +-
.../internal/compute/ItWorkerShutdownTest.java | 10 +-
.../threading/ItComputeApiThreadingTest.java | 30 +-
.../compute/utils/TestingJobExecution.java | 36 +-
.../internal/compute/AntiHijackIgniteCompute.java | 53 +-
.../internal/compute/AntiHijackJobExecution.java | 6 +-
.../ignite/internal/compute/ComputeComponent.java | 16 +-
.../internal/compute/ComputeComponentImpl.java | 16 +-
.../internal/compute/ComputeMessageTypes.java | 24 +-
.../ignite/internal/compute/ComputeUtils.java | 26 +-
.../internal/compute/DelegatingJobExecution.java | 6 +-
.../ignite/internal/compute/ExecutionManager.java | 24 +-
.../internal/compute/FailSafeJobExecution.java | 60 +-
.../ignite/internal/compute/FailedExecution.java | 4 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 134 +-
.../internal/compute/IgniteComputeInternal.java | 14 +-
.../compute/JobExecutionFutureWrapper.java | 6 +-
.../internal/compute/JobExecutionWrapper.java | 6 +-
.../internal/compute/TaskExecutionWrapper.java | 6 +-
.../compute/executor/JobExecutionInternal.java | 6 +-
...{JobStatusRequest.java => JobStateRequest.java} | 6 +-
...obStatusResponse.java => JobStateResponse.java} | 18 +-
...bStatusesRequest.java => JobStatesRequest.java} | 6 +-
...tatusesResponse.java => JobStatesResponse.java} | 10 +-
.../compute/messaging/ComputeMessaging.java | 123 +-
.../compute/messaging/RemoteJobExecution.java | 6 +-
.../internal/compute/queue/QueueExecution.java | 10 +-
.../internal/compute/queue/QueueExecutionImpl.java | 10 +-
.../compute/state/ComputeStateMachine.java | 32 +-
...sition.java => IllegalJobStatusTransition.java} | 24 +-
.../compute/state/InMemoryComputeStateMachine.java | 98 +-
.../compute/task/AntiHijackTaskExecution.java | 6 +-
.../compute/task/DelegatingTaskExecution.java | 10 +-
.../compute/task/TaskExecutionInternal.java | 60 +-
.../internal/compute/ComputeComponentImplTest.java | 80 +-
.../internal/compute/IgniteComputeImplTest.java | 25 +-
.../compute/executor/ComputeExecutorTest.java | 34 +-
.../compute/queue/PriorityQueueExecutorTest.java | 44 +-
.../state/InMemoryComputeStateMachineTest.java | 62 +-
.../{JobStatusImpl.java => JobStateImpl.java} | 54 +-
.../internal/replicator/ZonePartitionId.java | 122 +
.../testframework/matchers/JobStateMatcher.java | 218 ++
.../testframework/matchers/JobStatusMatcher.java | 219 --
.../distributionzones/rebalance/RebalanceUtil.java | 207 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 5 +-
.../DistributionZonesTestUtil.java | 2 +-
modules/index/build.gradle | 3 +
.../internal/index/ItBuildIndexOneNodeTest.java | 2 +-
.../ignite/internal/index/ItBuildIndexTest.java | 2 +-
.../index/ItDropIndexMultipleNodesTest.java | 2 +-
.../index/ItRwTransactionAndIndexesTest.java | 2 +-
.../internal/index/IndexBuildController.java | 6 +-
.../ignite/internal/index/IndexBuildTask.java | 14 +-
.../apache/ignite/internal/index/IndexBuilder.java | 14 +-
.../index/IndexAvailabilityControllerTest.java | 17 +-
.../internal/index/IndexBuildControllerTest.java | 35 +-
.../ignite/internal/index/IndexBuilderTest.java | 10 +-
.../ignite/internal/index/TestPlacementDriver.java | 11 +
.../ignite/internal/marshaller/FieldAccessor.java | 1 +
.../ignite/internal/marshaller/Marshaller.java | 1 +
.../internal/marshaller/FieldAccessorTest.java | 1 +
.../impl/ItIdempotentCommandCacheTest.java | 2 +-
.../internal/network/processor/MessageClass.java | 7 +
.../processor/messages/MessageImplGenerator.java | 17 +
.../serialization/MessageSerializerGenerator.java | 16 +-
.../SerializationFactoryGenerator.java | 2 +-
.../ignite/internal/network/NetworkMessage.java | 6 +
.../internal/network/DefaultMessagingService.java | 87 +-
.../network/direct/DirectMessageWriter.java | 113 +-
.../network/direct/state/DirectMessageState.java | 7 +-
.../stream/DirectByteBufferStreamImplV1.java | 272 +-
.../serialization/ClassDescriptorRegistry.java | 3 +-
.../PerSessionSerializationService.java | 95 +-
.../MessageSerializationRegistryImplTest.java | 5 +
.../tree/AbstractBplusTreeReusePageMemoryTest.java | 16 +-
.../PageMemoryLocalConfigurationModule.java | 7 +-
.../schema/MemoryAllocatorConfigurationSchema.java | 32 -
...istentPageMemoryProfileConfigurationSchema.java | 4 -
.../UnsafeMemoryAllocatorConfigurationSchema.java | 30 -
...latilePageMemoryProfileConfigurationSchema.java | 5 -
.../internal/pagememory/freelist/FreeListImpl.java | 4 +-
.../pagememory/inmemory/VolatilePageMemory.java | 5 -
.../persistence/PersistentPageMemory.java | 5 -
.../internal/pagememory/reuse/ReuseListImpl.java | 146 -
.../pagememory/freelist/FreeListImplTest.java | 1 -
.../{index => partition-replicator}/build.gradle | 87 +-
.../replicator/ItReplicaLifecycleTest.java | 936 +++++++
.../replicator/utils/TestPlacementDriver.java | 104 +
.../PartitionReplicaLifecycleManager.java | 424 +++
.../replicator/ZonePartitionRaftListener.java | 57 +
.../replicator/ZonePartitionReplicaListener.java | 47 +
.../marshaller/PartitionCommandsMarshaller.java} | 28 +-
.../PartitionCommandsMarshallerImpl.java | 4 +-
.../ThreadLocalPartitionCommandsMarshaller.java | 58 +
.../network/PartitionReplicationMessageGroup.java} | 83 +-
.../replicator/network}/TimedBinaryRow.java | 4 +-
.../network}/command/BuildIndexCommand.java | 9 +-
.../network}/command/CatalogVersionAware.java | 4 +-
.../network}/command/FinishTxCommand.java | 6 +-
.../network}/command/PartitionCommand.java | 2 +-
.../network}/command/TablePartitionIdMessage.java | 4 +-
.../network}/command/TimedBinaryRowMessage.java | 8 +-
.../network}/command/UpdateAllCommand.java | 8 +-
.../replicator/network}/command/UpdateCommand.java | 6 +-
.../network}/command/WriteIntentSwitchCommand.java | 6 +-
.../network}/disaster/LocalPartitionStateEnum.java | 4 +-
.../disaster}/LocalPartitionStateMessage.java | 7 +-
.../disaster}/LocalPartitionStatesRequest.java | 4 +-
.../disaster}/LocalPartitionStatesResponse.java | 4 +-
.../replicator/network}/message/DataPresence.java | 2 +-
.../network}/message/HasDataRequest.java | 6 +-
.../network}/message/HasDataResponse.java | 6 +-
.../network/raft}/SnapshotMetaRequest.java | 6 +-
.../network/raft}/SnapshotMetaResponse.java | 6 +-
.../network/raft}/SnapshotMvDataRequest.java | 6 +-
.../network/raft}/SnapshotMvDataResponse.java | 13 +-
.../network/raft}/SnapshotRequestMessage.java | 2 +-
.../network/raft}/SnapshotTxDataRequest.java | 6 +-
.../network/raft}/SnapshotTxDataResponse.java | 6 +-
.../network/replication}/BinaryRowMessage.java | 6 +-
.../network/replication}/BinaryTupleMessage.java | 6 +-
.../replication}/BuildIndexReplicaRequest.java | 9 +-
.../replication}/MultipleRowPkReplicaRequest.java | 3 +-
.../replication}/MultipleRowReplicaRequest.java | 3 +-
.../ReadOnlyDirectMultiRowReplicaRequest.java | 6 +-
.../ReadOnlyDirectSingleRowReplicaRequest.java | 6 +-
.../ReadOnlyMultiRowPkReplicaRequest.java | 6 +-
.../replication}/ReadOnlyReplicaRequest.java | 2 +-
.../ReadOnlyScanRetrieveBatchReplicaRequest.java | 6 +-
.../ReadOnlySingleRowPkReplicaRequest.java | 6 +-
.../ReadWriteMultiRowPkReplicaRequest.java | 6 +-
.../ReadWriteMultiRowReplicaRequest.java | 6 +-
.../replication}/ReadWriteReplicaRequest.java | 4 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java | 6 +-
.../ReadWriteSingleRowPkReplicaRequest.java | 6 +-
.../ReadWriteSingleRowReplicaRequest.java | 6 +-
.../ReadWriteSwapRowReplicaRequest.java | 6 +-
.../network/replication}/RequestType.java | 2 +-
.../replication}/ScanCloseReplicaRequest.java | 6 +-
.../ScanRetrieveBatchReplicaRequest.java | 2 +-
.../replication}/SingleRowPkReplicaRequest.java | 3 +-
.../replication}/SingleRowReplicaRequest.java | 3 +-
.../replication}/SwapRowReplicaRequest.java | 3 +-
.../snapshot/FailFastSnapshotStorageFactory.java | 84 +
modules/placement-driver-api/build.gradle | 2 +
.../AssignmentsPlacementDriver.java | 43 +
...cementDriver.java => LeasePlacementDriver.java} | 16 +-
.../internal/placementdriver/PlacementDriver.java | 52 +-
.../placementdriver/TestPlacementDriver.java | 9 +
.../placementdriver/AssignmentsTracker.java | 34 +-
.../internal/placementdriver/LeaseUpdater.java | 13 +-
.../placementdriver/PlacementDriverManager.java | 65 +-
.../placementdriver/leases/LeaseTracker.java | 5 +-
.../placementdriver/LeaseNegotiationTest.java | 3 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 3 +-
.../placementdriver/PlacementDriverTest.java | 255 +-
.../{dotnet => cpp}/Apache_Ignite_logo_128x128.png | Bin
modules/platforms/cpp/Doxyfile | 2915 ++++++++++++++++++++
modules/platforms/cpp/cmake/dependencies.cmake | 2 +-
.../platforms/cpp/ignite/client/compute/compute.h | 2 +-
.../cpp/ignite/client/compute/job_execution.h | 2 +-
.../client/detail/compute/job_execution_impl.h | 2 +-
.../client/detail/transaction/transaction_impl.h | 2 +-
.../client/detail/transaction/transactions_impl.h | 2 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 2 +-
.../platforms/cpp/ignite/client/ignite_client.h | 2 +-
.../platforms/cpp/ignite/client/sql/result_set.h | 2 +-
modules/platforms/cpp/ignite/client/sql/sql.h | 2 +-
.../cpp/ignite/client/table/key_value_view.h | 2 +-
.../cpp/ignite/client/table/record_view.h | 2 +-
modules/platforms/cpp/ignite/client/table/table.h | 2 +-
modules/platforms/cpp/ignite/client/table/tables.h | 2 +-
.../cpp/ignite/client/transaction/transaction.h | 2 +-
.../cpp/ignite/client/transaction/transactions.h | 2 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 11 +-
.../platforms/cpp/ignite/common/big_decimal.cpp | 6 +-
modules/platforms/cpp/ignite/common/big_decimal.h | 25 +-
.../platforms/cpp/ignite/common/big_integer.cpp | 12 +-
modules/platforms/cpp/ignite/common/big_integer.h | 2 +-
.../platforms/cpp/ignite/common/bignum_test.cpp | 10 +-
modules/platforms/cpp/ignite/common/bits_test.cpp | 432 ---
.../cpp/ignite/common/{ => detail}/bits.h | 4 +-
.../cpp/ignite/common/detail/bits_test.cpp | 434 +++
.../cpp/ignite/common/{ => detail}/bytes.h | 4 +-
.../cpp/ignite/common/{ => detail}/bytes_test.cpp | 80 +-
.../cpp/ignite/common/{ => detail}/config.h | 0
.../common/{ => detail}/ignite_mbedtls_config.h | 0
.../ignite/common/{ => detail}/server_version.h | 2 +-
modules/platforms/cpp/ignite/common/error_codes.h | 8 +-
.../cpp/ignite/network/length_prefix_codec.cpp | 4 +-
modules/platforms/cpp/ignite/network/network.cpp | 2 +-
.../ignite/odbc/app/application_data_buffer.cpp | 4 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 6 +-
.../cpp/ignite/odbc/config/connection_info.cpp | 6 +-
modules/platforms/cpp/ignite/odbc/entry_points.cpp | 2 +-
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 4 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 4 +-
modules/platforms/cpp/ignite/odbc/type_traits.cpp | 2 +-
.../cpp/ignite/protocol/buffer_adapter.cpp | 4 +-
.../cpp/ignite/protocol/protocol_context.h | 8 +-
modules/platforms/cpp/ignite/protocol/utils.cpp | 4 +-
modules/platforms/cpp/ignite/protocol/utils.h | 2 +-
modules/platforms/cpp/ignite/protocol/writer.h | 6 +-
.../cpp/ignite/tuple/binary_tuple_builder.cpp | 78 +-
.../cpp/ignite/tuple/binary_tuple_builder.h | 4 +-
.../cpp/ignite/tuple/binary_tuple_parser.cpp | 8 +-
modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 4 +-
.../cpp/tests/client-test/compute_test.cpp | 7 +-
.../cpp/tests/odbc-test/api_robustness_test.cpp | 2 +-
.../cpp/tests/test-common/ignite_runner.cpp | 2 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 14 +-
.../internal/raft/util/DefaultByteBuffersPool.java | 57 +-
.../ignite/internal/raft/util/OptimizedStream.java | 96 +-
modules/replica-lifecycle/build.gradle | 30 -
.../datareplication/ReplicaLifecycleManager.java | 58 -
.../apache/ignite/internal/replicator/Replica.java | 275 +-
.../replicator/{Replica.java => ReplicaImpl.java} | 31 +-
.../ignite/internal/replicator/ReplicaManager.java | 151 +-
.../replicator/ZonePartitionReplicaImpl.java | 70 +
.../replicator/PlacementDriverReplicaSideTest.java | 2 +-
.../internal/rest/api/compute/ComputeApi.java | 24 +-
.../ignite/internal/rest/api/compute/JobState.java | 88 +-
.../internal/rest/api/compute/JobStatus.java | 88 +-
.../rest/api/recovery/DisasterRecoveryApi.java | 8 +-
modules/rest/build.gradle | 1 +
.../rest/compute/ItComputeControllerTest.java | 91 +-
...asterRecoveryControllerResetPartitionsTest.java | 17 +-
...terRecoveryControllerRestartPartitionsTest.java | 18 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 10 +-
.../internal/rest/compute/ComputeController.java | 38 +-
...ception.java => ComputeJobStatusException.java} | 10 +-
....java => ComputeJobStatusExceptionHandler.java} | 10 +-
...StatusMatcher.java => RestJobStateMatcher.java} | 118 +-
modules/runner/build.gradle | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 11 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 3 +-
.../runner/app/PlatformTestNodeRunner.java | 15 +-
.../runner/app/client/ItThinClientComputeTest.java | 188 +-
.../client/ItThinClientPartitionAwarenessTest.java | 5 +-
.../streamer/ItAbstractDataStreamerTest.java | 16 +-
.../internal/table/ItThinClientColocationTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 57 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 17 +-
.../internal/schema/marshaller/KvMarshaller.java | 2 +-
.../schema/marshaller/RecordMarshaller.java | 2 +-
.../marshaller/asm/AsmMarshallerGenerator.java | 8 +-
.../marshaller/reflection/KvMarshallerImpl.java | 2 +-
.../reflection/RecordMarshallerImpl.java | 15 +-
.../schema/marshaller/KvMarshallerTest.java | 2 +-
.../schema/marshaller/RecordMarshallerTest.java | 2 +-
.../RecordMarshallerValidationsTest.java | 2 +-
modules/sql-engine/build.gradle | 2 +
.../sql/api/ItSqlClientAsynchronousApiTest.java | 18 -
.../sql/api/ItSqlClientSynchronousApiTest.java | 18 -
.../internal/sql/engine/ItCreateTableDdlTest.java | 30 +
.../ignite/internal/sql/api/IgniteSqlImpl.java | 20 +-
.../sql/engine/ExecutionTargetProviderImpl.java | 173 ++
.../internal/sql/engine/SqlQueryProcessor.java | 94 +-
.../internal/sql/engine/exec/ExchangeService.java | 2 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 2 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 3 +-
.../sql/engine/exec/UpdatableTableImpl.java | 10 +-
.../sql/engine/exec/mapping/ExecutionTarget.java | 10 +
.../exec/mapping/ExecutionTargetFactory.java | 5 +-
.../exec/mapping/ExecutionTargetProvider.java | 10 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 317 ++-
.../sql/engine/exec/mapping/FragmentMapping.java | 11 +-
.../sql/engine/exec/mapping/FragmentSplitter.java | 2 +-
.../sql/engine/exec/mapping/MappingParameters.java | 20 +-
.../engine/exec/mapping/MappingServiceImpl.java | 217 +-
.../exec/mapping/largecluster/AllOfTarget.java | 5 +
.../mapping/largecluster/LargeClusterFactory.java | 33 +-
.../exec/mapping/largecluster/OneOfTarget.java | 20 +
.../mapping/largecluster/PartitionedTarget.java | 51 +
.../exec/mapping/largecluster/SomeOfTarget.java | 20 +
.../exec/mapping/smallcluster/AllOfTarget.java | 5 +
.../exec/mapping/smallcluster/OneOfTarget.java | 15 +
.../mapping/smallcluster/PartitionedTarget.java | 51 +
.../mapping/smallcluster/SmallClusterFactory.java | 34 +-
.../exec/mapping/smallcluster/SomeOfTarget.java | 15 +
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../internal/sql/engine/exec/rel/Outbox.java | 6 +-
.../sql/engine/message/QueryBatchMessage.java | 2 +-
.../internal/sql/engine/prepare/Fragment.java | 10 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 13 +
.../sql/engine/benchmarks/MappingBenchmark.java | 17 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 50 +-
.../mapping/ExecutionTargetFactorySelfTest.java | 70 +-
.../engine/exec/mapping/FragmentMappingTest.java | 97 +-
.../exec/mapping/MappingServiceImplTest.java | 31 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 12 +-
.../sql/engine/framework/TestBuilders.java | 48 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 21 +-
.../NumericComparisonTypeCoercionTest.java | 128 +-
...rcionTest.java => SetOperatorCoercionTest.java} | 598 ++--
.../sql/engine/planner/datatypes/utils/Types.java | 12 +
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 67 +
.../src/test/resources/mapping/correlated.test | 136 +-
.../src/test/resources/mapping/hash_join.test | 31 +-
.../src/test/resources/mapping/merge_join.test | 66 +-
.../src/test/resources/mapping/set_ops.test | 18 +-
.../src/test/resources/mapping/table_identity.test | 68 +-
.../resources/mapping/table_identity_single.test | 60 +-
.../src/test/resources/mapping/table_single.test | 80 +-
.../resources/mapping/test_backup_mapping.test | 162 ++
.../resources/mapping/test_partition_pruning.test | 72 +-
.../src/test/resources/mapping/union.test | 30 +-
.../internal/storage/BaseMvStoragesTest.java | 19 +-
.../PersistentPageMemoryTableStorage.java | 1 -
.../pagememory/VolatilePageMemoryDataRegion.java | 5 +-
...yStorageEngineLocalConfigurationModuleTest.java | 7 +-
.../storage/rocksdb/RocksDbStorageProfile.java | 2 +-
.../schema/RocksDbProfileConfigurationSchema.java | 5 -
modules/table/build.gradle | 4 +-
.../ItInternalTableReadOnlyOperationsTest.java | 4 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 5 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 14 +-
.../ReplicasSafeTimePropagationTest.java | 4 +-
.../ItDisasterRecoveryReconfigurationTest.java | 211 +-
.../disaster/ItDisasterRecoverySystemViewTest.java | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 2 +-
.../rebalance/ItRebalanceDistributedTest.java | 20 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 3 +-
.../ignite/internal/table/ItColocationTest.java | 23 +-
.../table/ItTransactionPrimaryChangeTest.java | 2 +-
.../internal/table/ItTransactionRecoveryTest.java | 2 +-
.../schema/marshaller/TupleMarshaller.java | 13 +-
.../marshaller/TupleMarshallerException.java | 36 -
.../schema/marshaller/TupleMarshallerImpl.java | 13 +-
.../internal/table/KeyValueBinaryViewImpl.java | 19 +-
...aluePojoStreamerPartitionAwarenessProvider.java | 24 +-
.../ignite/internal/table/KeyValueViewImpl.java | 113 +-
.../PojoStreamerPartitionAwarenessProvider.java | 22 +-
.../internal/table/PublicApiThreadingViewBase.java | 13 +-
.../internal/table/RecordBinaryViewImpl.java | 27 +-
.../ignite/internal/table/RecordViewImpl.java | 141 +-
.../apache/ignite/internal/table/TableImpl.java | 21 +-
.../internal/table/TableViewRowConverter.java | 12 +-
.../PartitionReplicatorNodeRecovery.java | 12 +-
.../table/distributed/StorageUpdateHandler.java | 2 +-
.../internal/table/distributed/TableManager.java | 17 +-
.../internal/table/distributed/TableUtils.java | 28 -
.../disaster/DisasterRecoveryManager.java | 48 +-
.../distributed/disaster/GlobalPartitionState.java | 12 +
.../distributed/disaster/LocalPartitionState.java | 13 +
.../disaster/LocalPartitionStateByNode.java | 9 +-
.../LocalPartitionStateEnumWithLogIndex.java | 7 +-
.../disaster/LocalPartitionStateMessageByNode.java | 7 +-
.../disaster/ManualGroupUpdateRequest.java | 221 +-
.../disaster/PartitionStatesMetricSource.java | 11 +-
.../exceptions/DisasterRecoveryException.java | 6 +-
.../table/distributed/index/IndexMeta.java | 84 +-
.../table/distributed/index/IndexMetaStorage.java | 10 +-
.../table/distributed/raft/PartitionListener.java | 81 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 16 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 20 +-
.../outgoing/OutgoingSnapshotsManager.java | 18 +-
.../replicator/PartitionReplicaListener.java | 118 +-
.../distributed/replicator/ReplicatorUtils.java | 2 +-
.../schema/PartitionCommandsMarshallerImpl.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 40 +-
.../wrappers/DelegatingPlacementDriver.java | 9 +
.../table/partition/HashPartitionManagerImpl.java | 23 +-
.../TupleMarshallerFixlenOnlyBenchmark.java | 3 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 3 +-
.../UpdateCommandsMarshalingMicroBenchmark.java | 162 ++
.../table/ColocationHashCalculationTest.java | 5 +-
.../internal/table/MutableRowTupleAdapterTest.java | 48 +-
.../internal/table/distributed/IndexBaseTest.java | 7 +-
.../table/distributed/StorageCleanupTest.java | 2 +-
.../distributed/StorageUpdateHandlerTest.java | 2 +-
.../distributed/TableManagerRecoveryTest.java | 7 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../PartitionRaftCommandsSerializationTest.java | 16 +-
.../index/BaseIndexMetaStorageTest.java | 23 +
.../index/IndexMetaStorageRecoveryTest.java | 68 +-
.../distributed/index/IndexMetaStorageTest.java | 121 +-
.../raft/PartitionCommandListenerTest.java | 66 +-
.../incoming/IncomingSnapshotCopierTest.java | 16 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 8 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 8 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 17 +-
.../replication/PartitionReplicaListenerTest.java | 215 +-
.../replicator/ReplicatorUtilsTest.java | 2 +-
.../replicator/action/RequestTypeTest.java | 13 +-
.../CheckCatalogVersionOnActionRequestTest.java | 4 +-
.../PartitionCommandsMarshallerImplTest.java | 14 +-
.../table/type/NumericTypesSerializerTest.java | 28 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 11 +-
.../replicator/action/RequestTypes.java | 2 +-
.../ignite/internal/table/TxAbstractTest.java | 3 +-
.../table/impl/DummyInternalTableImpl.java | 7 +-
modules/workers/build.gradle | 1 +
.../worker/ItCriticalWorkerMonitoringTest.java | 10 +-
packaging/db/build.gradle | 7 +-
settings.gradle | 4 +-
504 files changed, 13680 insertions(+), 6285 deletions(-)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/DisasterRecoveryException.java
=> buildscripts/generate-version-file.gradle (58%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadOnlyReplicaRequest.java
=>
affinity/src/main/java/org/apache/ignite/internal/affinity/TokenizedAssignments.java}
(61%)
create mode 100644
modules/affinity/src/main/java/org/apache/ignite/internal/affinity/TokenizedAssignmentsImpl.java
copy
modules/{marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/MarshallerException.java
=> api/src/main/java/org/apache/ignite/compute/AnyNodeJobTarget.java} (57%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/ColocatedJobTarget.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/JobTarget.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/table/ReceiverDescriptor.java
create mode 100644
modules/api/src/test/java/org/apache/ignite/sql/BatchedArgumentsTest.java
copy
modules/{rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/ComputeJobStateException.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogMarshallerException.java}
(60%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/reset}/ItResetPartitionsCommandTest.java (86%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/reset}/ItResetPartitionsReplCommandTest.java (87%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/reset}/ItResetPartitionsTest.java (98%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions}/restart/ItRestartPartitionsCommandTest.java (90%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions}/restart/ItRestartPartitionsReplCommandTest.java (93%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions}/restart/ItRestartPartitionsTest.java (98%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/states}/ItPartitionStatesCommandTest.java (86%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/states}/ItPartitionStatesReplCommandTest.java (87%)
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/{
=> partitions/states}/ItPartitionStatesTest.java (99%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{RecoveryCommand.java
=> partitions/PartitionsCommand.java} (63%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{RecoveryReplCommand.java
=> partitions/PartitionsReplCommand.java} (62%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/reset/ResetPartitionsCommand.java (93%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/reset/ResetPartitionsMixin.java (97%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/reset/ResetPartitionsReplCommand.java (93%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/restart/RestartPartitionsCommand.java (92%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/restart/RestartPartitionsMixin.java (97%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/{ =>
partitions}/restart/RestartPartitionsReplCommand.java (92%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/{
=> states}/PartitionStatesCommand.java (96%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/{
=> states}/PartitionStatesMixin.java (99%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/{
=> states}/PartitionStatesReplCommand.java (96%)
rename
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/compute/{ClientComputeGetStatusRequest.java
=> ClientComputeGetStateRequest.java} (71%)
rename
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatusRequest.java
=> JobStateRequest.java} (89%)
rename
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatusResponse.java
=> JobStateResponse.java} (72%)
rename
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatusesRequest.java
=> JobStatesRequest.java} (87%)
rename
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatusesResponse.java
=> JobStatesResponse.java} (84%)
rename
modules/compute/src/main/java/org/apache/ignite/internal/compute/state/{IllegalJobStateTransition.java
=> IllegalJobStatusTransition.java} (58%)
rename
modules/core/src/main/java/org/apache/ignite/internal/compute/{JobStatusImpl.java
=> JobStateImpl.java} (81%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/replicator/ZonePartitionId.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/JobStateMatcher.java
delete mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/JobStatusMatcher.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/MemoryAllocatorConfigurationSchema.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/configuration/schema/UnsafeMemoryAllocatorConfigurationSchema.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/reuse/ReuseListImpl.java
copy modules/{index => partition-replicator}/build.gradle (63%)
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItReplicaLifecycleTest.java
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/utils/TestPlacementDriver.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ZonePartitionRaftListener.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ZonePartitionReplicaListener.java
rename
modules/{marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/MarshallerException.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller/PartitionCommandsMarshaller.java}
(53%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/schema
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller}/PartitionCommandsMarshallerImpl.java
(93%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/marshaller/ThreadLocalPartitionCommandsMarshaller.java
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/TableMessageGroup.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/PartitionReplicationMessageGroup.java}
(56%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/TimedBinaryRow.java
(92%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/BuildIndexCommand.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/CatalogVersionAware.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/FinishTxCommand.java
(87%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/PartitionCommand.java
(95%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/TablePartitionIdMessage.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/TimedBinaryRowMessage.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/UpdateAllCommand.java
(87%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/UpdateCommand.java
(90%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/command/WriteIntentSwitchCommand.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/disaster/LocalPartitionStateEnum.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStateMessage.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStatesRequest.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster}/LocalPartitionStatesResponse.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/DataPresence.java
(94%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/HasDataRequest.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network}/message/HasDataResponse.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMetaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMetaResponse.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMvDataRequest.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotMvDataResponse.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotRequestMessage.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotTxDataRequest.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/message
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/raft}/SnapshotTxDataResponse.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BinaryRowMessage.java
(84%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BinaryTupleMessage.java
(86%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/BuildIndexReplicaRequest.java
(83%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/MultipleRowPkReplicaRequest.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/MultipleRowReplicaRequest.java
(91%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyDirectMultiRowReplicaRequest.java
(81%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyDirectSingleRowReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyMultiRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyReplicaRequest.java
(93%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlyScanRetrieveBatchReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadOnlySingleRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteMultiRowPkReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteMultiRowReplicaRequest.java
(85%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteReplicaRequest.java
(89%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteScanRetrieveBatchReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSingleRowPkReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSingleRowReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ReadWriteSwapRowReplicaRequest.java
(80%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/action
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/RequestType.java
(96%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ScanCloseReplicaRequest.java
(82%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/ScanRetrieveBatchReplicaRequest.java
(97%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SingleRowPkReplicaRequest.java
(88%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SingleRowReplicaRequest.java
(90%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication}/SwapRowReplicaRequest.java
(90%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/snapshot/FailFastSnapshotStorageFactory.java
create mode 100644
modules/placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/AssignmentsPlacementDriver.java
copy
modules/placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/{PlacementDriver.java
=> LeasePlacementDriver.java} (85%)
copy modules/platforms/{dotnet => cpp}/Apache_Ignite_logo_128x128.png (100%)
create mode 100644 modules/platforms/cpp/Doxyfile
delete mode 100644 modules/platforms/cpp/ignite/common/bits_test.cpp
rename modules/platforms/cpp/ignite/common/{ => detail}/bits.h (99%)
create mode 100644 modules/platforms/cpp/ignite/common/detail/bits_test.cpp
rename modules/platforms/cpp/ignite/common/{ => detail}/bytes.h (99%)
rename modules/platforms/cpp/ignite/common/{ => detail}/bytes_test.cpp (83%)
rename modules/platforms/cpp/ignite/common/{ => detail}/config.h (100%)
rename modules/platforms/cpp/ignite/common/{ =>
detail}/ignite_mbedtls_config.h (100%)
rename modules/platforms/cpp/ignite/common/{ => detail}/server_version.h (98%)
delete mode 100644 modules/replica-lifecycle/build.gradle
delete mode 100644
modules/replica-lifecycle/src/main/java/org/apache/ignite/internal/datareplication/ReplicaLifecycleManager.java
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/{Replica.java
=> ReplicaImpl.java} (95%)
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ZonePartitionReplicaImpl.java
rename
modules/rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/{ComputeJobStateException.java
=> ComputeJobStatusException.java} (74%)
rename
modules/rest/src/main/java/org/apache/ignite/internal/rest/compute/exception/handler/{ComputeJobStateExceptionHandler.java
=> ComputeJobStatusExceptionHandler.java} (82%)
rename
modules/rest/src/testFixtures/java/org/apache/ignite/internal/rest/matcher/{RestJobStatusMatcher.java
=> RestJobStateMatcher.java} (60%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/ExecutionTargetProviderImpl.java
copy
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/{NumericComparisonTypeCoercionTest.java
=> SetOperatorCoercionTest.java} (55%)
create mode 100644
modules/sql-engine/src/test/resources/mapping/test_backup_mapping.test
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/schema/marshaller/TupleMarshallerException.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/benchmarks/UpdateCommandsMarshalingMicroBenchmark.java
