This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-3771
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b24d08546f fix ci
add 58048ecfa6 exclude md5 file when get latest snapshot (#6704)
add 882398b025 Update go client submodule commits for CI (#6732)
add 2c190fc60f [IOTDB-3889]List Privileges Role on Path cannot display a
wider range path pattern (#6718)
add 6d4d8c0d73 [IOTDB-3721] Keep each FI's execution timeout consistent
with timeout set in session (#6663)
add f465aac433 IOTDB-3901 C++ client method of insertRecordsOfOneDevice
sorting optimization (#6734)
add abbf3bfe9f Place the addMetrics for configManager after
setUpInternalServices (#6705)
add 62a80790a1 Update README_ZH.md (#6738)
add 7b595aefe4 Refine the Retry logic for QueryExecution because of
Execption changed. (#6737)
add 2e04339943 [IOTDB-3883] Support Order By timeseries in last query
(part1 - support SQL) (#6728)
add 5721496be8 [IOTDB-3624] Meet error when inserting data in SQL without
timestamp (#6642)
add 67d78fe47b [IOTDB-3827]support partition cache for query. (#6673)
add bafcd5b206 fix IOTDB-3899 (#6731)
add 53a15c5a6c Bump jetty.version from 9.4.35.v20201120 to
9.4.48.v20220622 (#6726)
add 6ad9f83cc1 [IOTDB-3881] strength the concurrency control of
regionReplicaSetCache. (#6708)
add 3b986fb935 [IoTDB-3842] Fix the issue that GroupByLevel cannot use
value filter
add 1ffe93cb27 [IOTDB-3815] replace remove data node to procedure (#6736)
add dfcb0a8903 fix timeout problem while using cli (#6741)
add 842105470d [IOTDB-3880] Optimize asyncclientpool retry logic (#6735)
add e429f89e7a update metric of confignode's number (#6754)
add d4b41bbb71 Modified the processing of metrics for collecting the
number of storage groups (#6749)
add d3e71a2b38 [IOTDB-3593] Broadcast latest ConfigNodeGroup (#6744)
add bd1894fb72 fix the potential issue for StateTracker that it cannot be
terminated sometimes (#6755)
add 3d73b16fbf [IOTDB-3848] Clear up thrift defined data structures of
cluster tools (#6716)
add 2b7dc520a7 [IOTDB-3723] Replace FilterOperator with
FilterAndProjectOperator and use batch processing for better performance (#6714)
add 159bdef59d [IOTDB-3954] Show datanodes shows nothing
add d7cb849abd Minor Grammar Changes to README.md (#6760)
add 6fceff0236 [IOTDB-3626] Fix wrong row count in UDTFAlignByTimeQueryIT
add f4d1323f11 [IOTDB-3938] Avoid performance decline caused by fsync
twice (#6769)
add c735a127b9 [IOTDB-3578] Support core requirements of template (#6750)
add 878de3a2a4 [IOTDB-3797] Print detailed info when failed opening
session (#6765)
add 22f2866325 [IOTDB-3777]Avoid holding sg write lock in the whole
processin of deletion (#6743)
add 6d3c0cc4d0 [IOTDB-3945] Fix TTL doesn't take effect bug in mpp
add 5fa8a67f36 [IOTDB-3967]fix-bug for user permission info (#6776)
add f3c61e8543 [IOTDB-3958] Add error logging in thread pool (#6772)
add 975eaa5bd2 [IOTDB-3937] Fix the initialization of IoTDB Reporter in
metric framework. (#6784)
add 91ce731bd8 Fix sendAsyncRequestToDataNode() method. (#6785)
add 7564963654 Fix bug in FunctionExpression
updateStatisticsForMemoryAssigner
add 4f6b0e72e3 Fix IoTDBInsertWithoutTimeIT failure on CI (#6790)
add c31eb3cb34 [IOTDB-3934] Compatibility of Apache IoTDB with
InfluxDB——example client (#6757)
add 9babfd35de [IOTDB-3952] Delete duplicated time filter in
FilterOperator (#6780)
add 159f669103 [IOTDB-3942] Support count timeseries where tag1 = v1
(#6763)
add 323808c2e4 [IOTDB-3977] Solve the problem of permission type lower
case execution failure when granting permission (#6794)
add 3bc0bf50c3 [IOTDB-3865] Add Cluster tool show confignodes (#6781)
add 7c0a6209b9 [IOTDB-3975]refactoring cache from authorityFetcher (#6791)
add 82e984baf2 [IOTDB-3947] LeaderPolicy can't broadcast when a DataNode
down (#6777)
add acce8c4631 [IOTDB-3781] Reinforce the regionCleaner task's startup
logic (#6804)
add a354fd4c35 [IOTDB-3979] Let WrappedCallable/WrappedRunnable catch
Throwable (#6803)
add a751beccc1 [IOTDB-3922] Fix incorrect column name in some scenarios
for GroupByLevel (#6789)
add 195cea0a82 Refine LocalExecutionPlanner (#6797)
add a46e79a65b [IOTDB-3960] Fix the issue that FilterNode is not
considered in ExchangeNodeAddr (#6813)
add d7d6c9e0ab [IOTDB-3900] start-confignode ，Failed to execute system
command (#6805)
add 76bf7e1359 Remove the useless code in Session (#6825)
add 26fbe7f1ce spotless
add 93a2469cc2 [IOTDB-3993] Adjust pom.xml files' <dependency> <version>
(#6826)
add 2db18ee7fb [IOTDB-3727] Support clear cache in new cluster (#6756)
add 52a92f6cd0 add wal disk usage (#6822)
add 76c60f4f89 fix COMPACTION_TASK_COUNT metric. (#6823)
add 532e2d0893 [IOTDB-3990] Remove useless param in
IndexedConsensusRequest and add some logs. (#6820)
add 03f8067e21 [IOTDB-3883] Support order by timeseries in last query &
support last query across different DataRegion in execution layer (#6759)
add b2e3e4ed91 [IOTDB-3779] The Non-Seed-ConfigNode should suicide if
waiting leader's scheduling for too long (#6819)
add f2bc7156f0 merge insert nodes with same search index into one (#6727)
add 4c8edc5661 [IOTDB-3985] Retry removePeer for region bug (#6829)
add 54f9452888 Load ConfigNode after registering the internal server
(#6832)
add 903a9d6ac0 Extract ISchemaTree interface (#6830)
add 6e7e7e22e3 [IOTDB-3961] Fix bug of Tsfile compact (#6770)
add 4789a5e368 [IOTDB-3999] Avoid using PlanNodeType.ordinal() (#6835)
add e52b8c23c6 [IOTDB-3986] Unified ConfigNode heartbeat request
add def138b590 [IOTDB-3971] Improve the process of writing chunks in
compaction for aligned series (#6786)
add 991cbe7e1e [IOTDB-3940] Using bitmap in PageHeader to optimize
ValuePageReader from row-base scanning to columnar-style scanning (#6806)
add 22af8d479f remove useless log in cross space compaction (#6837)
add 8ddb8da5f5 Optimize CI workflow (#6841)
add d7627c8751 [IOTDB-4003] del duplicated dependency defination in
pom.xml (#6843)
add 55b5b17af2 [IOTDB-3983] Recover wal file's metadata (#6838)
add 2de0dd8731 fix template api in SessionPool for master (#6810)
add 5f118301f6 fix NullPointerException (#6852)
add 8e39a52e23 [IOTDB-3844] Clear up Non-Seed-ConfigNode register process
(#6831)
add 1140cf2da6 Influxdb service adapts to distributed MPP framework and
fixes some bugs in InfluxFunction and TagInfoRecord (#6828)
add df9c629453 Improve the performance of Raw Query Without ValueFilter
for nonAligned (#6853)
add 47d4b06db3 Add the CPU load status, memory status, disk status in
DashBoard (#6834)
add ef0e514ca6 [IOTDB-3955] Improved node information metrics to push more
detailed node information, online and offline total and survival information of
each node (#6801)
add c7b5eeb8cf [IOTDB-3814] Fix insert rows by sql with wrong data type
NPE (#6859)
add 21c530abf7 [IOTDB-4007]Support multiple paths in privilege control
(#6854)
add 73d5b80f34 [IOTDB-3847] Clear up interfaces in NodeManager(#6862)
add 32fefe24bd [IOTDB-3847] Clear up interfaces in NodeManager (#6862)
add ceae065482 Fix ConfigNode startup bug (#6867)
add e84b1e3185 [IOTDB-3280] Can not set ttl to all sg in cli with one sql
(#6842)
add 0bc694c320 [IOTDB-3758] support merge in new cluster (#6866)
add bdc79a6316 [IOTDB-4032] fix show all ttl display is empty in stand
(#6877)
add ec589a5f98 Bump testcontainers from 1.15.2 to 1.15.3 (#6740)
add f0cbaf7865 [IOTDB-4026] unknown PhysicalPlan type: 51 (#6873)
add 5010712706 [IOTDB-2952] IOTDB Grafana Plugin: Build on Windows (#6752)
add bcc8913814 [IOTDB-4024] Implement ColumnTransformerVisitor for
Expression (#6872)
add c941a41e6f Revert "[IOTDB-2952] IOTDB Grafana Plugin: Build on Windows
(#6752)" (#6883)
add f18922b4a6 Fix typo (#6885)
add 8f12321e75 [IOTDB-3973] Implement a new UDF named 'deDup' to only keep
distinct … (#6874)
add 4251d49630 [IOTDB-4037] reduce thread count for new standalone server
(#6888)
add 8c1b616f9d Change default query execute threads to cpu cores (#6889)
add 5ef5936d56 [IOTDB-4017] Fix Error happened while calling
onAcknowledgeDataBlockEvent (#6869)
add 3e4405e465 Fix Calculating size for same TsBlock is not consistent
between SinkHandle and SourceHandle (#6882)
add 1bdf3f9598 [IOTDB-4028] Npe in updateNodeLoadStatistic of LoadManager
when cluster first starts. (#6886)
add f900a34295 [IOTDB-3982] Shielding heartbeat error log (#6860)
add 23f0d63297 [IOTDB-3820] Build a integration test environment for
ConfigNode IT (#6753)
add 786c698613 [IOTDB-4037] Do not start DataNodeInternalRPCService in
Standalone version (#6895)
add 3a67962016 change state tracker from RPC to method call locally (#6898)
add 10cab5e83a update website about release-0.13 (#6897)
add ec2b68e9c9 Relacing `select * from root` with `select * from root.**`
in documents (#6900)
add d037f1b739 [IOTDB-4023]C++ interface execute SQL query statement and
the returned result set records error (#6870)
add ffd346c236 Support TimePartiton in mpp query (#6901)
add ade087b330 [IOTDB-4029] Latent routing policy for MultiLeader protocol
(#6880)
add 399340e6fd [IOTDB-3845] Add annotations in confignode.thrift (#6899)
add 8a97792086 [IOTDB-4030] Simplify Privilege Operations SQL (#6875)
add 742cc64c85 [IOTDB-4050] Failed to wait region migrate finished (#6908)
add 39db994138 [IOTDB-4051] fix nodeid duplicated problem (#6909)
add 894104b29f Merge remote-tracking branch 'upstream/master' into
IOTDB-3771
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 4 +-
.github/workflows/influxdb-protocol.yml | 2 +-
README.md | 6 +-
README_ZH.md | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 90 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 21 +
checkstyle.xml | 7 +
cli/pom.xml | 3 -
.../java/org/apache/iotdb/cli/AbstractScript.java | 5 -
.../iotdb/tool/integration/ExportCsvTestIT.java | 8 +-
.../iotdb/tool/integration/ImportCsvTestIT.java | 8 +-
client-cpp/src/main/Session.cpp | 24 +-
client-cpp/src/test/cpp/sessionIT.cpp | 28 +
client-go | 2 +-
confignode/pom.xml | 1 -
.../client/ConfigNodeClientPoolFactory.java | 40 +
.../confignode/client/DataNodeRequestType.java | 10 +-
...ava => AsyncConfigNodeHeartbeatClientPool.java} | 42 +-
.../async/datanode/AsyncDataNodeClientPool.java | 299 ++--
.../datanode/AsyncDataNodeHeartbeatClientPool.java | 72 +
.../async/handlers/AbstractRetryHandler.java | 33 +-
.../{FlushHandler.java => ClearCacheHandler.java} | 27 +-
.../async/handlers/ConfigNodeHeartbeatHandler.java | 16 +-
.../client/async/handlers/CreateRegionHandler.java | 14 +-
.../async/handlers/DataNodeHeartbeatHandler.java | 13 +-
.../client/async/handlers/FlushHandler.java | 16 +-
.../async/handlers/FunctionManagementHandler.java | 11 +-
.../{FlushHandler.java => MergeHandler.java} | 31 +-
.../client/async/handlers/SetTTLHandler.java | 7 +-
...dler.java => UpdateConfigNodeGroupHandler.java} | 25 +-
.../handlers/UpdateRegionRouteMapHandler.java | 16 +-
.../sync/confignode/SyncConfigNodeClientPool.java | 24 +-
.../sync/datanode/SyncDataNodeClientPool.java | 3 +
.../consensus/request/ConfigPhysicalPlan.java | 28 +-
.../consensus/request/ConfigPhysicalPlanType.java | 10 +-
.../consensus/request/auth/AuthorPlan.java | 25 +-
.../template/CheckTemplateSettablePlan.java} | 14 +-
.../GetAllSchemaTemplatePlan.java} | 22 +-
.../GetAllTemplateSetInfoPlan.java} | 22 +-
.../{ => template}/GetPathsSetTemplatePlan.java | 2 +-
.../GetSchemaTemplatePlan.java} | 24 +-
.../request/write/RemoveDataNodePlan.java | 124 +-
.../consensus/request/write/SetTTLPlan.java | 29 +-
.../{ => template}/CreateSchemaTemplatePlan.java | 27 +-
.../{ => template}/SetSchemaTemplatePlan.java | 2 +-
.../consensus/response/AllTemplateSetInfoResp.java | 26 +-
.../response/DataNodeConfigurationResp.java | 20 +-
.../consensus/response/DataNodeRegisterResp.java | 6 +
.../consensus/response/RegionInfoListResp.java | 2 +-
.../statemachine/PartitionRegionStateMachine.java | 8 +-
.../exception/AddConsensusGroupException.java | 11 +-
.../confignode/manager/ClusterSchemaManager.java | 240 +--
.../iotdb/confignode/manager/ConfigManager.java | 261 ++--
.../confignode/manager/DataNodeRemoveManager.java | 806 ----------
.../apache/iotdb/confignode/manager/IManager.java | 30 +-
.../iotdb/confignode/manager/NodeManager.java | 248 ++-
.../iotdb/confignode/manager/PartitionManager.java | 100 +-
.../iotdb/confignode/manager/ProcedureManager.java | 49 +-
.../iotdb/confignode/manager/UDFManager.java | 63 +-
.../iotdb/confignode/manager/load/LoadManager.java | 404 ++++-
.../manager/load/balancer/RouteBalancer.java | 60 +-
.../load/balancer/router/LazyGreedyRouter.java | 154 ++
.../load/heartbeat/ConfigNodeHeartbeatCache.java | 2 +-
.../manager/load/heartbeat/IRegionGroupCache.java | 9 +
.../manager/load/heartbeat/RegionGroupCache.java | 19 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 174 ++-
.../iotdb/confignode/persistence/NodeInfo.java | 246 +--
.../persistence/executor/ConfigPlanExecutor.java | 32 +-
.../persistence/partition/PartitionInfo.java | 4 +-
.../partition/StorageGroupPartitionTable.java | 2 +-
.../{ => schema}/ClusterSchemaInfo.java | 170 ++-
.../persistence/schema/TemplateTable.java | 64 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 55 +-
.../procedure/env/DataNodeRemoveHandler.java | 386 +++++
.../procedure/impl/AbstractNodeProcedure.java | 64 +
.../procedure/impl/AddConfigNodeProcedure.java | 34 +-
.../procedure/impl/RegionMigrateProcedure.java | 232 +++
.../procedure/impl/RemoveConfigNodeProcedure.java | 34 +-
.../procedure/impl/RemoveDataNodeProcedure.java | 184 +++
.../confignode/procedure/scheduler/LockQueue.java | 63 +
.../procedure/state/RegionTransitionState.java | 14 +-
.../procedure/state/RemoveDataNodeState.java | 14 +-
.../procedure/store/ProcedureFactory.java | 14 +
.../iotdb/confignode/service/ConfigNode.java | 84 +-
.../confignode/service/ConfigNodeCommandLine.java | 31 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 66 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 168 +-
.../request/write/RemoveDataNodePlanTest.java | 1 -
.../load/balancer/router/LazyGreedyRouterTest.java | 166 ++
.../load/balancer/router/LeaderRouterTest.java | 139 +-
.../confignode/persistence/AuthorInfoTest.java | 344 ++++-
.../persistence/ClusterSchemaInfoTest.java | 28 +-
.../confignode/persistence/TemplateTableTest.java | 18 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 90 +-
.../common/request/IndexedConsensusRequest.java | 20 +-
.../multileader/MultiLeaderServerImpl.java | 10 +-
.../multileader/logdispatcher/LogDispatcher.java | 12 +-
.../service/MultiLeaderRPCServiceProcessor.java | 34 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 3 +
cross-tests/pom.xml | 1 -
docker/src/main/Dockerfile-single-influxdb | 4 +-
docs/Download/README.md | 28 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 2 +-
.../Administration-Management/Administration.md | 205 ++-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 56 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 25 +-
docs/UserGuide/Operate-Metadata/TTL.md | 21 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 48 +-
docs/UserGuide/Reference/SQL-Reference.md | 4 +-
docs/UserGuide/UDF-Library/Series-Processing.md | 70 +
docs/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 14 +-
docs/zh/Development/VoteRelease.md | 4 +-
docs/zh/Download/README.md | 28 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
.../Administration-Management/Administration.md | 209 ++-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 58 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 37 +-
docs/zh/UserGuide/Operate-Metadata/TTL.md | 18 +
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 50 +-
.../Query-Data/Performance-Tracing-Tool.md | 30 +-
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 30 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 2 +-
docs/zh/UserGuide/UDF-Library/Series-Processing.md | 69 +
.../zh/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 14 +-
example/inflxudb-protocol-example/pom.xml | 39 +
.../apache/iotdb/influxdb}/InfluxDBExample.java | 74 +-
.../main/java/org/apache/iotdb/SessionExample.java | 5 +-
.../iotdb/SyntaxConventionRelatedExample.java | 4 +-
flink-iotdb-connector/pom.xml | 1 -
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 275 +++-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 289 +++-
hadoop/pom.xml | 1 -
hive-connector/pom.xml | 1 -
influxdb-protocol/pom.xml | 2 -
integration-test/import-control.xml | 8 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 115 +-
.../org/apache/iotdb/it/env/ConfigFactory.java | 1 +
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 4 +
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 16 +
.../java/org/apache/iotdb/it/env/EnvUtils.java | 90 ++
.../java/org/apache/iotdb/it/env/MppConfig.java | 22 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 28 +
.../apache/iotdb/it/env/StandaloneOnMppEnv.java | 5 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 25 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 15 +
.../org/apache/iotdb/db/it/IoTDBConfigNodeIT.java | 209 +++
.../apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java | 193 +++
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 125 ++
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 269 ++++
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 24 +-
...Cache2IT.java => IoTDBAlignedLastQuery2IT.java} | 15 +-
...Cache2IT.java => IoTDBAlignedLastQuery3IT.java} | 15 +-
...stCacheIT.java => IoTDBAlignedLastQueryIT.java} | 36 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 270 ----
... => IoTDBAlignedSeriesQueryWithDeletionIT.java} | 79 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 12 +
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 7 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 28 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 4 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 24 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 4 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 4 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 30 +
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 27 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 104 ++
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 315 ++++
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 5 -
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 89 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 14 +-
integration/pom.xml | 1 -
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 20 +-
.../db/integration/IoTDBInsertWithoutTimeIT.java | 131 --
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 130 ++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 220 ---
.../iotdb/session/IoTDBSessionComplexIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 18 -
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +-
.../apache/iotdb/session/template/TemplateUT.java | 5 +-
library-udf/pom.xml | 10 -
.../metrics/dropwizard/reporter/IoTDBReporter.java | 5 +-
.../{MetricsUtils.java => IoTDBMetricsUtils.java} | 28 +-
.../micrometer/reporter/IoTDBMeterRegistry.java | 5 +-
.../micrometer/MicrometerMetricManagerTest.java | 11 +
node-commons/pom.xml | 1 -
.../iotdb/commons/auth/entity/PrivilegeType.java | 10 +-
.../apache/iotdb/commons/client/ClientManager.java | 13 +-
.../iotdb/commons/client/IClientManager.java | 5 +
.../AsyncConfigNodeHeartbeatServiceClient.java | 140 ++
.../async/AsyncDataNodeHeartbeatServiceClient.java | 140 ++
.../apache/iotdb/commons/cluster/NodeStatus.java | 4 +
.../{WrappedRunnable.java => WrappedCallable.java} | 34 +-
.../iotdb/commons/concurrent/WrappedRunnable.java | 28 +-
.../threadpool/ScheduledExecutorUtil.java | 7 +
.../WrappedScheduledExecutorService.java | 31 +-
.../WrappedSingleThreadExecutorService.java | 23 +-
.../WrappedSingleThreadScheduledExecutor.java | 31 +-
.../threadpool/WrappedThreadPoolExecutor.java | 25 +
.../iotdb/commons/partition/DataPartition.java | 1 +
.../commons/partition/DataPartitionQueryParam.java | 14 -
.../BuiltinTimeSeriesGeneratingFunction.java | 1 +
.../commons/udf/builtin/String/UDTFEndsWith.java | 3 +
.../commons/udf/builtin/String/UDTFLower.java | 3 +
.../commons/udf/builtin/String/UDTFUpper.java | 3 +
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 3 +
.../commons/udf/builtin/UDTFDeDuplication.java | 139 ++
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 3 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 3 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 +
.../commons/utils/BasicStructureSerDeUtil.java | 31 +
pom.xml | 43 +-
schema-engine-rocksdb/pom.xml | 1 -
.../schemaregion/rocksdb/RSchemaRegion.java | 82 +
server/pom.xml | 11 -
.../resources/conf/iotdb-datanode.properties | 4 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 11 +
.../apache/iotdb/db/auth/AuthorizerManager.java | 6 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 104 ++
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 98 +-
.../org/apache/iotdb/db/auth/IAuthorCache.java | 26 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 2 +
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 15 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 63 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 27 +-
.../statemachine/DataRegionStateMachine.java | 86 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 30 +-
.../db/engine/compaction/CompactionWorker.java | 34 +-
.../RewriteCrossSpaceCompactionSelector.java | 7 -
.../impl/ReadPointCompactionPerformer.java | 18 +-
.../writer/AbstractCompactionWriter.java | 7 +-
.../writer/CrossSpaceCompactionWriter.java | 19 +-
.../writer/InnerSpaceCompactionWriter.java | 15 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 154 +-
.../template/TemplateIsInUseException.java | 5 +-
.../exception/sql/StatementAnalyzeException.java | 4 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 185 ++-
.../db/metadata/cache/DataNodeSchemaCache.java | 9 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 1 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 12 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 17 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 27 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 155 +-
.../db/metadata/mtree/traverser/Traverser.java | 59 +-
.../traverser/collector/MeasurementCollector.java | 4 +-
.../traverser/counter/MeasurementCounter.java | 26 +-
.../counter/MeasurementGroupByLevelCounter.java | 24 +
.../db/metadata/schemaregion/ISchemaRegion.java | 22 +
.../schemaregion/SchemaRegionMemoryImpl.java | 92 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 46 +
.../apache/iotdb/db/metadata/tag/TagManager.java | 39 +
.../metadata/template/ClusterTemplateManager.java | 214 ++-
.../db/metadata/template/ITemplateManager.java | 10 +
.../iotdb/db/metadata/template/Template.java | 72 +-
.../template/TemplateInternalRPCUpdateType.java | 68 +
.../metadata/visitor/SchemaExecutionVisitor.java | 27 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 36 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 26 +-
.../{SchemaTree.java => ClusterSchemaTree.java} | 22 +-
.../db/mpp/common/schematree/ISchemaTree.java | 70 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 3 +-
.../db/mpp/execution/exchange/ISinkHandle.java | 2 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 10 +-
.../db/mpp/execution/exchange/SinkHandle.java | 52 +-
.../fragment/FragmentInstanceExecution.java | 5 +-
.../fragment/FragmentInstanceManager.java | 16 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 2 +-
.../operator/process/DeviceMergeOperator.java | 2 +-
.../operator/process/FilterAndProjectOperator.java | 193 +++
.../execution/operator/process/FilterOperator.java | 243 ---
.../RowBasedTimeJoinOperator.java} | 69 +-
.../process/{ => join}/TimeJoinOperator.java | 14 +-
.../{ => join}/merge/AscTimeComparator.java | 2 +-
.../process/{ => join}/merge/ColumnMerger.java | 24 +-
.../{ => join}/merge/DescTimeComparator.java | 2 +-
.../{ => join}/merge/MultiColumnMerger.java | 56 +-
.../merge/NonOverlappedMultiColumnMerger.java | 25 +-
.../{ => join}/merge/SingleColumnMerger.java | 44 +-
.../process/{ => join}/merge/TimeComparator.java | 2 +-
.../LastQueryCollectOperator.java} | 17 +-
.../LastQueryMergeOperator.java} | 158 +-
.../operator/process/last/LastQueryOperator.java | 143 ++
.../process/last/LastQuerySortOperator.java | 202 +++
.../operator/{ => process/last}/LastQueryUtil.java | 93 +-
.../{ => last}/UpdateLastCacheOperator.java | 4 +-
.../schema/LevelTimeSeriesCountOperator.java | 28 +-
.../schema/PathsUsingTemplateScanOperator.java | 61 +
.../operator/schema/SchemaFetchMergeOperator.java | 4 +-
.../operator/schema/SchemaFetchScanOperator.java | 16 +-
.../operator/schema/TimeSeriesCountOperator.java | 26 +-
.../schema/TimeSeriesSchemaScanOperator.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 9 +-
.../mpp/execution/schedule/IDriverScheduler.java | 3 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 50 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 43 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 352 ++++-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 63 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 154 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 133 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 29 +-
.../mpp/plan/analyze/GroupByLevelController.java | 16 +-
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 17 +-
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 6 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 50 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 166 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 14 +-
.../mpp/plan/execution/config/ConfigExecution.java | 6 +-
.../plan/execution/config/ConfigTaskVisitor.java | 42 +
.../config/executor/ClusterConfigTaskExecutor.java | 108 +-
.../config/executor/IConfigTaskExecutor.java | 8 +
.../executor/StandaloneConfigTaskExecutor.java | 59 +-
.../{ => metadata}/CountStorageGroupTask.java | 4 +-
.../config/{ => metadata}/CreateFunctionTask.java | 4 +-
.../{ => metadata}/DeleteStorageGroupTask.java | 4 +-
.../config/{ => metadata}/DropFunctionTask.java | 4 +-
.../config/{ => metadata}/SetStorageGroupTask.java | 4 +-
.../config/{ => metadata}/SetTTLTask.java | 4 +-
.../config/{ => metadata}/ShowClusterTask.java | 8 +-
.../ShowConfigNodesTask.java} | 48 +-
.../config/{ => metadata}/ShowDataNodesTask.java | 23 +-
.../config/{ => metadata}/ShowFunctionsTask.java | 4 +-
.../config/{ => metadata}/ShowRegionTask.java | 6 +-
.../{ => metadata}/ShowStorageGroupTask.java | 4 +-
.../config/{ => metadata}/ShowTTLTask.java | 4 +-
.../config/{ => metadata}/UnSetTTLTask.java | 2 +-
.../template}/CreateSchemaTemplateTask.java | 4 +-
.../template}/SetSchemaTemplateTask.java | 4 +-
.../template}/ShowNodesInSchemaTemplateTask.java | 4 +-
.../template}/ShowPathSetTemplateTask.java | 4 +-
.../template}/ShowSchemaTemplateTask.java | 4 +-
.../execution/config/{ => sys}/AuthorizerTask.java | 4 +-
.../{FlushTask.java => sys/ClearCacheTask.java} | 41 +-
.../plan/execution/config/{ => sys}/FlushTask.java | 4 +-
.../MergeTask.java} | 26 +-
.../memory/StatementMemorySourceVisitor.java | 11 +
.../iotdb/db/mpp/plan/expression/Expression.java | 133 +-
.../plan/expression/binary/BinaryExpression.java | 11 +
.../expression/binary/CompareBinaryExpression.java | 5 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 6 +
.../db/mpp/plan/expression/leaf/LeafOperand.java | 6 +
.../plan/expression/leaf/TimeSeriesOperand.java | 6 +
.../mpp/plan/expression/leaf/TimestampOperand.java | 6 +
.../plan/expression/multi/FunctionExpression.java | 25 +-
.../plan/expression/ternary/BetweenExpression.java | 7 +
.../plan/expression/ternary/TernaryExpression.java | 13 +
.../plan/expression/unary/IsNullExpression.java | 5 +
.../mpp/plan/expression/unary/UnaryExpression.java | 11 +
.../visitor/ColumnTransformerVisitor.java | 478 ++++++
.../plan/expression/visitor/ExpressionVisitor.java | 73 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 308 ++--
.../db/mpp/plan/parser/StatementGenerator.java | 124 ++
.../plan/planner/LocalExecutionPlanContext.java | 161 ++
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 1444 +----------------
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 104 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 91 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 1614 ++++++++++++++++++++
.../distribution/DistributionPlanContext.java | 18 +
.../planner/distribution/ExchangeNodeAdder.java | 20 +-
.../SimpleFragmentParallelPlanner.java | 3 +-
.../plan/planner/distribution/SourceRewriter.java | 85 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 21 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 32 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 17 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 41 +-
...ntNode.java => PathsUsingTemplateScanNode.java} | 44 +-
.../node/metedata/read/SchemaFetchScanNode.java | 39 +-
.../node/metedata/read/TimeSeriesCountNode.java | 40 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 71 +-
.../node/metedata/write/ActivateTemplateNode.java | 154 ++
.../planner/plan/node/process/AggregationNode.java | 12 +-
.../planner/plan/node/process/DeviceMergeNode.java | 44 +-
.../planner/plan/node/process/DeviceViewNode.java | 42 +-
.../plan/planner/plan/node/process/FillNode.java | 13 +-
.../plan/planner/plan/node/process/FilterNode.java | 13 +-
.../plan/node/process/GroupByLevelNode.java | 12 +-
.../planner/plan/node/process/MultiChildNode.java | 21 +
.../node/process/SlidingWindowAggregationNode.java | 12 +-
.../plan/planner/plan/node/process/SortNode.java | 12 +-
.../planner/plan/node/process/TimeJoinNode.java | 12 +-
.../planner/plan/node/process/TransformNode.java | 12 +-
.../LastQueryCollectNode.java} | 93 +-
.../process/{ => last}/LastQueryMergeNode.java | 76 +-
.../LastQueryNode.java} | 69 +-
.../source/AlignedSeriesAggregationScanNode.java | 10 +-
.../plan/node/source/AlignedSeriesScanNode.java | 12 +-
.../node/source/SeriesAggregationScanNode.java | 10 +-
.../node/source/SeriesAggregationSourceNode.java | 6 +-
.../planner/plan/node/source/SeriesScanNode.java | 14 +-
.../planner/plan/node/write/DeleteDataNode.java | 6 +-
.../plan/node/write/InsertMultiTabletsNode.java | 7 +-
.../plan/planner/plan/node/write/InsertNode.java | 4 +-
.../planner/plan/node/write/InsertRowNode.java | 20 +-
.../planner/plan/node/write/InsertRowsNode.java | 7 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 7 +-
.../planner/plan/node/write/InsertTabletNode.java | 6 +-
.../planner/plan/parameter/OrderByParameter.java | 93 ++
.../scheduler/AbstractFragInsStateTracker.java | 28 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 20 +-
.../scheduler/FixedRateFragInsStateTracker.java | 16 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 4 -
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 28 +-
.../db/mpp/plan/statement/StatementVisitor.java | 31 +-
.../plan/statement/component/OrderByComponent.java | 92 ++
.../component/{OrderBy.java => Ordering.java} | 22 +-
.../db/mpp/plan/statement/component/SortItem.java | 83 +
.../component/SortKey.java} | 13 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 65 +-
.../statement/internal/SchemaFetchStatement.java | 10 +-
.../metadata/CountLevelTimeSeriesStatement.java | 32 +
.../metadata/CountTimeSeriesStatement.java | 30 +
...tatement.java => ShowConfigNodesStatement.java} | 13 +-
.../template/ActivateTemplateStatement.java} | 38 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 22 +-
.../template/ShowPathsUsingTemplateStatement.java} | 31 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 20 +-
.../ClearCacheStatement.java} | 40 +-
.../MergeStatement.java} | 35 +-
.../mpp/transformation/dag/column/ColumnCache.java | 56 +
.../dag/column/ColumnTransformer.java | 78 +
.../ArithmeticAdditionColumnTransformer.java} | 18 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 57 +
.../ArithmeticDivisionColumnTransformer.java} | 18 +-
.../binary/ArithmeticModuloColumnTransformer.java} | 18 +-
...ArithmeticMultiplicationColumnTransformer.java} | 23 +-
.../ArithmeticSubtractionColumnTransformer.java} | 18 +-
.../dag/column/binary/BinaryColumnTransformer.java | 65 +
.../binary/CompareBinaryColumnTransformer.java | 89 ++
.../binary/CompareEqualToColumnTransformer.java | 47 +
.../CompareGreaterEqualColumnTransformer.java} | 18 +-
.../CompareGreaterThanColumnTransformer.java} | 18 +-
.../binary/CompareLessEqualColumnTransformer.java} | 18 +-
.../binary/CompareLessThanColumnTransformer.java} | 18 +-
.../binary/CompareNonEqualColumnTransformer.java | 47 +
.../column/binary/LogicAndColumnTransformer.java} | 18 +-
.../binary/LogicBinaryColumnTransformer.java | 65 +
.../column/binary/LogicOrColumnTransformer.java} | 18 +-
.../column/leaf/ConstantColumnTransformer.java} | 24 +-
.../column/leaf/IdentityColumnTransformer.java} | 31 +-
.../dag/column/leaf/LeafColumnTransformer.java} | 23 +-
.../dag/column/leaf/TimeColumnTransformer.java} | 17 +-
.../column/multi/MappableUDFColumnTransformer.java | 91 ++
.../column/ternary/BetweenColumnTransformer.java | 93 ++
.../ternary/CompareTernaryColumnTransformer.java | 74 +
.../column/ternary/TernaryColumnTransformer.java | 44 +
.../unary/ArithmeticNegationColumnTransformer.java | 51 +
.../dag/column/unary/InColumnTransformer.java | 207 +++
.../dag/column/unary/IsNullColumnTransformer.java | 37 +-
.../column/unary/LogicNotColumnTransformer.java | 52 +
.../dag/column/unary/RegularColumnTransformer.java | 61 +
.../dag/column/unary/UnaryColumnTransformer.java | 51 +
.../dag/transformer/Transformer.java | 21 -
.../binary/CompareBinaryTransformer.java | 21 -
.../binary/CompareEqualToTransformer.java | 3 +-
.../binary/CompareGreaterEqualTransformer.java | 3 +-
.../binary/CompareGreaterThanTransformer.java | 3 +-
.../binary/CompareLessEqualTransformer.java | 3 +-
.../binary/CompareLessThanTransformer.java | 3 +-
.../binary/CompareNonEqualTransformer.java | 3 +-
.../transformer/ternary/BetweenTransformer.java | 5 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 29 +-
...eInferrer.java => UDTFInformationInferrer.java} | 64 +-
.../transformation/dag/util/TransformUtils.java | 99 ++
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 40 +-
.../function/aggregator/InfluxMeanFunction.java | 4 +-
.../function/aggregator/InfluxSpreadFunction.java | 6 +-
.../function/selector/InfluxFirstFunction.java | 5 +-
.../function/selector/InfluxLastFunction.java | 5 +-
.../influxdb/handler/AbstractQueryHandler.java | 511 +++++++
.../protocol/influxdb/handler/NewQueryHandler.java | 200 +++
.../db/protocol/influxdb/handler/QueryHandler.java | 466 +-----
.../influxdb/meta/AbstractInfluxDBMetaManager.java | 114 ++
.../influxdb/meta/InfluxDBMetaManager.java | 96 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 129 ++
.../db/protocol/influxdb/meta/TagInfoRecords.java | 24 +-
.../influxdb/util/InfluxReqAndRespUtils.java | 55 +
.../protocol/influxdb/util/QueryResultUtils.java | 153 ++
.../db/protocol/influxdb/util/StringUtils.java | 11 +
.../mpprest/impl/GrafanaApiServiceImpl.java | 26 +-
.../protocol/mpprest/impl/RestApiServiceImpl.java | 14 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 90 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 26 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../sys/ActivateTemplateInClusterPlan.java | 110 ++
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 62 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 12 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 162 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 35 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 108 +-
.../db/service/DataNodeServerCommandLine.java | 120 +-
.../iotdb/db/service/InfluxDBRPCService.java | 26 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 3 -
.../iotdb/db/service/RegionMigrateService.java | 40 +-
.../recorder/CompactionMetricsRecorder.java | 6 +-
.../handler/InfluxDBServiceThriftHandler.java | 10 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 207 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 67 +-
.../thrift/impl/IInfluxDBServiceWithHandler.java} | 12 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 20 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 128 ++
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 16 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 2 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 44 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 3 +
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 9 +-
.../iotdb/db/wal/recover/WALRecoverWriter.java | 26 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 22 +-
.../db/engine/storagegroup/DataRegionTest.java | 85 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 5 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 11 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 3 +-
...emaTreeTest.java => ClusterSchemaTreeTest.java} | 28 +-
.../db/mpp/execution/ConfigExecutionTest.java | 18 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 10 +-
.../execution/exchange/LocalSinkHandleTest.java | 6 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 70 +-
.../db/mpp/execution/exchange/StubSinkHandle.java | 4 +-
.../iotdb/db/mpp/execution/exchange/Utils.java | 11 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../operator/AlignedSeriesScanOperatorTest.java | 14 +-
.../operator/DeviceMergeOperatorTest.java | 2 +-
.../operator/LastCacheScanOperatorTest.java | 93 --
.../operator/LastQueryMergeOperatorTest.java | 598 ++++----
...peratorTest.java => LastQueryOperatorTest.java} | 64 +-
...torTest.java => LastQuerySortOperatorTest.java} | 72 +-
.../mpp/execution/operator/LimitOperatorTest.java | 10 +-
.../execution/operator/MultiColumnMergerTest.java | 2 +-
.../NonOverlappedMultiColumnMergerTest.java | 4 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 14 +-
.../operator/RawDataAggregationOperatorTest.java | 10 +-
.../execution/operator/SingleColumnMergerTest.java | 6 +-
.../execution/operator/TimeJoinOperatorTest.java | 16 +-
.../operator/UpdateLastCacheOperatorTest.java | 3 +-
.../operator/schema/CountMergeOperatorTest.java | 21 +-
.../operator/schema/SchemaCountOperatorTest.java | 21 +-
.../schema/SchemaFetchScanOperatorTest.java | 7 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../execution/schedule/DriverSchedulerTest.java | 9 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 9 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 103 ++
.../mpp/plan/analyze/cache/PartitionCacheTest.java | 432 ++++++
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 20 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 196 ++-
.../distribution/AggregationDistributionTest.java | 34 +-
.../distribution/DistributionPlannerBasicTest.java | 42 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 62 +-
.../distribution/NoDataRegionPlanningTest.java | 20 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 7 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 8 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 4 +-
.../node/process/AggregationNodeSerdeTest.java | 6 +-
.../plan/node/process/DeviceViewNodeSerdeTest.java | 16 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 5 +-
.../plan/plan/node/process/FillNodeSerdeTest.java | 7 +-
.../plan/node/process/FilterNodeSerdeTest.java | 7 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 8 +-
.../plan/plan/node/process/LimitNodeSerdeTest.java | 4 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 4 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 7 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 9 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 4 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 4 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertRowNodeSerdeTest.java | 8 +-
.../plan/node/write/InsertRowsNodeSerdeTest.java | 2 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 3 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 6 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 20 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 2 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 2 +-
.../iotdb/db/wal/recover/WALRecoverWriterTest.java | 198 +++
.../main/java/org/apache/iotdb/session/Config.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 38 +-
.../apache/iotdb/session/SessionConnection.java | 15 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 8 +-
spark-iotdb-connector/pom.xml | 4 -
thrift-commons/src/main/thrift/common.thrift | 31 +-
.../src/main/thrift/confignode.thrift | 300 +++-
.../src/main/thrift/mutlileader.thrift | 3 +-
thrift/src/main/thrift/client.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 27 +
tsfile/pom.xml | 8 -
.../file/metadata/statistics/Statistics.java | 10 +
.../file/metadata/statistics/TimeStatistics.java | 8 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 4 +
.../block/column/BinaryArrayColumnEncoder.java | 26 +-
.../read/common/block/column/BinaryColumn.java | 16 +
.../read/common/block/column/BooleanColumn.java | 16 +
.../block/column/ByteArrayColumnEncoder.java | 19 +-
.../tsfile/read/common/block/column/Column.java | 38 +
.../read/common/block/column/DoubleColumn.java | 16 +
.../read/common/block/column/FloatColumn.java | 16 +
.../block/column/Int32ArrayColumnEncoder.java | 37 +-
.../block/column/Int64ArrayColumnEncoder.java | 64 +-
.../tsfile/read/common/block/column/IntColumn.java | 16 +
.../read/common/block/column/LongColumn.java | 16 +
.../block/column/RunLengthEncodedColumn.java | 58 +
.../read/common/block/column/TimeColumn.java | 11 +
.../iotdb/tsfile/read/common/type/BinaryType.java | 39 +-
.../iotdb/tsfile/read/common/type/BooleanType.java | 39 +-
.../iotdb/tsfile/read/common/type/DoubleType.java | 85 ++
.../iotdb/tsfile/read/common/type/FloatType.java | 85 ++
.../iotdb/tsfile/read/common/type/IntType.java | 85 ++
.../iotdb/tsfile/read/common/type/LongType.java | 85 ++
.../apache/iotdb/tsfile/read/common/type/Type.java | 104 ++
.../iotdb/tsfile/read/common/type/TypeEnum.java | 19 +-
.../iotdb/tsfile/read/common/type/TypeFactory.java | 33 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 98 +-
.../tsfile/read/reader/page/ValuePageReader.java | 99 ++
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 63 +
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 10 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 24 +-
.../iotdb/tsfile/write/page/TimePageWriter.java | 6 +-
.../iotdb/tsfile/write/page/ValuePageWriter.java | 72 +-
.../tsfile/common/block/TsBlockSerdeTest.java | 139 +-
zeppelin-interpreter/pom.xml | 1 -
629 files changed, 23501 insertions(+), 9762 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/confignode/{AsyncConfigNodeClientPool.java
=> AsyncConfigNodeHeartbeatClientPool.java} (54%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/async/datanode/AsyncDataNodeHeartbeatClientPool.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{FlushHandler.java
=> ClearCacheHandler.java} (76%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{FlushHandler.java
=> MergeHandler.java} (73%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{UpdateRegionRouteMapHandler.java
=> UpdateConfigNodeGroupHandler.java} (74%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/SetSchemaTemplatePlan.java
=> read/template/CheckTemplateSettablePlan.java} (79%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java
=> template/GetAllSchemaTemplatePlan.java} (71%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java
=> template/GetAllTemplateSetInfoPlan.java} (71%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{
=> template}/GetPathsSetTemplatePlan.java (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetNodesInSchemaTemplatePlan.java
=> template/GetSchemaTemplatePlan.java} (67%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> template}/CreateSchemaTemplatePlan.java (73%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{
=> template}/SetSchemaTemplatePlan.java (96%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeStatus.java =>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java
(64%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/UnSetTTLTask.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/exception/AddConsensusGroupException.java
(69%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeRemoveManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouter.java
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{ =>
schema}/ClusterSchemaInfo.java (81%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AbstractNodeProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RegionMigrateProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RemoveDataNodeProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/LockQueue.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/UnSetTTLTask.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RegionTransitionState.java
(72%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/UnSetTTLTask.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveDataNodeState.java
(72%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouterTest.java
create mode 100644 docs/UserGuide/UDF-Library/Series-Processing.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Series-Processing.md
create mode 100644 example/inflxudb-protocol-example/pom.xml
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/example =>
example/inflxudb-protocol-example/src/main/java/org/apache/iotdb/influxdb}/InfluxDBExample.java
(58%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/EnvUtils.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBConfigNodeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertWithoutTimeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBTtlIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBAlignedLastQuery2IT.java} (84%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBAlignedLastQuery3IT.java} (84%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheIT.java
=> IoTDBAlignedLastQueryIT.java} (89%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
=> IoTDBAlignedSeriesQueryWithDeletionIT.java} (51%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBSchemaTemplateIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithoutTimeIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
rename
metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/{MetricsUtils.java
=> IoTDBMetricsUtils.java} (63%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncConfigNodeHeartbeatServiceClient.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncDataNodeHeartbeatServiceClient.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/concurrent/{WrappedRunnable.java
=> WrappedCallable.java} (54%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFDeDuplication.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/auth/BasicAuthorityCache.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeStatus.java =>
server/src/main/java/org/apache/iotdb/db/auth/IAuthorCache.java (66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUpdateType.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/{SchemaTree.java
=> ClusterSchemaTree.java} (95%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/ISchemaTree.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterAndProjectOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{TimeJoinOperator.java
=> join/RowBasedTimeJoinOperator.java} (83%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{
=> join}/TimeJoinOperator.java (94%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{
=> join}/merge/AscTimeComparator.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
join}/merge/ColumnMerger.java (70%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{
=> join}/merge/DescTimeComparator.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
join}/merge/MultiColumnMerger.java (63%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
join}/merge/NonOverlappedMultiColumnMerger.java (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
join}/merge/SingleColumnMerger.java (74%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
join}/merge/TimeComparator.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{LastQueryMergeOperator.java
=> last/LastQueryCollectOperator.java} (88%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{TimeJoinOperator.java
=> last/LastQueryMergeOperator.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/last/LastQueryOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/last/LastQuerySortOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/{ =>
process/last}/LastQueryUtil.java (55%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{ =>
last}/UpdateLastCacheOperator.java (96%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/PathsUsingTemplateScanOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/CountStorageGroupTask.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/CreateFunctionTask.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/DeleteStorageGroupTask.java (89%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/DropFunctionTask.java (87%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/SetStorageGroupTask.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/SetTTLTask.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowClusterTask.java (91%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ShowDataNodesTask.java
=> metadata/ShowConfigNodesTask.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowDataNodesTask.java (75%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowFunctionsTask.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowRegionTask.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowStorageGroupTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/ShowTTLTask.java (92%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata}/UnSetTTLTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata/template}/CreateSchemaTemplateTask.java (88%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata/template}/SetSchemaTemplateTask.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata/template}/ShowNodesInSchemaTemplateTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata/template}/ShowPathSetTemplateTask.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
metadata/template}/ShowSchemaTemplateTask.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
sys}/AuthorizerTask.java (90%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{FlushTask.java
=> sys/ClearCacheTask.java} (57%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{ =>
sys}/FlushTask.java (92%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{SetSchemaTemplateTask.java
=> sys/MergeTask.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/ColumnTransformerVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/ExpressionVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/OperatorTreeGenerator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{TimeSeriesCountNode.java
=> PathsUsingTemplateScanNode.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/ActivateTemplateNode.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{SortNode.java
=> last/LastQueryCollectNode.java} (51%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{
=> last}/LastQueryMergeNode.java (60%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{LastQueryMergeNode.java
=> last/LastQueryNode.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/OrderByParameter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderByComponent.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{OrderBy.java
=> Ordering.java} (70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/SortItem.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/{execution/config/UnSetTTLTask.java
=> statement/component/SortKey.java} (72%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CountTimeSeriesStatement.java
=> ShowConfigNodesStatement.java} (75%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/LastPointFetchStatement.java
=> metadata/template/ActivateTemplateStatement.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/SchemaFetchStatement.java
=> metadata/template/ShowPathsUsingTemplateStatement.java} (59%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/SchemaFetchStatement.java
=> sys/ClearCacheStatement.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/SchemaFetchStatement.java
=> sys/MergeStatement.java} (64%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ColumnCache.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/ArithmeticAdditionColumnTransformer.java}
(59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/ArithmeticBinaryColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/ArithmeticDivisionColumnTransformer.java}
(59%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/AscTimeComparator.java
=> transformation/dag/column/binary/ArithmeticModuloColumnTransformer.java}
(60%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{plan/statement/metadata/CountLevelTimeSeriesStatement.java
=>
transformation/dag/column/binary/ArithmeticMultiplicationColumnTransformer.java}
(59%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=>
transformation/dag/column/binary/ArithmeticSubtractionColumnTransformer.java}
(59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/BinaryColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareBinaryColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareEqualToColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/CompareGreaterEqualColumnTransformer.java}
(60%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/CompareGreaterThanColumnTransformer.java}
(60%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/CompareLessEqualColumnTransformer.java}
(60%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/CompareLessThanColumnTransformer.java}
(60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareNonEqualColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/LogicAndColumnTransformer.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/LogicBinaryColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/binary/LogicOrColumnTransformer.java} (60%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/{plan/execution/config/DropFunctionTask.java
=> transformation/dag/column/leaf/ConstantColumnTransformer.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java
=> transformation/dag/column/leaf/IdentityColumnTransformer.java} (54%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/AscTimeComparator.java
=> transformation/dag/column/leaf/LeafColumnTransformer.java} (60%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/{execution/operator/process/merge/DescTimeComparator.java
=> transformation/dag/column/leaf/TimeColumnTransformer.java} (66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/multi/MappableUDFColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/BetweenColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/CompareTernaryColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/TernaryColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/ArithmeticNegationColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/InColumnTransformer.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/concurrent/WrappedRunnable.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/IsNullColumnTransformer.java
(50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/LogicNotColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/RegularColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/UnaryColumnTransformer.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/udf/{UDTFTypeInferrer.java
=> UDTFInformationInferrer.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/util/TransformUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/AbstractQueryHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/NewQueryHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/AbstractInfluxDBMetaManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/meta/NewInfluxDBMetaManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/InfluxReqAndRespUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ActivateTemplateInClusterPlan.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/execution/config/UnSetTTLTask.java
=> service/thrift/impl/IInfluxDBServiceWithHandler.java} (72%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/NewInfluxDBServiceImpl.java
rename
server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/{SchemaTreeTest.java
=> ClusterSchemaTreeTest.java} (95%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/LastCacheScanOperatorTest.java
copy
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/{LastQueryMergeOperatorTest.java
=> LastQueryOperatorTest.java} (87%)
copy
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/{LastQueryMergeOperatorTest.java
=> LastQuerySortOperatorTest.java} (87%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCacheTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/wal/recover/WALRecoverWriterTest.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaTemplatePlan.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/BinaryType.java
(50%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaTemplatePlan.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/BooleanType.java
(51%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/DoubleType.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/FloatType.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/IntType.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/LongType.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/Type.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/UnSetTTLTask.java
=> tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/TypeEnum.java
(72%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/TypeFactory.java
(54%)
