This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch memtable_sort_in_query
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f6b0d91 add test
add b84c5a6 fix level compaction file not exist bug (#2061)
add 7fb0d5e [IOTDB-990] cli parameter maxPRC shouldn't to be set zero
(#2045)
add 84de3f8 change some mem control default parameters (#2054)
add 1229b86 [IoTDB-804] Index framework: from SQL to PhysicalPlan (#2024)
new a57e27b Merge branch 'master' of https://github.com/apache/iotdb into
memtable_sort_in_query
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 52 +++--
.../java/org/apache/iotdb/cli/AbstractCli.java | 9 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 2 +-
cli/src/main/java/org/apache/iotdb/cli/WinCli.java | 8 +-
.../java/org/apache/iotdb/cli/AbstractCliIT.java | 29 ++-
.../resources/conf/iotdb-engine.properties | 31 ++-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 79 ++++++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 ++
.../db/conf/directories/DirectoryManager.java | 4 +
.../engine/compaction/utils/CompactionUtils.java | 3 +
.../exception/index/DistanceMetricException.java | 9 +-
.../index/IllegalIndexParamException.java | 9 +-
.../db/exception/index/IndexManagerException.java | 20 +-
.../IndexRuntimeException.java} | 15 +-
.../db/exception/index/QueryIndexException.java | 15 +-
.../index/UnsupportedIndexTypeException.java | 16 +-
.../iotdb/db/index/common/IndexConstant.java | 22 +-
.../apache/iotdb/db/index/common/IndexType.java | 87 ++++++++
.../apache/iotdb/db/index/common/IndexUtils.java | 25 ++-
.../iotdb/db/metadata/MetadataOperationType.java | 2 +
.../main/java/org/apache/iotdb/db/qp/Planner.java | 5 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 5 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 7 +
.../org/apache/iotdb/db/qp/logical/Operator.java | 3 +-
...teDataOperator.java => QueryIndexOperator.java} | 32 +--
.../CreateIndexOperator.java} | 43 ++--
...oveFileOperator.java => DropIndexOperator.java} | 29 +--
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 12 +-
.../physical/crud/QueryIndexPlan.java} | 48 +++--
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 182 ++++++++++++++++
...eteStorageGroupPlan.java => DropIndexPlan.java} | 88 ++++++--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 229 ++++++++++++++++++++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 23 +++
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 15 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 5 +
.../db/utils/datastructure/BooleanTVList.java | 5 +
.../iotdb/db/utils/datastructure/DoubleTVList.java | 5 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 5 +
.../iotdb/db/utils/datastructure/IntTVList.java | 5 +
.../iotdb/db/utils/datastructure/LongTVList.java | 5 +
.../iotdb/db/utils/datastructure/TVList.java | 5 +
.../iotdb/db/qp/plan/IndexLogicalPlanTest.java | 156 ++++++++++++++
.../qp/plan/IndexSubMatchingPhysicalPlanTest.java | 160 ++++++++++++++
.../plan/IndexWholeMatchingPhysicalPlanTest.java | 154 ++++++++++++++
server/src/test/resources/iotdb-engine.properties | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 23 +++
48 files changed, 1523 insertions(+), 197 deletions(-)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/NotCompatibleTsFileException.java
=>
server/src/main/java/org/apache/iotdb/db/exception/index/DistanceMetricException.java
(77%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/NotCompatibleTsFileException.java
=>
server/src/main/java/org/apache/iotdb/db/exception/index/IllegalIndexParamException.java
(77%)
copy
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
=>
server/src/main/java/org/apache/iotdb/db/exception/index/IndexManagerException.java
(64%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{runtime/RPCServiceException.java
=> index/IndexRuntimeException.java} (72%)
copy
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
=>
server/src/main/java/org/apache/iotdb/db/exception/index/QueryIndexException.java
(70%)
copy
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
=>
server/src/main/java/org/apache/iotdb/db/exception/index/UnsupportedIndexTypeException.java
(63%)
copy
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
=> server/src/main/java/org/apache/iotdb/db/index/common/IndexConstant.java
(63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
copy
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTSerializationSchema.java
=> server/src/main/java/org/apache/iotdb/db/index/common/IndexUtils.java (67%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{DeleteDataOperator.java
=> QueryIndexOperator.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/{crud/InsertOperator.java
=> sys/CreateIndexOperator.java} (57%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{RemoveFileOperator.java
=> DropIndexOperator.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/cache/AccountableString.java
=> qp/physical/crud/QueryIndexPlan.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateIndexPlan.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{DeleteStorageGroupPlan.java
=> DropIndexPlan.java} (50%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/plan/IndexLogicalPlanTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/plan/IndexSubMatchingPhysicalPlanTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/plan/IndexWholeMatchingPhysicalPlanTest.java
