You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2022/10/18 13:25:25 UTC
[ignite-3] branch ignite-17748 updated (6476d660ae -> 5f0243c7ab)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17748
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 6476d660ae fix imports.
add 391660c691 IGNITE-17923 Remove PartitionStorage and its tests (#1222)
add d7a04885a7 IGNITE-17840 .NET: Allow null args in SQL and Compute (#1221)
add 9533299e7a IGNITE-17210 Changed data region documentation to remove config (#1184)
add debe65d3f6 IGNITE-17888 Meta-storage commands reimplemented as Transferable classes (#1223)
add 05f3f463d1 IGNITE-17820 SQL. Add native support for SEARCH/SARG operator (#1176)
add 5f0243c7ab Merge branch 'main' into ignite-17748
No new revisions were added by this update.
Summary of changes:
docs/_docs/config/data-region.adoc | 48 +-
.../requests/sql/ClientSqlExecuteRequest.java | 6 +
modules/metastorage-client/build.gradle | 2 +-
.../internal/metastorage/client/CursorImpl.java | 21 +-
.../metastorage/client/MetaStorageServiceImpl.java | 204 ++++--
modules/metastorage-common/build.gradle | 6 +
modules/metastorage-common/pom.xml | 37 ++
.../common/{command => }/OperationInfo.java | 54 +-
.../internal/metastorage/common/StatementInfo.java | 56 +-
.../metastorage/common/StatementResultInfo.java | 23 +-
.../internal/metastorage/common/UpdateInfo.java | 32 +-
.../common/command/CompoundConditionInfo.java | 47 +-
.../metastorage/common/command/ConditionInfo.java | 3 +-
.../metastorage/common/command/ErrorResponse.java | 44 --
.../metastorage/common/command/GetAllCommand.java | 59 +-
.../common/command/GetAndPutAllCommand.java | 53 +-
.../common/command/GetAndPutCommand.java | 34 +-
.../common/command/GetAndRemoveAllCommand.java | 29 +-
.../common/command/GetAndRemoveCommand.java | 24 +-
.../metastorage/common/command/GetCommand.java | 47 +-
.../metastorage/common/command/IfInfo.java | 40 +-
.../metastorage/common/command/InvokeCommand.java | 40 +-
.../command/MetastorageCommandsMessageGroup.java | 114 ++++
.../common/command/MultiInvokeCommand.java | 21 +-
.../metastorage/common/command/PutAllCommand.java | 47 +-
.../metastorage/common/command/PutCommand.java | 34 +-
.../metastorage/common/command/RangeCommand.java | 192 +-----
.../common/command/RemoveAllCommand.java | 29 +-
.../metastorage/common/command/RemoveCommand.java | 24 +-
.../common/command/SimpleConditionInfo.java | 50 +-
.../common/command/WatchExactKeysCommand.java | 89 +--
.../common/command/WatchRangeKeysCommand.java | 86 +--
.../common/command/cursor/CursorCloseCommand.java | 24 +-
.../command/cursor/CursorHasNextCommand.java | 24 +-
.../common/command/cursor/CursorNextCommand.java | 24 +-
.../common/command/cursor/CursorsCloseCommand.java | 24 +-
.../metastorage/common/ConditionTypeTest.java | 60 ++
.../metastorage/common/OperationTypeTest.java} | 20 +-
.../common/command/CompoundConditionTypeTest.java} | 17 +-
modules/metastorage-server/build.gradle | 1 +
.../server/raft/MetaStorageListener.java | 22 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 12 +-
.../dotnet/Apache.Ignite.Tests/ListLogger.cs | 2 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 35 +
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 8 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 12 +-
.../Internal/Proto/MessagePackWriterExtensions.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 4 +-
.../dotnet/Apache.Ignite/Log/CategoryLogger.cs | 2 +-
.../dotnet/Apache.Ignite/Log/ConsoleLogger.cs | 2 +-
.../dotnet/Apache.Ignite/Log/IIgniteLogger.cs | 2 +-
.../dotnet/Apache.Ignite/Log/LoggerExtensions.cs | 24 +-
modules/platforms/dotnet/Apache.Ignite/Sql/ISql.cs | 4 +-
.../runner/app/client/ItThinClientComputeTest.java | 6 +-
.../sql/engine/exec/AbstractIndexScan.java | 62 +-
.../sql/engine/exec/LogicalRelImplementor.java | 28 +-
.../sql/engine/exec/RuntimeSortedIndex.java | 62 +-
.../ignite/internal/sql/engine/exec/TreeIndex.java | 4 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 13 +
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 261 +++++++-
.../exp/{BiScalar.java => RangeCondition.java} | 22 +-
.../exec/exp/{Scalar.java => RangeIterable.java} | 7 +-
.../sql/engine/exec/rel/IndexScanNode.java | 97 ++-
.../sql/engine/exec/rel/IndexSpoolNode.java | 7 +-
.../sql/engine/externalize/RelInputEx.java | 10 +
.../internal/sql/engine/externalize/RelJson.java | 61 +-
.../sql/engine/externalize/RelJsonReader.java | 7 +
.../sql/engine/metadata/IgniteMdSelectivity.java | 40 +-
.../sql/engine/prepare/IgnitePrograms.java | 2 +
.../bounds/ExactBounds.java} | 38 +-
.../bounds/MultiBounds.java} | 40 +-
.../sql/engine/prepare/bounds/RangeBounds.java | 126 ++++
.../sql/engine/prepare/bounds/SearchBounds.java | 66 ++
.../internal/sql/engine/rel/AbstractIndexScan.java | 80 +--
.../internal/sql/engine/rel/IgniteIndexScan.java | 16 +-
.../sql/engine/rel/IgniteSortedIndexSpool.java | 30 +-
.../engine/rel/ProjectableFilterableTableScan.java | 9 +-
.../engine/rel/logical/IgniteLogicalIndexScan.java | 22 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 46 +-
.../sql/engine/rule/LogicalScanConverterRule.java | 2 +-
.../engine/rule/logical/FilterScanMergeRule.java | 18 +-
.../internal/sql/engine/util/IndexConditions.java | 151 -----
.../ignite/internal/sql/engine/util/RexUtils.java | 449 ++++++++-----
.../sql/engine/exec/RuntimeSortedIndexTest.java | 2 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 55 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 54 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 28 +-
.../planner/ProjectFilterScanMergePlannerTest.java | 24 +-
.../planner/SortedIndexSpoolPlannerTest.java | 85 +--
modules/storage-api/README.md | 4 +-
.../apache/ignite/internal/storage/DataRow.java | 35 -
.../ignite/internal/storage/InvokeClosure.java | 61 --
.../ignite/internal/storage/OperationType.java | 30 -
.../ignite/internal/storage/PartitionStorage.java | 162 -----
.../apache/ignite/internal/storage/SearchRow.java | 36 -
.../internal/storage/basic/BinarySearchRow.java | 54 --
.../internal/storage/basic/DelegatingDataRow.java | 94 ---
.../storage/basic/DeleteExactInvokeClosure.java | 71 --
.../storage/basic/GetAndRemoveInvokeClosure.java | 68 --
.../storage/basic/GetAndReplaceInvokeClosure.java | 91 ---
.../storage/basic/InsertInvokeClosure.java | 70 --
.../storage/basic/ReplaceExactInvokeClosure.java | 77 ---
.../internal/storage/basic/SimpleDataRow.java | 93 ---
.../storage/basic/SimpleReadInvokeClosure.java | 60 --
.../storage/basic/SimpleRemoveInvokeClosure.java | 45 --
.../storage/basic/SimpleWriteInvokeClosure.java | 57 --
.../internal/storage/engine/StorageEngine.java | 13 -
.../internal/storage/engine/TableStorage.java | 93 ---
.../storage/AbstractPartitionStorageTest.java | 723 ---------------------
.../distributed/ItInternalTableScanTest.java | 5 +-
.../table/distributed/raft/PartitionListener.java | 15 -
111 files changed, 2105 insertions(+), 3802 deletions(-)
rename modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/{command => }/OperationInfo.java (58%)
delete mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/ErrorResponse.java
create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/MetastorageCommandsMessageGroup.java
create mode 100644 modules/metastorage-common/src/test/java/org/apache/ignite/internal/metastorage/common/ConditionTypeTest.java
copy modules/metastorage-common/src/{main/java/org/apache/ignite/internal/metastorage/common/OperationType.java => test/java/org/apache/ignite/internal/metastorage/common/OperationTypeTest.java} (67%)
copy modules/metastorage-common/src/{main/java/org/apache/ignite/internal/metastorage/common/command/ConditionInfo.java => test/java/org/apache/ignite/internal/metastorage/common/command/CompoundConditionTypeTest.java} (69%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{BiScalar.java => RangeCondition.java} (65%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{Scalar.java => RangeIterable.java} (83%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{session/SessionId.java => prepare/bounds/ExactBounds.java} (65%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{session/SessionId.java => prepare/bounds/MultiBounds.java} (61%)
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/bounds/RangeBounds.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/bounds/SearchBounds.java
delete mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/IndexConditions.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/DataRow.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/InvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/OperationType.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/PartitionStorage.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/SearchRow.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/BinarySearchRow.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/DelegatingDataRow.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/DeleteExactInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/GetAndRemoveInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/GetAndReplaceInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/InsertInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/ReplaceExactInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleDataRow.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleReadInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleRemoveInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleWriteInvokeClosure.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/TableStorage.java
delete mode 100644 modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/AbstractPartitionStorageTest.java