This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/feature/show_datanodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c9dd5fc805 fix confignode.thrift bug
add 95884ad6b9 [IOTDB-3277] [IOTDB-3310] [IOTDB-3311] Fix some SQL parser
bugs in new cluster (#6060)
add 31e5893900 [IOTDB-3315] Make unset of ttl in cluster mode same as
0.13.0 version. (#6061)
add 23bb94e2e5 [IOTDB-3271] Wrong multi IP for one sender in receiver
(#6037)
add bb1a88540d [ISSUES-6057] Add a method(getAllDataRegionID) to
StorageEngineV2 (#6059)
add fcb27a8449 [IOTDB-3228] UDF Management in MPP Cluster: DROP FUNCTION
(#6064)
add 4f101d8acf [IOTDB-3246]Improve Validation tool (#6066)
add e1dfec58e3 [IOTDB-3320] Don't return data which are not satisfied with
time filter in last query (#6068)
add 88426aa3e3 [IOTDB-3319] fix IndexOutOfBoundsException when executing
linear fill in group by query (#6070)
add 8500eb9cd1 Fix aligned data in memory query bug (#6065)
add c84095d093 [IOTDB-3325] Thrown an exception when using group by in raw
data query (#6077)
add 221e5fc871 Merge branch 'master' into beyyes/feature/show_datanodes
add 3bbaa201b4 perfect the code of show cluster command, make code tidy by
some pr comments
add 2a0857b3f2 merge with master, make code tidy by some pr comments
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 14 ++-
.../confignode/client/AsyncDataNodeClientPool.java | 19 +++-
...Handler.java => FunctionManagementHandler.java} | 6 +-
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 1 +
...eleteProcedureReq.java => DropFunctionReq.java} | 38 +++----
.../iotdb/confignode/manager/ConfigManager.java | 8 ++
.../apache/iotdb/confignode/manager/Manager.java | 2 +
.../iotdb/confignode/manager/UDFManager.java | 59 +++++++++--
.../iotdb/confignode/persistence/UDFInfo.java | 25 ++++-
.../executor/ConfigRequestExecutor.java | 3 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 ++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 5 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 7 +-
.../udf/service/UDFRegistrationService.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +++
.../apache/iotdb/db/engine/StorageEngineV2.java | 11 +-
.../SmoothQueueSlidingWindowAggregator.java | 1 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 4 +-
.../operator/process/LinearFillOperator.java | 3 +-
.../operator/process/UpdateLastCacheOperator.java | 5 +
.../plan/execution/config/ConfigTaskVisitor.java | 7 ++
...eateFunctionTask.java => DropFunctionTask.java} | 38 ++-----
.../mpp/plan/execution/config/ShowClusterTask.java | 74 ++++++-------
.../execution/config/ShowStorageGroupTask.java | 7 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 5 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 115 ++++++++++++++++++---
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 21 ++--
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 4 +
...onStatement.java => DropFunctionStatement.java} | 21 +---
.../query/reader/chunk/MemAlignedPageReader.java | 10 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 24 ++---
.../service/thrift/impl/InternalServiceImpl.java | 12 +++
.../db/sync/sender/service/TransportHandler.java | 5 +-
.../db/sync/transport/client/TransportClient.java | 21 ++--
.../db/tools/validate/TsFileValidationTool.java | 13 ++-
.../iotdb/db/engine/StorageEngineV2Test.java | 71 +++++++++++++
.../execution/operator/LinearFillOperatorTest.java | 113 +++++++++++++++++++-
.../db/sync/transport/TransportServiceTest.java | 8 +-
.../src/main/thrift/confignode.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 11 ++
42 files changed, 621 insertions(+), 218 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{CreateFunctionHandler.java
=> FunctionManagementHandler.java} (89%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteProcedureReq.java
=> DropFunctionReq.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{CreateFunctionTask.java
=> DropFunctionTask.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> DropFunctionStatement.java} (76%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/StorageEngineV2Test.java