You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/11/19 04:28:02 UTC
[iotdb] branch cluster_new updated (f3fda74 -> e960c36)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f3fda74 Merge pull request #2059 from neuyilan/apache_cluster_new_1116_thread_pool_fix
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 e960c36 Merge branch 'master' into cluster_new
No new revisions were added by this update.
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 ++-
.../cluster/client/sync/SyncClientAdaptor.java | 13 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 30 ++-
.../query/last/ClusterLastQueryExecutor.java | 133 +++++++-----
.../iotdb/cluster/utils/ClusterQueryUtils.java | 8 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 6 +-
.../resources/conf/iotdb-engine.properties | 35 +++-
server/src/assembly/resources/sbin/start-server.sh | 2 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../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 +
.../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 ++-
.../java/org/apache/iotdb/db/metadata/MTree.java | 15 +-
.../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 +++--
.../db/qp/physical/crud/RawDataQueryPlan.java | 3 +
.../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 | 25 ++-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 15 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 15 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 200 ++++++++++--------
.../iotdb/db/service/thrift/ThriftService.java | 6 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 112 ++++++----
.../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 +
.../apache/iotdb/db/integration/IoTDBLastIT.java | 2 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +-
.../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 +
thrift/src/main/thrift/cluster.thrift | 11 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 23 +++
64 files changed, 1912 insertions(+), 415 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