You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2020/11/20 07:54:52 UTC
[iotdb] branch change_listener_to_visitor updated (9257493 ->
003c4ba)
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch change_listener_to_visitor
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 9257493 fix bug
add 07ab57d fix filechannal force and interrupting-related exception(#2038)
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)
add 6fcc4b8 Fix thread safety issues in SyncServerManager (#2027)
add 3969132 Refactor LastQueryExecutor to separate the execution into multiple stages
add 370a06b Fix codesmell
add 26508e9 Fix some issues
add 9b2e4ab Fix review issues
add 12f569d Fix error in MTree
add e646559 Fix test case error
add b9fc750 codesmell fix
add 6aad5c7 Merge pull request #2063 from wshao08/last_mod
add f2e9161 set max open file in linux (#2071)
add 50b6b79 fix level compaction recover file not exist bug (#2067)
add 65b5aa5 change tsfile size threshold (#2068)
add 5f287ae [IOTDB-1012] Remove unfriendly query process error for users (#2062)
add 344c387 Update level compaction delete and change list lock (#2070)
add 209f5e4 Using contains instead of indexOf to be more readable in ServerArgument (#2075)
add 3e2a9da Remove all useless semicolons (#2077)
add 4a0c4f7 Using method reference instead of Lambda to be more readable in MetricsSystem (#2076)
add a7f14ef [IOTDB-1015] Add document for session query API and examples for align by device (#2072)
add ff6f352 fix series bug
add e43a812 Merge pull request #2073 from Alima777/iotdb1016
add cd58f4b Merge branch 'master' into change_listener_to_visitor
add 0451eb7 update index
add 003c4ba resolve conflict
No new revisions were added by this update.
Summary of changes:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 51 ++++--
.../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 ++-
docs/UserGuide/Client/Programming - Native API.md | 22 ++-
.../DML Data Manipulation Language.md | 12 +-
.../UserGuide/Client/Programming - Native API.md | 18 ++
.../DML Data Manipulation Language.md | 14 +-
.../resources/conf/iotdb-engine.properties | 35 +++-
server/src/assembly/resources/sbin/start-server.sh | 2 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 81 ++++++++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 +++
.../db/conf/directories/DirectoryManager.java | 4 +
.../level/LevelCompactionTsFileManagement.java | 41 +++--
.../engine/compaction/utils/CompactionUtils.java | 3 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 1 -
.../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 +--
.../org/apache/iotdb/db/metadata/MLogWriter.java | 1 +
.../java/org/apache/iotdb/db/metadata/MTree.java | 15 +-
.../iotdb/db/metadata/MetadataOperationType.java | 2 +
.../iotdb/db/metrics/server/MetricsSystem.java | 6 +-
.../iotdb/db/metrics/server/ServerArgument.java | 8 +-
.../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 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 21 +++
.../CreateIndexOperator.java} | 43 ++---
...oveFileOperator.java => DropIndexOperator.java} | 29 +--
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 12 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 2 +-
.../physical/crud/QueryIndexPlan.java} | 48 +++--
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 182 +++++++++++++++++++
...eteStorageGroupPlan.java => DropIndexPlan.java} | 88 ++++++---
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 172 +++++++++++++++++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 23 ++-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 14 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 15 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 199 ++++++++++++---------
.../db/query/executor/fill/LastPointReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 16 +-
.../iotdb/db/service/thrift/ThriftService.java | 6 +-
.../db/tools/watermark/WatermarkDetector.java | 1 -
.../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/integration/IOTDBGroupByIT.java | 2 +-
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../iotdb/db/integration/IoTDBAggregationIT.java | 8 +-
.../integration/IoTDBAggregationLargeDataIT.java | 4 +-
.../integration/IoTDBAggregationSmallDataIT.java | 4 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 10 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 2 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 2 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 2 +-
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 2 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 2 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 4 +-
.../iotdb/db/integration/IoTDBRecoverIT.java | 6 +-
.../db/integration/IoTDBRecoverUnclosedIT.java | 2 +-
.../iotdb/db/qp/plan/IndexLogicalPlanTest.java | 156 ++++++++++++++++
.../qp/plan/IndexSubMatchingPhysicalPlanTest.java | 160 +++++++++++++++++
.../plan/IndexWholeMatchingPhysicalPlanTest.java | 154 ++++++++++++++++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 18 +-
server/src/test/resources/iotdb-engine.properties | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../java/org/apache/iotdb/session/Session.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 23 +++
.../iotdb/tsfile/read/ReadInPartitionTest.java | 4 +-
87 files changed, 1752 insertions(+), 373 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/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