This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch IGNITE-22152
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from f5d60bf6bd Fix
add 942d94ddb3 IGNITE-22523 Thin client: reserve op code range for
extensions (#4071)
add c00b97c18d Bump org.junit.platform:junit-platform-testkit from 1.10.2
to 1.10.3 (#4004)
add eb7b4e58b1 IGNITE-22713: Sql. Move timeout scheduling code to
ExecutionContext (#4073)
add 496fe683cd IGNITE-22353 Basic Python DB API Driver (#4075)
add 644536bf1f IGNITE-22708 Do not start distributionZoneRebalanceEngineV2
without feature flag (#4074)
add 5446df3bac IGNITE-22714 Use IndexMeta in PartitionReplicaListener
(#4077)
add 0077758ad6 IGNITE-22709 Use IndexMeta in ChangeIndexStatusTask (#4072)
add c3ad113dd4 Bump io.github.goooler.shadow from 8.1.7 to 8.1.8 (#3995)
add b5575f5bde IGNITE-22720 Get rid of
CatalogIndexDescriptor#txWaitCatalogVersion (#4080)
add ae982d7fea IGNITE-22310 Do not log slow network processing in storage
threads (#4079)
add 75ed4f4c76 IGNITE-21771 Removed unnecessary TODO (#4084)
add a0811f97b3 IGNITE-22728 Switch to a different Gradle CMake plugin.
(#4082)
add 8f510c448a IGNITE-22736 Fix log buffers position change by
unmarshalling process (#4086)
add bc6c427574 IGNITE-22715 Support HybridTimestamp in Network
serialization (#4078)
add ba1624502f IGNITE-22737 Cleanup comments in the platforms native code
(#4087)
add 26f4e67810 IGNITE-22619 Add `InternalTable#estimatedSize` method
(#4065)
add 78a4b821b5 IGNITE-22750 log node start errors in error logging level
(#4093)
add 7dedc06ea2 IGNITE-22581 Add planner test to verify numeric type
coercion of source for INSERT, UPDATE and MERGE operators (#4045)
add 146e803bf7 IGNITE-22735 Sql. Avoid double parsing of sql queries
(#4085)
add 514949e722 IGNITE-22555 Fixed assertion in
ReplicaStateManager.onPrimaryElected (#4055)
add 2b7dbb6643 IGNITE-22710 Add exception translation to Transaction
implementations (#4070)
add b8d08f16b7 IGNITE-16444 Get rid of unnecessary TODO (#4097)
add ca69fcd96b IGNITE-22690 Fixe tx cleanup triggered by commit partition
primary replica election from non-primary node (#4083)
add 86b8dcbe3d IGNITE-22764 Increase readability in MvPartitionStorage
tests (#4101)
add cc2ea0d1a2 Bump org.assertj:assertj-core from 3.26.0 to 3.26.3 (#4076)
add 2592e6de34 IGNITE-20137 Fixed
ItIgniteNodeRestartTest#testOneNodeRestartWithGap (#4098)
add 7fc402d3f5 IGNITE-22292 Move LogSyncer out of Loza and RaftServer.
(#4094)
add 9c4f2a784d IGNITE-22616 Implement
AbstractPageMemoryMvPartitionStorage#estimatedSize (#4102)
add 96095a157b IGNITE-22770 Fix testBytesSentReceived fail on short
version (#4107)
add 9b271581a7 IGNITE-22285 Implement Embedded Data Streamer with Receiver
(#4103)
add 08222ebae4 IGNITE-22761 Disable WAL in RocksDB used to spill volatile
Raft logs on disk (#4113)
add 1c9366450f IGNITE-22699 Fix anti-hijack protection of
containsAllAsync() (#4115)
add 918becac48 IGNITE-20525 Fix
ItBuildIndexTest#testChangePrimaryReplicaOnMiddleBuildIndex (#4112)
add e22683ef88 IGNITE-22780 Sql. Fix cast from VARCHAR to TS WITH LOCAL TZ
(#4116)
add d81a14651c IGNITE-22185
DistributionZoneCausalityDataNodesTest.testEmptyDataNodesOnZoneCreationBeforeTopologyEventAndZoneInitialisation
became flaky on the main (#4095)
add 95fc4dfc10 Bump org.rocksdb:rocksdbjni from 9.3.1 to 9.4.0 (#4089)
add 1d2f377a58 Bump com.github.spotbugs from 6.0.18 to 6.0.19 (#4081)
add 6aeb623fff Bump jline from 3.26.2 to 3.26.3 (#4105)
add 9c00ca1176 IGNITE-22585 Sql. Fix possible NPE in distributed query
manager when a timeout occurs during mapping (#4092)
add 0b803ee01b IGNITE-20415 Internal IncompatibleSchemaException is thrown
from public API (#4068)
add f665bb3720 IGNITE-22658 Update IgniteCatalog javadoc (#4096)
add 09ba0768b1 IGNITE-18357 Move classes from fixtures to tests (#4122)
add f54bd46f58 IGNITE-22793 Sql. Make ItCastToTsWithLocalTimeZoneTest
stable (#4123)
add 2c3ce15a0d IGNITE-22233 Add zone replica listener (#3931)
add 5d65a0022a IGNITE-22646 Support marshallers in the Java Client for
Compute API (#4100)
add 36b119e37f IGNITE-22797 Fix estimated size for insert-after-delete
scenario (#4125)
add 6178f00920 IGNITE-22799 Add partition ID to BplusTree names to make
debugging easier (#4126)
add 76ef888279 Bump netty from 4.1.111.Final to 4.1.112.Final (#4120)
add 5691869bec IGNITE-22791 Fix marshaller spelling (#4127)
add a143a94fb8 IGNITE-22617 Implement
RocksDbMvPartitionStorage#estimatedSize (#4118)
add cd3c790b03 IGNITE-22655 Sql. Improve error message for incorrect SQL
string (#4108)
add c7ecf24e8d IGNITE-22636 Implement catalog compaction coordinator
(#4059)
add 00467d1c7c IGNITE-22800 Make field BplusTree#globalRmvId monotonically
increasing to avoid errors after node recovery (#4131)
add 24a60d7eb6 IGNITE-22820 Unwrap exception cause on retry in
InternalTableImpl (#4133)
add 1f1a7cf010 IGNITE-22283 Sql. Prepare to remove NUMBER and BITMASK
native types (#4114)
add 1d76a1c434 IGNITE-22817 Sql. Align rule of conversion between numerics
(#4128)
add a1483550c4 Merge branch 'refs/heads/main' into IGNITE-22152
add 6f46512738 Fix merge
No new revisions were added by this update.
Summary of changes:
check-rules/spotbugs-excludes.xml | 1 +
docs/_docs/developers-guide/clients/cpp.adoc | 2 +-
docs/_docs/developers-guide/java-to-tables.adoc | 10 +-
gradle/libs.versions.toml | 16 +-
.../org/apache/ignite/catalog/IgniteCatalog.java | 19 +-
.../java/org/apache/ignite/compute/ComputeJob.java | 18 +-
.../org/apache/ignite/compute/JobDescriptor.java | 26 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 7 +
.../org/apache/ignite/lang/IgniteException.java | 4 +-
.../ByteArrayMarshaller.java} | 18 +-
.../JavaSerializationByteArrayMarshalling.java} | 4 +-
.../Marshaler.java => marshalling/Marshaller.java} | 18 +-
.../MarshallingException.java | 4 +-
.../TupleMarshaller.java | 6 +-
...UnsupportedObjectTypeMarshallingException.java} | 12 +-
.../java/org/apache/ignite/sql/ColumnType.java | 2 +
.../apache/ignite/table/DataStreamerReceiver.java | 2 +-
.../apache/ignite/table/DataStreamerTarget.java | 2 +-
.../apache/ignite/table/ReceiverDescriptor.java | 20 +-
.../main/java/org/apache/ignite/table/Tuple.java | 2 +
.../ignite/tx/IncompatibleSchemaException.java} | 24 +-
.../tx/MismatchingTransactionOutcomeException.java | 36 +-
.../org/apache/ignite/tx/TransactionException.java | 11 +-
.../ByteArrayMarshallerTest.java} | 34 +-
.../ignite/table/AbstractImmutableTupleTest.java | 23 -
.../internal/binarytuple/BinaryTupleBuilder.java | 2 +
.../internal/binarytuple/BinaryTupleParser.java | 2 +
.../internal/binarytuple/BinaryTupleReader.java | 2 +
modules/catalog-compaction/README.md | 1 +
.../{compute => catalog-compaction}/build.gradle | 43 +-
...ItCatalogCompactionCoordinatorChoosingTest.java | 6 +-
.../compaction/CatalogCompactionRunner.java | 385 ++++++++++++
.../message/CatalogCompactionMessageGroup.java} | 20 +-
.../CatalogMinimumRequiredTimeRequest.java} | 11 +-
.../CatalogMinimumRequiredTimeResponse.java} | 22 +-
.../CatalogCompactionRunnerSelfTest.java | 415 +++++++++++++
modules/catalog/build.gradle | 6 -
.../internal/catalog/CatalogManagerImpl.java | 20 -
.../commands/AbstractCreateIndexCommand.java | 4 +-
.../internal/catalog/commands/CatalogUtils.java | 11 +-
.../catalog/commands/CreateHashIndexCommand.java | 4 +-
.../catalog/commands/CreateSortedIndexCommand.java | 4 +-
.../catalog/commands/CreateTableCommand.java | 7 +-
.../internal/catalog/commands/DefaultValue.java | 12 -
.../descriptors/CatalogHashIndexDescriptor.java | 20 +-
.../descriptors/CatalogIndexDescriptor.java | 25 +-
.../descriptors/CatalogSortedIndexDescriptor.java | 19 +-
.../storage/AbstractChangeIndexStatusEntry.java | 17 +-
.../internal/catalog/storage/RenameIndexEntry.java | 2 -
.../ignite/internal/catalog/CatalogIndexTest.java | 68 --
.../catalog/CatalogManagerRecoveryTest.java | 24 -
.../internal/catalog/CatalogManagerSelfTest.java | 33 +-
.../ignite/internal/catalog/CatalogTableTest.java | 1 -
...ractChangeIndexStatusCommandValidationTest.java | 1 -
.../catalog/commands/CatalogUtilsTest.java | 3 +-
.../CatalogHashIndexDescriptorTest.java | 2 +-
.../CatalogSortedIndexDescriptorTest.java | 2 +-
.../storage/CatalogEntrySerializationTest.java | 15 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 54 +-
.../client/proto/ClientBinaryTupleUtils.java | 42 +-
.../internal/client/proto/ClientMessagePacker.java | 8 +-
.../ignite/internal/client/proto/ClientOp.java | 8 +
.../client/proto/StreamerReceiverSerializer.java | 126 +++-
.../table/MutableTupleBinaryTupleAdapter.java | 6 -
.../ignite/internal/jdbc/JdbcConverterUtils.java | 6 -
.../internal/jdbc/proto/event/JdbcColumnMeta.java | 4 -
.../handler/ClientInboundMessageHandler.java | 2 +-
.../ClientComputeExecuteColocatedRequest.java | 4 +-
.../compute/ClientComputeExecuteRequest.java | 12 +-
.../handler/requests/sql/ClientSqlCommon.java | 9 -
...ClientStreamerWithReceiverBatchSendRequest.java | 67 +-
.../handler/requests/table/ClientTableCommon.java | 5 -
.../requests/table/ClientHandlerTupleTests.java | 7 +-
.../internal/client/compute/ClientCompute.java | 36 +-
.../client/compute/ClientJobExecution.java | 6 +-
.../internal/client/sql/ClientAsyncResultSet.java | 6 -
.../internal/client/table/ClientDataStreamer.java | 9 +-
.../client/table/ClientKeyValueBinaryView.java | 2 +-
.../internal/client/table/ClientKeyValueView.java | 2 +-
.../client/table/ClientRecordBinaryView.java | 2 +-
.../internal/client/table/ClientRecordView.java | 2 +-
.../ignite/internal/client/table/ClientSchema.java | 6 -
.../ignite/client/AbstractClientTableTest.java | 12 -
.../apache/ignite/client/ClientComputeTest.java | 35 +-
.../ignite/client/ClientKeyValueViewTest.java | 8 -
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../apache/ignite/client/ClientRecordViewTest.java | 8 -
.../org/apache/ignite/client/ClientSqlTest.java | 20 +-
.../org/apache/ignite/client/ClientTupleTest.java | 92 ++-
.../org/apache/ignite/client/DataStreamerTest.java | 4 -
.../apache/ignite/client/RequestBalancingTest.java | 7 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 5 +
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 6 +-
.../apache/ignite/client/fakes/FakeCompute.java | 18 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 9 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 10 +-
.../ignite/client/fakes/FakeIgniteTables.java | 16 +-
.../ignite/client/fakes/FakeInternalTable.java | 38 +-
modules/compute/build.gradle | 2 +
.../ignite/internal/compute/ItComputeBaseTest.java | 4 +-
.../internal/compute/ItComputeTestStandalone.java | 2 +-
.../apache/ignite/internal/compute/PojoJob.java | 8 +-
.../internal/compute/ComputeComponentImpl.java | 6 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 111 +++-
.../internal/compute/IgniteComputeInternal.java | 9 +
.../internal/compute/JobExecutionWrapper.java | 2 +-
...per.java => ResultMarshallingJobExecution.java} | 28 +-
.../compute/executor/ComputeExecutorImpl.java | 56 +-
.../compute/streamer/StreamerReceiverJob.java | 64 ++
.../internal/lang/IgniteExceptionMapperUtil.java | 50 +-
.../apache/ignite/internal/lang/InternalTuple.java | 2 +
.../ignite/internal/type/NativeTypeSpec.java | 18 +-
.../apache/ignite/internal/type/NativeTypes.java | 10 +-
.../ignite/internal/util/HashCalculator.java | 42 --
.../org/apache/ignite/internal/util/ViewUtils.java | 1 +
.../communication/MessageCollectionItemType.java | 6 +-
.../ignite/internal/lang/ExceptionUtilsTest.java | 56 ++
.../internal/testframework/IgniteTestUtils.java | 20 -
.../asserts/CompletableFutureAssert.java | 29 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 18 +-
.../DistributionZoneCausalityDataNodesTest.java | 1 -
.../DistributionZoneRebalanceEngineTest.java | 5 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 5 +-
modules/index/build.gradle | 1 +
.../ignite/internal/index/ItBuildIndexTest.java | 285 ++++-----
.../internal/index/ChangeIndexStatusTask.java | 44 +-
.../index/ChangeIndexStatusTaskController.java | 5 +-
.../index/ChangeIndexStatusTaskScheduler.java | 7 +
.../index/IndexAvailabilityController.java | 13 +-
.../internal/index/IndexBuildController.java | 5 +-
.../internal/index/IndexBuildingManager.java | 9 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 2 +
.../internal/index/ChangeIndexStatusTaskTest.java | 40 +-
.../IndexAvailabilityControllerRestorerTest.java | 2 +-
.../index/IndexAvailabilityControllerTest.java | 12 +-
.../internal/index/IndexBuildControllerTest.java | 2 +
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 3 +-
.../ignite/jdbc/ItJdbcComplexQuerySelfTest.java | 4 +-
.../ignite/internal/marshaller/BinaryMode.java | 2 +
.../internal/marshaller/MarshallerWriter.java | 2 +
.../internal/marshaller/FieldAccessorTest.java | 4 -
.../testobjects/TestObjectWithAllTypes.java | 26 -
.../impl/ItIdempotentCommandCacheTest.java | 6 +-
.../command/MetaStorageWriteCommand.java | 27 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 14 +-
.../metastorage/server/KeyValueStorage.java | 1 -
.../server/raft/MetaStorageWriteHandler.java | 2 +-
.../impl/IdempotentCommandCacheTest.java | 16 +-
.../impl/StandaloneMetaStorageManager.java | 4 +-
.../serialization/BaseMethodNameResolver.java | 7 +-
.../MessageCollectionItemTypeConverter.java | 7 +-
.../network/TrackableNetworkMessageHandler.java | 23 +-
.../internal/network/annotations/Transferable.java | 2 +
.../network/serialization/MessageReader.java | 8 +
.../network/serialization/MessageWriter.java | 10 +
.../network/direct/DirectMessageReader.java | 18 +
.../network/direct/DirectMessageWriter.java | 11 +
.../internal/network/messages/AllTypesMessage.java | 3 +
.../tree/AbstractBplusTreePageMemoryTest.java | 114 +++-
.../tree/AbstractBplusTreeReusePageMemoryTest.java | 7 +-
.../pagememory/datastructure/DataStructure.java | 13 +-
.../internal/pagememory/freelist/FreeListImpl.java | 5 +-
.../internal/pagememory/freelist/PagesList.java | 6 +-
.../ignite/internal/pagememory/tree/BplusTree.java | 26 +-
.../pagememory/freelist/FreeListImplTest.java | 2 +-
.../replicator/ItReplicaLifecycleTest.java | 103 ++-
.../PartitionReplicaLifecycleManager.java | 36 +-
.../replicator/ZonePartitionRaftListener.java | 48 +-
.../replicator/ZonePartitionReplicaListener.java | 94 ++-
.../PartitionCommandsMarshallerImpl.java | 2 +
.../network/PartitionReplicationMessageGroup.java | 6 +
.../network/command/FinishTxCommand.java | 15 +-
.../network/command/TimedBinaryRowMessage.java | 9 +-
.../network/command/UpdateAllCommand.java | 4 +-
.../replicator/network/command/UpdateCommand.java | 8 +-
.../network/command/WriteIntentSwitchCommand.java | 15 +-
...caRequest.java => GetEstimatedSizeRequest.java} | 7 +-
.../ReadOnlyDirectMultiRowReplicaRequest.java | 3 +-
.../ReadOnlyDirectSingleRowReplicaRequest.java | 3 +-
.../ReadOnlyMultiRowPkReplicaRequest.java | 3 +-
.../replication/ReadOnlyReplicaRequest.java | 6 +-
.../ReadOnlyScanRetrieveBatchReplicaRequest.java | 3 +-
.../ReadOnlySingleRowPkReplicaRequest.java | 3 +-
.../ReadWriteMultiRowPkReplicaRequest.java | 3 +-
.../ReadWriteMultiRowReplicaRequest.java | 3 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java | 3 +-
.../ReadWriteSingleRowPkReplicaRequest.java | 3 +-
.../ReadWriteSingleRowReplicaRequest.java | 3 +-
.../ReadWriteSwapRowReplicaRequest.java | 3 +-
.../placementdriver/LeasePlacementDriver.java | 2 +-
.../message/LeaseGrantedMessage.java | 14 +-
.../internal/placementdriver/LeaseUpdater.java | 36 +-
.../placementdriver/leases/LeaseTracker.java | 8 +-
.../negotiation/LeaseAgreement.java | 21 +-
.../negotiation/LeaseNegotiator.java | 33 +-
modules/platforms/build.gradle | 12 +-
modules/platforms/cpp/CMakeLists.txt | 6 +-
.../platforms/cpp/ignite/common/big_decimal.cpp | 10 -
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
.../cpp/ignite/odbc/config/configuration.h | 35 ++
.../cpp/tests/client-test/all_fields_type.h | 3 -
.../client-test/key_value_binary_view_test.cpp | 1 -
.../cpp/tests/client-test/key_value_view_test.cpp | 2 -
.../tests/client-test/record_binary_view_test.cpp | 1 -
.../cpp/tests/client-test/record_view_test.cpp | 2 -
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 7 -
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 1 -
.../Proto/ColocationHashTests.cs | 10 -
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 3 -
.../Table/KeyValueViewPrimitiveTests.cs | 8 -
.../Table/PocoAllColumnsNullable.cs | 2 -
.../Table/RecordViewBinaryTests.cs | 2 -
.../Table/RecordViewPocoTests.cs | 3 -
.../Table/RecordViewPrimitiveTests.cs | 4 -
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
modules/platforms/python/.gitignore | 13 +
modules/platforms/python/CMakeLists.txt | 54 ++
modules/platforms/python/LICENSE | 14 +
modules/platforms/python/MANIFEST.in | 7 +
modules/platforms/python/NOTICE | 5 +
modules/platforms/python/README.md | 48 ++
modules/platforms/python/cpp_module/CMakeLists.txt | 56 ++
modules/platforms/python/cpp_module/module.cpp | 195 ++++++
.../python/cpp_module/module.h} | 17 +-
.../platforms/python/cpp_module/py_connection.cpp | 109 ++++
.../platforms/python/cpp_module/py_connection.h | 70 +++
modules/platforms/python/pyignite3/__init__.py | 149 +++++
modules/platforms/python/requirements/install.txt | 3 +
modules/platforms/python/requirements/tests.txt | 7 +
modules/platforms/python/setup.py | 158 +++++
modules/platforms/python/tests/__init__.py | 14 +
modules/platforms/python/tests/conftest.py | 18 +
modules/platforms/python/tests/test_connect.py | 33 +
modules/platforms/python/tests/util.py | 155 +++++
.../apache/ignite/internal/raft/RaftManager.java | 3 -
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 1 +
.../ignite/raft/jraft/core/MockStateMachine.java | 0
.../apache/ignite/raft/jraft/core/TestCluster.java | 0
.../raft/jraft/core/TestJRaftServiceFactory.java | 0
.../raft/server/counter/GetValueCommand.java | 7 +-
.../server/counter/IncrementAndGetCommand.java | 7 +-
.../counter/IntegrationTestMessageGroup.java} | 11 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 6 -
.../internal/raft/server/impl/JraftServerImpl.java | 12 +-
.../internal/raft/storage/LogStorageFactory.java | 1 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 10 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 5 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 12 +-
.../raft/jraft/storage/impl/RocksDbSpillout.java | 1 +
.../ignite/internal/raft/TestLozaFactory.java | 1 +
.../ignite/raft/messages/TestMessageGroup.java | 7 -
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../apache/ignite/internal/replicator/Replica.java | 9 +
.../ignite/internal/replicator/ReplicaImpl.java | 10 +-
.../ignite/internal/replicator/ReplicaManager.java | 49 +-
.../replicator/ZonePartitionReplicaImpl.java | 8 +-
.../command/SafeTimePropagatingCommand.java | 18 +-
.../message/ReplicationGroupIdMessage.java | 2 +-
.../internal/replicator/message/TableAware.java} | 15 +-
.../replicator/message/TimestampAware.java | 20 +-
.../replicator/PlacementDriverReplicaSideTest.java | 4 +-
.../internal/replicator/ReplicaManagerTest.java | 2 +-
modules/runner/build.gradle | 1 +
.../ignite/internal/benchmark/InsertBenchmark.java | 29 +-
.../runner/app/ItIgniteNodeRestartTest.java | 68 +-
.../runner/app/ItReplicaStateManagerTest.java | 2 -
.../apache/ignite/internal/runner/app/Jobs.java | 309 +++++++++
.../runner/app/PlatformTestNodeRunner.java | 25 -
.../client/ItThinClientComputeMarshallingTest.java | 259 ++++++--
.../runner/app/client/ItThinClientComputeTest.java | 4 -
...tThinClientComputeTypeCheckMarshallingTest.java | 233 +++++++
.../app/compute/ItEmbeddedMarshallingTest.java | 140 +++++
.../ItSchemaForwardCompatibilityTest.java | 49 +-
.../schemasync/ItSchemaSyncSingleNodeTest.java | 27 +-
.../streamer/ItAbstractDataStreamerTest.java | 36 +-
.../streamer/ItServerDataStreamerTest.java | 23 -
.../ignite/internal/table/ItDurableFinishTest.java | 7 +-
.../ignite/internal/table/ItInternalTableTest.java | 10 +-
.../internal/table/ItPublicApiColocationTest.java | 28 +-
.../internal/table/ItThinClientColocationTest.java | 2 -
.../org/apache/ignite/internal/app/IgniteImpl.java | 43 +-
.../ignite/internal/schema/BinaryRowConverter.java | 6 -
.../ignite/internal/schema/BinaryTupleSchema.java | 6 -
.../CatalogToSchemaDescriptorConverter.java | 8 -
.../configuration/ValueSerializationHelper.java | 9 -
.../internal/schema/marshaller/MarshallerUtil.java | 7 -
.../schema/registry/UpgradingRowAdapter.java | 20 +-
.../ignite/internal/schema/row/RowAssembler.java | 13 +-
.../ignite/internal/util/ColocationUtils.java | 10 -
.../schema/AbstractSchemaConverterTest.java | 7 +-
.../org/apache/ignite/internal/schema/RowTest.java | 13 -
.../CatalogToSchemaDescriptorConverterTest.java | 20 +-
.../schema/marshaller/KvMarshallerTest.java | 45 +-
.../schema/marshaller/MarshallerUtilTest.java | 4 -
.../schema/marshaller/RecordMarshallerTest.java | 30 +-
.../schema/registry/UpgradingRowAdapterTest.java | 2 -
.../ignite/internal/schema/BinaryRowMatcher.java | 44 +-
.../ignite/internal/schema/SchemaTestUtils.java | 19 +-
.../internal/sql/engine/ItAlterTableDdlTest.java | 13 +-
.../internal/sql/engine/ItDataTypesTest.java | 19 +-
.../internal/sql/engine/ItFunctionsTest.java | 2 +-
.../sql/engine/datatypes/ItCastToBigintTest.java | 691 +++++++++++++++++++++
.../sql/engine/datatypes/ItCastToIntTest.java | 681 ++++++++++++++++++++
.../sql/engine/datatypes/ItCastToSmallintTest.java | 682 ++++++++++++++++++++
.../sql/engine/datatypes/ItCastToTinyintTest.java | 682 ++++++++++++++++++++
.../datatypes/ItCastToTsWithLocalTimeZoneTest.java | 600 ++++++++++++++++++
.../engine/datatypes/tests/TestTypeArguments.java | 4 +-
.../integrationTest/sql/cast/test_cast_bigint.test | 2 +-
.../integrationTest/sql/cast/test_cast_int.test | 12 +-
.../sql/cast/test_cast_smallint.test | 12 +-
.../sql/cast/test_cast_tinyint.test | 12 +-
.../sql/identifiers/test_long_identifiers.test | 57 +-
.../sql/types/decimal/cast_from_decimal.test | 2 +-
.../sql/types/decimal/cast_to_decimal.test | 2 +-
.../ignite/internal/sql/engine/QueryCancel.java | 5 +
.../sql/engine/exec/ExchangeServiceImpl.java | 2 +-
.../internal/sql/engine/exec/ExecutionContext.java | 19 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 258 ++++----
.../internal/sql/engine/exec/SqlRowHandler.java | 12 +-
.../sql/engine/exec/UpdatableTableImpl.java | 9 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 5 +-
.../internal/sql/engine/externalize/RelJson.java | 10 +
.../sql/engine/message/QueryStartRequest.java | 15 +-
.../engine/prepare/IgniteSqlToRelConvertor.java | 71 ++-
.../sql/engine/prepare/KeyValueGetPlan.java | 11 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 11 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 15 +-
.../internal/sql/engine/rex/IgniteRexBuilder.java | 13 -
.../sql/engine/sql/IgniteSqlCreateTableOption.java | 15 -
.../internal/sql/engine/sql/IgniteSqlParser.java | 63 ++
.../internal/sql/engine/sql/IgniteSqlUpdate.java | 3 +-
.../sql/engine/sql/IgniteSqlZoneOption.java | 15 -
.../internal/sql/engine/sql/ParserServiceImpl.java | 19 +-
.../ignite/internal/sql/engine/util/Commons.java | 20 -
.../internal/sql/engine/util/IgniteMath.java | 140 ++---
.../ignite/internal/sql/engine/util/TypeUtils.java | 19 -
.../sql/engine/exec/ExecutionServiceImplTest.java | 350 +++++++----
.../exec/rel/TableScanNodeExecutionTest.java | 4 +-
.../sql/engine/exec/row/RowSchemaTypesTest.java | 9 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 4 +-
.../sql/engine/framework/ArrayRowHandler.java | 12 -
.../sql/engine/framework/TestBuilders.java | 12 -
.../sql/engine/planner/AbstractPlannerTest.java | 12 +
.../engine/planner/JoinWithUsingPlannerTest.java | 5 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 16 +
.../datatypes/MergeSourcesCoercionTest.java | 532 ++++++++++++++++
.../NumericBinaryOperationsTypeCoercionTest.java | 218 +------
.../NumericComparisonTypeCoercionTest.java | 218 +------
.../NumericInsertSourcesCoercionTest.java | 478 ++++++++++++++
...st.java => NumericSetOperatorCoercionTest.java} | 232 +------
.../NumericUpdateSourcesCoercionTest.java | 516 +++++++++++++++
.../planner/datatypes/utils/NumericPair.java | 54 --
.../sql/engine/planner/datatypes/utils/Types.java | 6 -
.../pruning/PartitionPruningPredicateSelfTest.java | 14 +-
.../engine/schema/SqlSchemaManagerImplTest.java | 6 +-
.../sql/engine/util/EmptyCacheFactory.java | 3 +-
.../sql/engine/util/ProjectedTupleTest.java | 4 +
.../internal/sql/engine/util/NativeTypeValues.java | 5 -
.../internal/sql/engine/util/SqlTestUtils.java | 78 ++-
.../ignite/internal/storage/DataStorageModule.java | 5 +-
.../internal/storage/DataStorageModules.java | 10 +-
.../internal/storage/MvPartitionStorage.java | 1 -
.../storage/index/BinaryTupleComparator.java | 6 -
.../storage/index/StorageIndexDescriptor.java | 4 -
.../internal/storage/DataStorageModulesTest.java | 8 +-
.../storage/index/BinaryTupleComparatorTest.java | 28 -
.../storage/index/StorageIndexDescriptorTest.java | 2 -
.../AbstractMvPartitionStorageConcurrencyTest.java | 15 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 19 +-
.../storage/AbstractMvPartitionStorageTest.java | 305 ++++++---
.../storage/AbstractMvTableStorageTest.java | 85 ++-
.../storage/impl/TestDataStorageModule.java | 6 +-
.../storage/impl/TestMvPartitionStorage.java | 21 +-
.../index/AbstractHashIndexStorageTest.java | 1 -
.../storage/index/AbstractIndexStorageTest.java | 2 -
.../index/AbstractSortedIndexStorageTest.java | 1 -
.../AbstractPageMemoryStorageEngine.java | 43 ++
.../pagememory/AbstractPageMemoryTableStorage.java | 3 +
.../PersistentPageMemoryDataStorageModule.java | 17 +-
.../PersistentPageMemoryStorageEngine.java | 29 +-
.../PersistentPageMemoryTableStorage.java | 16 +-
.../storage/pagememory/StoragePartitionMeta.java | 55 +-
.../pagememory/StoragePartitionMetaFactory.java | 3 +-
.../storage/pagememory/StoragePartitionMetaIo.java | 25 +
.../pagememory/VolatilePageMemoryDataRegion.java | 12 +-
.../VolatilePageMemoryDataStorageModule.java | 20 +-
.../VolatilePageMemoryStorageEngine.java | 30 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 17 +-
.../storage/pagememory/index/InlineUtils.java | 6 +-
.../pagememory/index/hash/HashIndexRow.java | 6 +
.../pagememory/index/hash/HashIndexRowKey.java | 6 +
.../pagememory/index/hash/HashIndexTree.java | 18 +-
.../pagememory/index/meta/IndexMetaKey.java | 7 +
.../pagememory/index/meta/IndexMetaTree.java | 8 +-
.../pagememory/index/sorted/SortedIndexRow.java | 6 +
.../pagememory/index/sorted/SortedIndexTree.java | 21 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 22 +-
.../mv/AddWriteCommittedInvokeClosure.java | 19 +-
.../pagememory/mv/CommitWriteInvokeClosure.java | 50 +-
.../storage/pagememory/mv/IndexStorageFactory.java | 11 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 15 +
.../storage/pagememory/mv/VersionChainTree.java | 10 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 23 +
.../internal/storage/pagememory/mv/gc/GcQueue.java | 10 +-
.../PersistentPageMemoryMvTableStorageTest.java | 20 +-
.../StoragePartitionMetaManagerTest.java | 7 +-
.../pagememory/StoragePartitionMetaTest.java | 48 +-
.../VolatilePageMemoryMvTableStorageTest.java | 17 +-
.../PersistentPageMemoryStorageEngineTest.java | 11 +-
.../storage/pagememory/index/InlineUtilsTest.java | 11 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 7 +-
...PersistentPageMemorySortedIndexStorageTest.java | 7 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 4 +-
.../VolatilePageMemorySortedIndexStorageTest.java | 4 +-
.../AbstractPageMemoryMvPartitionStorageTest.java | 48 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 14 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 7 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 11 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 11 +-
...VolatilePageMemoryMvPartitionStorageGcTest.java | 4 +-
.../VolatilePageMemoryMvPartitionStorageTest.java | 4 +-
.../storage/rocksdb/ColumnFamilyUtils.java | 8 -
.../internal/storage/rocksdb/GarbageCollector.java | 34 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 4 +-
.../storage/rocksdb/RocksDbMetaStorage.java | 8 +
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 114 +++-
.../internal/storage/rocksdb/ThreadLocalState.java | 11 +-
.../rocksdb/instance/SharedRocksDbInstance.java | 2 +
.../RocksDbMvPartitionStorageConcurrencyTest.java | 7 -
.../rocksdb/RocksDbMvPartitionStorageTest.java | 37 --
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 13 -
.../internal/systemview/utils/SystemViewUtils.java | 12 -
.../internal/systemview/SystemViewManagerTest.java | 10 +-
modules/table/build.gradle | 1 +
.../ignite/distributed/ReplicaUnavailableTest.java | 15 +-
.../ReplicasSafeTimePropagationTest.java | 17 +-
.../rebalance/ItRebalanceDistributedTest.java | 26 +-
.../ignite/internal/table/ItColocationTest.java | 13 +-
.../ignite/internal/table/ItEstimatedSizeTest.java | 182 ++++++
.../internal/table/ItTransactionRecoveryTest.java | 11 +-
.../internal/table/ItTxResourcesVacuumTest.java | 4 +-
.../threading/ItKvRecordApiThreadingTest.java | 2 +
.../ignite/internal/table/AbstractTableView.java | 4 +-
.../apache/ignite/internal/table/DataStreamer.java | 2 +-
.../internal/table/IgniteTablesInternal.java | 2 +
.../ignite/internal/table/InternalTable.java | 22 +-
.../internal/table/KeyValueBinaryViewImpl.java | 30 +-
.../ignite/internal/table/KeyValueViewImpl.java | 50 +-
.../table/PublicApiThreadingKeyValueView.java | 2 +-
.../table/PublicApiThreadingRecordView.java | 2 +-
.../internal/table/RecordBinaryViewImpl.java | 30 +-
.../ignite/internal/table/RecordViewImpl.java | 48 +-
.../internal/table/StreamerReceiverRunner.java | 63 ++
.../table/TableExceptionMapperProvider.java} | 17 +-
.../internal/table/distributed/TableManager.java | 263 ++++++--
.../internal/table/distributed/TableUtils.java | 1 -
.../table/distributed/index/IndexMeta.java | 2 +-
.../table/distributed/index/MetaIndexStatus.java | 2 +-
...ava => IncompatibleSchemaVersionException.java} | 18 +-
.../replicator/PartitionReplicaListener.java | 67 +-
.../replicator/SchemaCompatibilityValidator.java | 6 +-
.../StaleTransactionOperationException.java | 5 +-
.../replicator/TransactionStateResolver.java | 2 +-
.../schema/PartitionCommandsMarshallerImpl.java | 2 +
.../distributed/storage/InternalTableImpl.java | 300 ++++++---
...> UpdateCommandsMarshallingMicroBenchmark.java} | 17 +-
.../internal/table/InteropOperationsTest.java | 61 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 10 +-
.../internal/table/KeyValueViewOperationsTest.java | 6 +-
.../internal/table/MutableRowTupleAdapterTest.java | 8 +-
.../internal/table/RecordViewOperationsTest.java | 6 +-
.../table/TableExceptionMapperProviderTest.java | 54 ++
.../distributed/TableManagerRecoveryTest.java | 38 +-
.../table/distributed/TableManagerTest.java | 21 +-
.../PartitionRaftCommandsSerializationTest.java | 17 +-
.../PersistentPageMemoryGcUpdateHandlerTest.java | 7 +-
.../gc/VolatilePageMemoryGcUpdateHandlerTest.java | 3 +-
.../raft/PartitionCommandListenerTest.java | 54 +-
.../PartitionReplicaListenerIndexLockingTest.java | 8 +
.../replication/PartitionReplicaListenerTest.java | 124 ++--
.../SchemaCompatibilityValidatorTest.java | 16 -
.../PartitionCommandsMarshallerImplTest.java | 6 +-
.../storage/InternalTableEstimatedSizeTest.java | 476 ++++++++++++++
.../distributed/storage/InternalTableImplTest.java | 5 +-
.../table/type/NumericTypesSerializerTest.java | 72 +--
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
.../table/impl/DummyValidationSchemasSource.java | 8 -
.../tx/IncompatibleSchemaAbortException.java} | 16 +-
...tchingTransactionOutcomeInternalException.java} | 13 +-
.../tx/TransactionExceptionMapperProvider.java | 6 +
.../internal/tx/TransactionInternalException.java} | 40 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 3 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 3 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 3 +-
.../ignite/internal/tx/TxStateMetaFinishing.java | 3 +-
.../tx/impl/IgniteAbstractTransactionImpl.java | 31 +-
.../internal/tx/impl/TransactionInflights.java | 4 +-
.../tx/impl/TransactionsExceptionMapperUtil.java | 85 +++
.../internal/tx/impl/TxCleanupRequestHandler.java | 6 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 17 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 21 +-
.../tx/message/TransactionMetaMessage.java | 11 +-
.../internal/tx/message/TxCleanupMessage.java | 19 +-
.../tx/message/TxFinishReplicaRequest.java | 22 +-
.../tx/message/TxStateCoordinatorRequest.java | 8 +-
.../message/WriteIntentSwitchReplicaRequest.java | 19 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 12 +-
settings.gradle | 2 +
511 files changed, 13624 insertions(+), 4624 deletions(-)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/ByteArrayMarshaler.java
=> marshalling/ByteArrayMarshaller.java} (65%)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/JavaSerializationByteArrayMarshallilng.java
=> marshalling/JavaSerializationByteArrayMarshalling.java} (96%)
rename modules/api/src/main/java/org/apache/ignite/{marshaling/Marshaler.java
=> marshalling/Marshaller.java} (75%)
rename modules/api/src/main/java/org/apache/ignite/{marshaling =>
marshalling}/MarshallingException.java (97%)
copy modules/api/src/main/java/org/apache/ignite/{marshaling =>
marshalling}/TupleMarshaller.java (88%)
rename
modules/api/src/main/java/org/apache/ignite/{marshaling/UnsupportedObjectTypeMarshalingException.java
=> marshalling/UnsupportedObjectTypeMarshallingException.java} (81%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication/ReadOnlyScanRetrieveBatchReplicaRequest.java
=> api/src/main/java/org/apache/ignite/tx/IncompatibleSchemaException.java}
(52%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal =>
api/src/main/java/org/apache/ignite}/tx/MismatchingTransactionOutcomeException.java
(53%)
rename
modules/api/src/test/java/org/apache/ignite/{marshaling/ByteArrayMarshalerTest.java
=> marshalling/ByteArrayMarshallerTest.java} (76%)
create mode 100644 modules/catalog-compaction/README.md
copy modules/{compute => catalog-compaction}/build.gradle (57%)
rename
modules/{catalog/src/integrationTest/java/org/apache/ignite/internal/catalog =>
catalog-compaction/src/integrationTest/java/org/apache/ignite/internal/catalog/compaction}/ItCatalogCompactionCoordinatorChoosingTest.java
(93%)
create mode 100644
modules/catalog-compaction/src/main/java/org/apache/ignite/internal/catalog/compaction/CatalogCompactionRunner.java
copy
modules/{raft/src/testFixtures/java/org/apache/ignite/raft/messages/TestMessageGroup.java
=>
catalog-compaction/src/main/java/org/apache/ignite/internal/catalog/compaction/message/CatalogCompactionMessageGroup.java}
(59%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication/ReadWriteSwapRowReplicaRequest.java
=>
catalog-compaction/src/main/java/org/apache/ignite/internal/catalog/compaction/message/CatalogMinimumRequiredTimeRequest.java}
(68%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateCoordinatorRequest.java
=>
catalog-compaction/src/main/java/org/apache/ignite/internal/catalog/compaction/message/CatalogMinimumRequiredTimeResponse.java}
(64%)
create mode 100644
modules/catalog-compaction/src/test/java/org/apache/ignite/internal/catalog/compaction/CatalogCompactionRunnerSelfTest.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{JobExecutionWrapper.java
=> ResultMarshallingJobExecution.java} (62%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/streamer/StreamerReceiverJob.java
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication/{ReadWriteScanRetrieveBatchReplicaRequest.java
=> GetEstimatedSizeRequest.java} (78%)
create mode 100644 modules/platforms/python/.gitignore
create mode 100644 modules/platforms/python/CMakeLists.txt
create mode 100644 modules/platforms/python/LICENSE
create mode 100644 modules/platforms/python/MANIFEST.in
create mode 100644 modules/platforms/python/NOTICE
create mode 100644 modules/platforms/python/README.md
create mode 100644 modules/platforms/python/cpp_module/CMakeLists.txt
create mode 100644 modules/platforms/python/cpp_module/module.cpp
copy
modules/{api/src/main/java/org/apache/ignite/marshaling/TupleMarshaller.java =>
platforms/python/cpp_module/module.h} (71%)
create mode 100644 modules/platforms/python/cpp_module/py_connection.cpp
create mode 100644 modules/platforms/python/cpp_module/py_connection.h
create mode 100644 modules/platforms/python/pyignite3/__init__.py
create mode 100644 modules/platforms/python/requirements/install.txt
create mode 100644 modules/platforms/python/requirements/tests.txt
create mode 100644 modules/platforms/python/setup.py
create mode 100644 modules/platforms/python/tests/__init__.py
create mode 100644 modules/platforms/python/tests/conftest.py
create mode 100644 modules/platforms/python/tests/test_connect.py
create mode 100644 modules/platforms/python/tests/util.py
rename modules/raft/src/{testFixtures =>
integrationTest}/java/org/apache/ignite/raft/jraft/core/MockStateMachine.java
(100%)
rename modules/raft/src/{testFixtures =>
integrationTest}/java/org/apache/ignite/raft/jraft/core/TestCluster.java (100%)
rename modules/raft/src/{testFixtures =>
integrationTest}/java/org/apache/ignite/raft/jraft/core/TestJRaftServiceFactory.java
(100%)
rename modules/raft/src/{testFixtures =>
integrationTest}/java/org/apache/ignite/raft/server/counter/GetValueCommand.java
(76%)
rename modules/raft/src/{testFixtures =>
integrationTest}/java/org/apache/ignite/raft/server/counter/IncrementAndGetCommand.java
(76%)
copy
modules/raft/src/{testFixtures/java/org/apache/ignite/raft/messages/TestMessageGroup.java
=>
integrationTest/java/org/apache/ignite/raft/server/counter/IntegrationTestMessageGroup.java}
(77%)
rename
modules/{api/src/main/java/org/apache/ignite/marshaling/TupleMarshaller.java =>
replicator/src/main/java/org/apache/ignite/internal/replicator/message/TableAware.java}
(72%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/Jobs.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientComputeTypeCheckMarshallingTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/compute/ItEmbeddedMarshallingTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/ItCastToBigintTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/ItCastToIntTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/ItCastToSmallintTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/ItCastToTinyintTest.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/datatypes/ItCastToTsWithLocalTimeZoneTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/MergeSourcesCoercionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/NumericInsertSourcesCoercionTest.java
rename
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/{SetOperatorCoercionTest.java
=> NumericSetOperatorCoercionTest.java} (74%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/datatypes/NumericUpdateSourcesCoercionTest.java
create mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/AbstractPageMemoryStorageEngine.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItEstimatedSizeTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/StreamerReceiverRunner.java
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionExceptionMapperProvider.java
=>
table/src/main/java/org/apache/ignite/internal/table/TableExceptionMapperProvider.java}
(69%)
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/{IncompatibleSchemaException.java
=> IncompatibleSchemaVersionException.java} (76%)
rename
modules/table/src/test/java/org/apache/ignite/internal/benchmarks/{UpdateCommandsMarshalingMicroBenchmark.java
=> UpdateCommandsMarshallingMicroBenchmark.java} (91%)
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/TableExceptionMapperProviderTest.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/storage/InternalTableEstimatedSizeTest.java
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/replication/ReadOnlyReplicaRequest.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/IncompatibleSchemaAbortException.java}
(56%)
rename
modules/transactions/src/main/java/org/apache/ignite/internal/tx/{MismatchingTransactionOutcomeException.java
=> MismatchingTransactionOutcomeInternalException.java} (79%)
copy modules/{api/src/main/java/org/apache/ignite/tx/TransactionException.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/TransactionInternalException.java}
(69%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TransactionsExceptionMapperUtil.java
