This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch iotdb-3349
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4b055888b6 Merge branch 'master' of github.com:apache/iotdb into
iotdb-3349
add 39298c609f [IOTDB-3459] Make sure SignalWALEntry be pushed to the
queue successfully in close() (#6241)
add 546f71dae8 [IOTDB-3458] Fix incorrect error handling strategy of some
periodic services (#6240)
add e80b219032 Make CI stable (#6243)
add 38f3332736 skip RegionReplicaSet in serialization of Fragment Instance
(#6217)
add 7b07fd9cba [IOTDB-3413] Fix the datatype consistency check of group by
level (#6208)
add 74b7835c8a [IOTDB-3035] Modify keywords doc: remove
encoding/compression/datatype (#6238)
add a3a0b23916 [IOTDB-3439] Move Setting up RPC Service to the last step
of starting DataNode 2 (#6232)
add abb242a54b fix the issue that AutoCreateTimeSeries throws NPE (#6249)
add ae5f78646c [IOTDB-3424] avoid run duplicated IotDB server/node (#6200)
add e3fe470a0f [IOTDB-3460] Python API: Add support for DBAPI (#6246)
add 3247f48cd8 [IOTDB-3447] add some schema template function in python
client (#6223)
add c05ac0ff0b [IOTDB-3099] Flush in new cluster (#6167)
add 51acf53822 Support LocalSinkHandle and LocalSourceHandle if two FI in
the same DataNode (#6193)
add 149ededde9 fix test (#6251)
add a5aed992fa Abandon set ttl, schema replication factor, data
replication factor, time partition interval to specific storage group (#6252)
add f6943d9dfe Support flush in new standalone IoTDB (#6254)
add 1e31ab278d [IOTDB-3445][IOTDB-3446] Fixed empty dirs are not deleted
after data … (#6242)
add 5f9d274930 Fix group by level node serialize bug (#6258)
add 0eba12bfcf Rename deleteDirectoryAndParent to
deleteDirectoryAndEmptyParent (#6262)
add 2242a4033e [IOTDB-3331] Fix create three level timeseries. (#6247)
add 9e749b8ee1 [IOTDB-3472] Fix OOM in New Standalone mode (#6263)
add c742abeff6 [IOTDB-3390] Serialize ConfigNode expansion (#6256)
add a9060a1d3e [IOTDB-3440] Add description of compatibility between
0.13.x and 0.12.x / master and 0.13.x (#6234)
add 3e0a1281fb [IOTDB-5879]Override hashCode of AuthorReq (#6257)
add 3c78969fea Revert "[IOTDB-3390] Serialize ConfigNode expansion
(#6256)" (#6266)
add 9da5ad5281 [IOTDB-3463] IT framework supports read and compare from
multi data nodes (#6271)
add a93728770f IOTDB-3481 Optimize Log Print (#6273)
add c4b22f26ac [IOTDB-3477] Send two phase message to ConfigNode when
starting DataNode (#6269)
add babb62a355 [IOTDB-3416] Abstract interface of ConfigTask Execution for
standalone IoTDB (#6260)
add d7cf590774 [IOTDB-3384] fix run length tsblock serde (#6270)
add 16314af65a Add data Deletion IT and Insert IT for aligned time series
(#6259)
add 1871e60f39 [IOTDB-3476] remove error log when update cache
add 47ad89c8da Fix the issue that query is not removed from
QueryExecutionMap (#6278)
add b3355c58b3 [IOTDB-3485] Insert with wrong type didn't return error
massage (#6277)
add d976dcf530 [IOTDB-3434] Implement the Built-in Functions of String
(#6250)
add 73b4253ab9 fix the bug that the judgement of hasResultSet is skipped
(#6284)
add 3d4061ad69 [IOTDB-3473][metrics] Prometheus reporter will lose data in
some conditions (#6265)
add 914cc9a354 [IOTDB-3401] Fix some operators in filter condition query
are currently not returning BOOLEAN (#6169)
add f29b0f7609 [IOTDB-3486] Support deleteStorageGroup for new standalone
IoTDB (#6280)
add 732fa7716e [IOTDB-3489] Add test name to log folder in cluster test
(#6279)
add e2bb2ddc57 [IOTDB-3490] Eliminate LocalConfigNode Usage in New Cluster
(#6281)
add 2c8ff673cc [IOTDB-3494] Fix TypeError in python session (#6292)
add eafa32263c [IOTDB-3371] Fix bug when using alias in SELECT clause
(#6139)
add 34238dc682 grafana plugin doc update (#6184)
add 79f46915b0 [IOTDB-3285] Fix IndexOutOfBoundsException when creating
aligned timeseries with session API
add 20c679877d Fix the issue that sometimes the schema partition cannot be
calculated correctly (#6276)
add 6b7a978471 Optimize log for mpp process (#6286)
add 360e356cb3 fix the issue related to LocalSinkHandle/LocalSourceHandle
(#6296)
add 3ab79349a5 [IOTDB-3495] Print detailed error message when insert wrong
datatype (#6288)
add 0422d48006 [IOTDB-3470] [IOTDB-3471] Add some semantic checks for
InsertStatement (#6298)
add d417b3d6d2 [IOTDB-3505] The region dirs are not deleted when the
storage group is deleted in MultiLeaderConsensus (#6297)
add 149d88e7bf Improve auto create schema (#6295)
add 473070e9c6 [IOTDB-3182] Judge DataNode status through heartbeat(Simple
version) (#6285)
add 1147668b15 [IOTDB-3500] Fix delete storage group failure in new
standable IoTDB (#6302)
add 99279e0352 [IOTDB-3491] Assign an unique id to each ConfigNode (#6287)
add 9562161613 [IOTDB-3433] add metric for cluster. (#6291)
add 3b785c80ca [IOTDB-3449] Fix case sensitive bug of aggregation function
name (#6253)
add 18a514c384 [IOTDB-3456] Optimize PathPattarnTree for improving write
performance (#6294)
add 0ae9985eb2 [IOTDB-3436] Add IT for aggregation, groupby and align by
device query in MPP (#6207)
add a438aaeaaa Change meaning of Flush to Flush on Cluster (#6314)
add ed439a4c4a rest java example (#6274)
add a350004421 rest services add clientAuth (#4965)
add a920737417 [IOTDB-3515] load empty TsFile error message (#6307)
add 65413a28e7 [IOTDB-3323][IOTDB-3506] Support MQTT for MPP framework
(#6311)
add 2313d99c36 [IOTDB-3482] Add IT for UDF management in new Cluster
(#6290)
add 54d0720188 uncomment the data_block_manager_port and change default
data region to StandAlone Consensus (#6317)
add cba438a413 Print sql and corresponding QueryId (#6319)
add 462c0c2c8c [IOTDB-3438] Fix empty WAL file (#6312)
add aabba8b548 [IOTDB-3505] Fix NPE when regionCleaner deletes schema
regions after restart. (#6316)
add dfb538d1aa [IOTDB-3516] Add trigger snapshot implementation for
RatisConsensus (#6305)
add a0031aece9 Consensus CI test fix transferLeader assert (#6264)
add ed68cb5d9b Fix the issue that the QueryExecution may not be released
(#6318)
add 93ef537af0 fixed (#6320)
add 1840cd1a78 [IOTDB-3344] Fix dataRegion snapshot may meet file not
found due to compaction (#6303)
add a7466e551a [IOTDB-3466] Python client add support for SQLAlchemy
Dialect (#6255)
add a352d93492 [IOTDB-3299] Migrate udf api to a seperate module (#6268)
add e269bb7a83 Accelerate New Cluster IT (#6326)
add 1309eef2b1 [IOTDB-3388] Let MQTT Service could parse JSON array of
existed format (#6154)
add fbf8144854 Merge remote-tracking branch 'origin/master' into iotdb-3349
add 61237df065 fix some bug
add 77563a6273 [IOTDB-3511] Show Region tool (#6315)
add e34850cacc [IOTDB-3189] Fix compaction is not well-distributed across
sgs (#6324)
add de0b507523 [IOTDB-2179] New IT framework supports Windows platform
(#6313)
add 98b65a1ba4 Fix Dead Lock Bug (#6331)
add 05a849184e [IOTDB-3365] Add more log name in query processing and Fix
NPE while fetchFragmentInstanceState (#6332)
add 6702808c25 [IOTDB-3414] [mpp] fix schema query limit offset bug (#6179)
add ed20fccc2b [IOTDB-3392] File doesn't exist when move tsfile when
virtual_storage_group_num > 1 (#6310)
add 1fb7229c2d Fix DeadLock bug (#6334)
add f1df2b9909 Merge remote-tracking branch 'origin/master' into iotdb-3349
add e2c5381ab3 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 31 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 4 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 12 +
client-py/README.md | 209 +-
client-py/SessionExample.py | 44 +-
client-py/iotdb/Session.py | 226 +-
client-py/iotdb/dbapi/Connection.py | 91 +
client-py/iotdb/dbapi/Cursor.py | 288 ++
.../{tsfile/utils/Pair.py => dbapi/Exceptions.py} | 47 +-
.../{requirements.txt => iotdb/dbapi/__init__.py} | 13 +-
client-py/iotdb/{ => dbapi/tests}/__init__.py | 0
client-py/iotdb/dbapi/tests/test_connection.py | 57 +
client-py/iotdb/dbapi/tests/test_cursor.py | 123 +
client-py/iotdb/sqlalchemy/IoTDBDialect.py | 136 +
.../IoTDBIdentifierPreparer.py} | 13 +-
client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 243 ++
.../IoTDBTypeCompiler.py} | 39 +-
client-py/iotdb/{ => sqlalchemy}/__init__.py | 0
client-py/iotdb/{ => sqlalchemy/tests}/__init__.py | 0
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 92 +
client-py/iotdb/template/Template.py | 5 +-
client-py/iotdb/template/TemplateNode.py | 3 +-
.../Pair.py => template/TemplateQueryType.py} | 25 +-
client-py/iotdb/tsfile/utils/Pair.py | 4 +-
client-py/requirements.txt | 5 +-
client-py/setup.py | 7 +
client-py/tests/test_template.py | 130 +-
.../src/assembly/resources/conf/confignode-env.bat | 8 +-
.../resources/conf/iotdb-confignode.properties | 2 +-
confignode/src/assembly/resources/conf/logback.xml | 13 +-
.../client/ConfigNodeClientPoolFactory.java | 4 +-
.../confignode/client/SyncDataNodeClientPool.java | 46 +-
.../client/handlers/HeartbeatHandler.java | 1 -
.../{ConfigNodeConf.java => ConfigNodeConfig.java} | 14 +-
.../confignode/conf/ConfigNodeDescriptor.java | 8 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 4 +-
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 3 +-
.../consensus/request/auth/AuthorReq.java | 6 +
.../request/read/GetRegionLocationsReq.java | 62 +
.../consensus/response/RegionLocationsResp.java | 35 +-
.../iotdb/confignode/manager/ConfigManager.java | 149 +-
.../iotdb/confignode/manager/ConsensusManager.java | 8 +-
.../apache/iotdb/confignode/manager/Manager.java | 14 +-
.../iotdb/confignode/manager/NodeManager.java | 8 +-
.../iotdb/confignode/manager/PartitionManager.java | 13 +-
.../confignode/manager/PermissionManager.java | 36 +-
.../iotdb/confignode/manager/ProcedureManager.java | 14 +-
.../iotdb/confignode/manager/load/LoadManager.java | 83 +-
.../manager/load/heartbeat/HeartbeatCache.java | 74 +-
.../manager/load/heartbeat/HeartbeatPackage.java | 1 +
.../manager/load/heartbeat/HeartbeatWindow.java | 51 -
.../load/heartbeat/IHeartbeatStatistic.java | 19 +-
.../iotdb/confignode/persistence/NodeInfo.java | 74 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../executor/ConfigRequestExecutor.java | 3 +
.../persistence/partition/PartitionInfo.java | 231 +-
.../partition/StorageGroupPartitionTable.java | 139 +-
.../iotdb/confignode/service/ConfigNode.java | 11 +-
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 55 +-
.../consensus/request/ConfigRequestSerDeTest.java | 13 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 4 +-
.../confignode/persistence/PartitionInfoTest.java | 72 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 33 +-
.../multileader/MultiLeaderConsensus.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 23 +-
.../consensus/standalone/StandAloneConsensus.java | 10 +-
.../consensus/standalone/StandAloneServerImpl.java | 2 +
.../{standalone => }/EmptyStateMachine.java | 3 +-
.../{standalone => multileader}/RecoveryTest.java | 16 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 120 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 1 +
.../standalone/StandAloneConsensusTest.java | 1 +
docs/Download/README.md | 20 +-
docs/UserGuide/API/Programming-MQTT.md | 7 +-
.../UserGuide/API/Programming-Python-Native-API.md | 209 +-
.../Ecosystem Integration/Grafana Plugin.md | 21 +-
.../Maintenance-Tools/Maintenance-Command.md | 67 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 32 +-
docs/UserGuide/Reference/Keywords.md | 24 -
docs/UserGuide/Reference/Syntax-Conventions.md | 22 +-
docs/UserGuide/UDF-Library/String-Processing.md | 656 +++-
docs/zh/Download/README.md | 21 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 7 +-
.../UserGuide/API/Programming-Python-Native-API.md | 205 +-
.../Ecosystem Integration/Grafana Plugin.md | 18 +-
.../Maintenance-Tools/Maintenance-Command.md | 63 +
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 32 +-
docs/zh/UserGuide/Reference/Keywords.md | 24 -
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 27 +-
docs/zh/UserGuide/UDF-Library/String-Processing.md | 652 +++-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 7 +
{metrics => example/rest-java-example}/pom.xml | 37 +-
.../main/java/org/apache/iotdb/HttpExample.java | 141 +
.../main/java/org/apache/iotdb/HttpsExample.java | 144 +
.../src/main/java/org/apache/iotdb/SSLClient.java | 83 +
.../java/org/apache/iotdb/udf/UDTFExample.java | 22 +-
...Apache IoTDB ConfigNode Dashboard v0.14.0.json} | 802 ++--
.../Apache IoTDB DataNode Dashboard v0.14.0.json} | 107 +-
.../Apache IoTDB Dashboard v0.13.1.json | 0
.../Apache IoTDB Dashboard v0.14.0.json | 0
integration-test/README.md | 27 +-
integration-test/import-control.xml | 23 +-
.../iotdb/db/query/udf/example/Accumulator.java | 28 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 22 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 22 +-
.../iotdb/db/query/udf/example/Multiplier.java | 22 +-
.../SlidingSizeWindowConstructorTester0.java | 16 +-
.../SlidingSizeWindowConstructorTester1.java | 22 +-
.../SlidingTimeWindowConstructionTester.java | 22 +-
.../db/query/udf/example/TerminateTester.java | 18 +-
.../iotdb/db/query/udf/example/ValidateTester.java | 20 +-
.../iotdb/db/query/udf/example/WindowStartEnd.java | 18 +-
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 4 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 248 +-
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 11 +
.../org/apache/iotdb/it/env/ClusterNodeBase.java | 188 +-
.../java/org/apache/iotdb/it/env/ConfigNode.java | 151 +-
.../java/org/apache/iotdb/it/env/DataNode.java | 132 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../env/{Cluster1Env.java => IoTDBTestRunner.java} | 24 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 4 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 16 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 2 +
.../itbase/runtime/ClusterResultSetMetaData.java | 239 ++
.../itbase/runtime/ClusterTestConnection.java | 333 ++
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 1178 ++++++
.../iotdb/itbase/runtime/ClusterTestStatement.java | 319 ++
.../itbase/runtime/InconsistentDataException.java | 10 +-
.../iotdb/itbase/runtime/NodeConnection.java | 85 +
.../itbase/runtime/ParallelRequestDelegate.java | 60 +
.../iotdb/itbase/runtime/RequestDelegate.java | 86 +
.../iotdb/itbase/runtime/RequestThreadPool.java | 44 +-
.../itbase/runtime/SerialRequestDelegate.java | 40 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 3 +
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 8 +-
...regationWithoutValueFilterWithDeletion2IT.java} | 29 +-
...ggregationWithoutValueFilterWithDeletionIT.java | 180 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 4010 +++++++++++++++++---
...upByQueryWithoutValueFilterWithDeletion2IT.java | 45 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 263 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 120 +
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 121 +
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 78 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 294 ++
...2IT.java => IoTDBLastQueryWithDeletion2IT.java} | 25 +-
...heIT.java => IoTDBLastQueryWithDeletionIT.java} | 275 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 3 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 19 +-
...BLastQueryWithoutLastCacheWithDeletion2IT.java} | 23 +-
...DBLastQueryWithoutLastCacheWithDeletionIT.java} | 30 +-
...RawQueryWithoutValueFilterWithDeletion2IT.java} | 28 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 407 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 8 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 16 +
.../db/it/udf/BuiltinAggregationFunctionEnum.java | 58 +
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 87 +
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 339 ++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 1233 ++++++
integration/checkstyle.xml | 2 +-
.../iotdb/db/query/udf/example/Accumulator.java | 28 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 22 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 22 +-
.../iotdb/db/query/udf/example/Multiplier.java | 22 +-
.../SlidingSizeWindowConstructorTester0.java | 16 +-
.../SlidingSizeWindowConstructorTester1.java | 22 +-
.../SlidingTimeWindowConstructionTester.java | 22 +-
.../db/query/udf/example/TerminateTester.java | 18 +-
.../iotdb/db/query/udf/example/ValidateTester.java | 20 +-
.../iotdb/db/query/udf/example/WindowStartEnd.java | 18 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 8 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 138 +
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 14 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 5 +-
.../IoTDBSyntaxConventionIdentifierIT.java | 5 +
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 398 --
.../IoTDBAggregationWithoutValueFilter2IT.java | 65 -
.../IoTDBAggregationWithoutValueFilterIT.java | 456 ---
...gregationWithoutValueFilterWithDeletion2IT.java | 82 -
.../integration/aligned/IoTDBAlignByDevice2IT.java | 67 -
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1623 --------
.../IoTDBGroupByQueryWithoutValueFilter2IT.java | 65 -
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 1128 ------
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 --
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 -
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 --
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 -
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 --
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 -
.../session/IoTDBSessionDisableMemControlIT.java | 16 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 8 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 8 +-
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 23 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 21 +-
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 23 +-
.../iotdb/library/anomaly/UDTFMissDetect.java | 21 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 21 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 21 +-
.../iotdb/library/anomaly/util/MissDetector.java | 4 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 4 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 26 +-
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 26 +-
.../apache/iotdb/library/dmatch/UDAFPearson.java | 26 +-
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 23 +-
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 24 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 20 +-
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 28 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 28 +-
.../apache/iotdb/library/dprofile/UDAFMode.java | 17 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFSkew.java | 23 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 25 +-
.../apache/iotdb/library/dprofile/UDAFStddev.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 23 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 26 +-
.../iotdb/library/dprofile/UDTFHistogram.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 25 +-
.../apache/iotdb/library/dprofile/UDTFPACF.java | 23 +-
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 23 +-
.../iotdb/library/dprofile/UDTFResample.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFSpline.java | 23 +-
.../apache/iotdb/library/dprofile/UDTFZScore.java | 23 +-
.../dprofile/util/ExactOrderStatistics.java | 41 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 18 +-
.../iotdb/library/dquality/UDTFConsistency.java | 18 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 18 +-
.../iotdb/library/dquality/UDTFValidity.java | 18 +-
.../library/dquality/util/TimeSeriesQuality.java | 4 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 19 +-
.../iotdb/library/drepair/UDTFValueFill.java | 19 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 19 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 4 +-
.../iotdb/library/drepair/util/LikelihoodFill.java | 2 +-
.../iotdb/library/drepair/util/LinearFill.java | 2 +-
.../iotdb/library/drepair/util/LsGreedy.java | 2 +-
.../apache/iotdb/library/drepair/util/MAFill.java | 2 +-
.../iotdb/library/drepair/util/MeanFill.java | 2 +-
.../iotdb/library/drepair/util/PreviousFill.java | 2 +-
.../apache/iotdb/library/drepair/util/Screen.java | 2 +-
.../iotdb/library/drepair/util/ScreenFill.java | 4 +-
.../library/drepair/util/TimestampRepair.java | 4 +-
.../iotdb/library/drepair/util/ValueFill.java | 6 +-
.../iotdb/library/drepair/util/ValueRepair.java | 4 +-
.../apache/iotdb/library/frequency/UDTFConv.java | 26 +-
.../apache/iotdb/library/frequency/UDTFDWT.java | 23 +-
.../apache/iotdb/library/frequency/UDTFDeconv.java | 26 +-
.../apache/iotdb/library/frequency/UDTFFFT.java | 23 +-
.../iotdb/library/frequency/UDTFHighPass.java | 23 +-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 23 +-
.../apache/iotdb/library/frequency/UDTFIFFT.java | 23 +-
.../iotdb/library/frequency/UDTFLowPass.java | 23 +-
.../iotdb/library/frequency/util/FFTUtil.java | 2 +-
.../library/series/UDTFConsecutiveSequences.java | 20 +-
.../library/series/UDTFConsecutiveWindows.java | 20 +-
.../iotdb/library/series/util/ConsecutiveUtil.java | 4 +-
.../iotdb/library/string/UDTFRegexMatch.java | 22 +-
.../iotdb/library/string/UDTFRegexReplace.java | 22 +-
.../iotdb/library/string/UDTFRegexSplit.java | 22 +-
.../iotdb/library/string/UDTFStrReplace.java | 22 +-
.../iotdb/library/util/LinearRegression.java | 2 +-
.../java/org/apache/iotdb/library/util/Util.java | 4 +-
.../reporter/MicrometerPrometheusReporter.java | 1 +
.../micrometer/MicrometerMetricManagerTest.java | 12 +
metrics/pom.xml | 41 +
node-commons/pom.xml | 5 +
.../UDFException.java => cluster/NodeStatus.java} | 18 +-
.../RegionStatus.java} | 17 +-
.../iotdb/commons/partition/DataPartition.java | 3 +-
.../iotdb/commons/partition/SchemaPartition.java | 3 +-
.../BuiltinTimeSeriesGeneratingFunction.java | 21 +
.../commons/udf/builtin/String/UDTFConcat.java | 74 +
.../commons/udf/builtin/String/UDTFEndsWith.java | 51 +
.../commons/udf/builtin/String/UDTFLower.java | 48 +
.../commons/udf/builtin/String/UDTFStartsWith.java | 50 +
.../commons/udf/builtin/String/UDTFStrCompare.java | 55 +
.../commons/udf/builtin/String/UDTFStrLength.java | 48 +
.../commons/udf/builtin/String/UDTFStrLocate.java | 60 +
.../commons/udf/builtin/String/UDTFSubstr.java | 70 +
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 48 +
.../commons/udf/builtin/String/UDTFUpper.java | 48 +
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 28 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 17 +-
.../apache/iotdb/commons/udf/builtin/UDTFCast.java | 28 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 16 +-
.../udf/builtin/UDTFCommonValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 24 +-
.../iotdb/commons/udf/builtin/UDTFConstE.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFConstPi.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFContains.java | 24 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 47 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 21 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 29 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 28 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 32 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 26 +-
.../udf/builtin/UDTFEqualSizeBucketSample.java | 14 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 64 +-
.../iotdb/commons/udf/builtin/UDTFMatches.java | 24 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 36 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 16 +-
.../builtin/UDTFNonNegativeValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 35 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 58 +-
.../commons/udf/builtin/UDTFTimeDifference.java | 18 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 17 +-
.../commons/udf/builtin/UDTFValueDifference.java | 19 +-
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 24 +-
.../udf/service/UDFRegistrationInformation.java | 2 +-
.../udf/service/UDFRegistrationService.java | 4 +-
.../commons/udf/utils/UDFBinaryTransformer.java | 29 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 77 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 22 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 14 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 6 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 4 +
.../iotdb/commons/client/ClientManagerTest.java | 29 +-
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 3 +-
pom.xml | 1 +
.../resources/conf/iotdb-engine.properties | 2 +-
server/src/assembly/resources/conf/iotdb-env.bat | 8 +-
.../assembly/resources/conf/iotdb-rest.properties | 3 +
server/src/assembly/resources/conf/logback.xml | 13 +-
.../src/assembly/resources/sbin/start-datanode.sh | 63 +
.../assembly/resources/sbin/start-new-server.sh | 63 +
server/src/assembly/resources/sbin/start-server.sh | 63 +
.../apache/iotdb/db/auth/AuthorizerManager.java | 18 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 51 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 9 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 20 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 62 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 11 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 3 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 96 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 63 +-
.../db/engine/compaction/CompactionScheduler.java | 6 +-
.../DefaultCompactionTaskComparatorImpl.java | 17 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 6 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 6 +-
.../compaction/task/AbstractCompactionTask.java | 9 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 56 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 54 +-
.../db/engine/storagegroup/TsFileManager.java | 6 +
.../dataregion/StorageGroupManager.java | 23 +-
.../metadata/DataTypeMismatchException.java | 18 +-
....java => MeasurementAlreadyExistException.java} | 24 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 106 +-
.../localconfignode/LocalDataPartitionTable.java | 8 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 5 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 19 +-
.../db/metadata/schemaregion/SchemaEngine.java | 145 +-
.../metadata/schemaregion/SchemaRegionUtils.java | 13 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 163 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 3 +
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 3 +
.../db/mpp/aggregation/ExtremeAccumulator.java | 3 +
.../db/mpp/aggregation/FirstValueAccumulator.java | 3 +
.../db/mpp/aggregation/LastValueAccumulator.java | 3 +
.../db/mpp/aggregation/MaxTimeAccumulator.java | 3 +
.../db/mpp/aggregation/MaxValueAccumulator.java | 3 +
.../db/mpp/aggregation/MinTimeAccumulator.java | 3 +
.../db/mpp/aggregation/MinValueAccumulator.java | 3 +
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 3 +
.../iotdb/db/mpp/common/header/ColumnHeader.java | 6 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 18 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 24 +
.../db/mpp/common/schematree/PathPatternTree.java | 276 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 3 +-
.../execution/datatransfer/DataBlockManager.java | 116 +-
.../execution/datatransfer/LocalSinkHandle.java | 86 +-
.../execution/datatransfer/LocalSourceHandle.java | 70 +-
.../execution/datatransfer/SharedTsBlockQueue.java | 53 +-
.../db/mpp/execution/datatransfer/SinkHandle.java | 36 +-
.../mpp/execution/datatransfer/SourceHandle.java | 134 +-
.../fragment/FragmentInstanceExecution.java | 35 +-
.../execution/fragment/FragmentInstanceState.java | 4 +-
.../fragment/FragmentInstanceStateMachine.java | 7 +-
.../operator/process/TransformOperator.java | 4 +
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../AlignedSeriesAggregationScanOperator.java | 10 +-
.../source/SeriesAggregationScanOperator.java | 8 +-
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 4 +-
.../mpp/execution/schedule/DriverTaskThread.java | 71 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 15 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 120 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 12 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 210 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 20 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 53 +-
.../mpp/plan/analyze/GroupByLevelController.java | 57 +-
.../plan/analyze/StandalonePartitionFetcher.java | 3 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 20 +-
.../db/mpp/plan/constant/DataNodeEndPoints.java | 4 +
.../iotdb/db/mpp/plan/constant/StatementType.java | 3 +-
.../db/mpp/plan/execution/QueryExecution.java | 67 +-
.../mpp/plan/execution/config/AuthorizerTask.java | 67 +-
.../mpp/plan/execution/config/ConfigExecution.java | 27 +-
.../plan/execution/config/ConfigTaskVisitor.java | 12 +
.../execution/config/CountStorageGroupTask.java | 51 +-
.../plan/execution/config/CreateFunctionTask.java | 74 +-
.../execution/config/DeleteStorageGroupTask.java | 69 +-
.../plan/execution/config/DropFunctionTask.java | 65 +-
.../db/mpp/plan/execution/config/FlushTask.java | 66 +
.../db/mpp/plan/execution/config/IConfigTask.java | 7 +-
.../plan/execution/config/SetStorageGroupTask.java | 68 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 58 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 70 +-
.../plan/execution/config/ShowFunctionsTask.java | 7 +-
.../mpp/plan/execution/config/ShowRegionTask.java | 86 +
.../execution/config/ShowStorageGroupTask.java | 64 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 85 +-
.../config/executor/ClusterConfigTaskExecutor.java | 343 ++
.../config/executor/IConfigTaskExecutor.java | 64 +
.../executor/StandaloneConfigTaskExecutor.java | 271 ++
.../plan/expression/multi/FunctionExpression.java | 5 +-
.../db/mpp/plan/expression/unary/InExpression.java | 6 +-
.../mpp/plan/expression/unary/LikeExpression.java | 8 +-
.../plan/expression/unary/RegularExpression.java | 8 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 51 +
.../db/mpp/plan/parser/StatementGenerator.java | 1 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 57 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 31 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 102 +-
.../planner/distribution/ExchangeNodeAdder.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 13 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 12 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 2 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../mpp/plan/planner/plan/node/PlanNodeUtil.java | 9 +
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 7 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 5 +
.../node/metedata/read/SchemaFetchScanNode.java | 10 +
.../node/metedata/read/SchemaQueryScanNode.java | 8 +
.../write/InternalCreateTimeSeriesNode.java} | 124 +-
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 7 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 3 +-
.../source/AlignedSeriesAggregationScanNode.java | 5 +-
.../plan/node/source/AlignedSeriesScanNode.java | 3 +-
.../plan/node/source/LastQueryScanNode.java | 5 +-
.../node/source/SeriesAggregationScanNode.java | 3 +-
.../planner/plan/node/source/SeriesScanNode.java | 5 +-
.../plan/node/write/InsertMultiTabletsNode.java | 10 +
.../plan/planner/plan/node/write/InsertNode.java | 8 +-
.../planner/plan/node/write/InsertRowNode.java | 17 +-
.../planner/plan/node/write/InsertRowsNode.java | 10 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 10 +
.../planner/plan/node/write/InsertTabletNode.java | 40 +
.../plan/parameter/AggregationDescriptor.java | 68 +-
.../plan/parameter/GroupByLevelDescriptor.java | 15 +-
.../scheduler/AbstractFragInsStateTracker.java | 1 -
.../db/mpp/plan/scheduler/ClusterScheduler.java | 32 +-
.../scheduler/FixedRateFragInsStateTracker.java | 5 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 14 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 1 -
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 25 +-
.../db/mpp/plan/statement/StatementVisitor.java | 18 +-
.../mpp/plan/statement/crud/InsertStatement.java | 29 +
.../InternalCreateTimeSeriesStatement.java} | 40 +-
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../statement/metadata/ShowRegionStatement.java | 54 +
.../db/mpp/plan/statement/sys/FlushStatement.java | 91 +
.../db/mpp/transformation/api/LayerRowReader.java | 2 +-
.../transformation/api/LayerRowWindowReader.java | 2 +-
...ializableRowRecordListBackedMultiColumnRow.java | 16 +-
...izableRowRecordListBackedMultiColumnWindow.java | 12 +-
...wRecordListBackedMultiColumnWindowIterator.java | 4 +-
...ticSerializableTVListBackedSingleColumnRow.java | 14 +-
...SerializableTVListBackedSingleColumnWindow.java | 13 +-
...ableTVListBackedSingleColumnWindowIterator.java | 4 +-
.../LayerPointReaderBackedSingleColumnRow.java | 14 +-
.../intermediate/ConstantIntermediateLayer.java | 4 +-
.../dag/intermediate/IntermediateLayer.java | 6 +-
.../MultiInputColumnIntermediateLayer.java | 8 +-
...InputColumnMultiReferenceIntermediateLayer.java | 8 +-
...nputColumnSingleReferenceIntermediateLayer.java | 8 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 5 +-
.../dag/transformer/unary/InTransformer.java | 14 +-
.../dag/transformer/unary/RegularTransformer.java | 4 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 24 +-
.../transformation/dag/udf/UDTFTypeInferrer.java | 17 +-
.../transformation/dag/util/LayerCacheUtils.java | 9 +-
.../tv/ElasticSerializableBinaryTVList.java | 15 +-
.../tv/ElasticSerializableTVList.java | 27 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 15 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 163 +
.../apache/iotdb/db/protocol/rest/RestService.java | 13 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 4 +-
.../qp/physical/crud/InsertMultiTabletsPlan.java | 6 +
.../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 12 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 6 +
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 6 +
.../db/qp/physical/crud/InsertTabletPlan.java | 35 +
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 100 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 10 +-
.../org/apache/iotdb/db/service/MQTTService.java | 12 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 10 +-
.../iotdb/db/service/metrics/enums/Metric.java | 7 +-
.../recorder/CompactionMetricsRecorder.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 45 +-
.../service/thrift/impl/InternalServiceImpl.java | 78 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 2 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 8 +-
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 3 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 42 +-
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 3 +-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 3 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 19 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 4 +-
.../compaction/CompactionTaskComparatorTest.java | 74 +-
.../compaction/CompactionTaskManagerTest.java | 27 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 9 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 12 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 3 +-
.../db/engine/storagegroup/DataRegionTest.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 3 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../mpp/common/schematree/PathPatternTreeTest.java | 10 +-
.../db/mpp/execution/ConfigExecutionTest.java | 7 +-
.../datatransfer/LocalSourceHandleTest.java | 2 +-
.../schema/SchemaFetchScanOperatorTest.java | 4 +-
.../plan/analyze/AggregationDescriptorTest.java | 20 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 7 +
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 16 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 90 +-
.../distribution/AggregationDistributionTest.java | 24 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 9 +-
.../node/process/AggregationNodeSerdeTest.java | 36 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 18 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 58 +
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 7 +-
.../ElasticSerializableTVListTest.java | 6 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
server/src/test/resources/iotdb-rest.properties | 3 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 9 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 9 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
session/src/test/resources/iotdb-rest.properties | 3 +
thrift-commons/src/main/thrift/common.thrift | 29 +-
.../src/main/thrift/confignode.thrift | 27 +
thrift/src/main/thrift/mpp.thrift | 2 +
.../tsfile/file/metadata/enums/TSDataType.java | 6 +-
.../block/column/BinaryArrayColumnEncoder.java | 5 +-
.../block/column/ByteArrayColumnEncoder.java | 5 +-
.../read/common/block/column/ColumnEncoder.java | 9 +-
.../common/block/column/ColumnEncoderFactory.java | 3 +-
.../read/common/block/column/ColumnEncoding.java | 6 +-
.../block/column/Int32ArrayColumnEncoder.java | 8 +-
.../block/column/Int64ArrayColumnEncoder.java | 21 +-
.../block/column/RunLengthColumnEncoder.java | 54 +
.../block/column/RunLengthEncodedColumn.java | 2 +-
.../read/common/block/column/TsBlockSerde.java | 19 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 8 +-
.../common/block/ByteArrayColumnEncoderTest.java | 9 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 15 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 17 +-
...erTest.java => RunLengthColumnEncoderTest.java} | 75 +-
{metrics => udf-api}/pom.xml | 17 +-
.../main/java/org/apache/iotdb}/udf/api/UDF.java | 8 +-
.../main/java/org/apache/iotdb}/udf/api/UDTF.java | 20 +-
.../java/org/apache/iotdb}/udf/api/access/Row.java | 8 +-
.../apache/iotdb}/udf/api/access/RowIterator.java | 2 +-
.../apache/iotdb}/udf/api/access/RowWindow.java | 10 +-
.../iotdb}/udf/api/collector/PointCollector.java | 56 +-
.../api/customizer/config/UDFConfigurations.java | 8 +-
.../api/customizer/config/UDTFConfigurations.java | 24 +-
.../parameter/UDFParameterValidator.java | 47 +-
.../api/customizer/parameter/UDFParameters.java | 29 +-
.../api/customizer/strategy/AccessStrategy.java | 8 +-
.../strategy/RowByRowAccessStrategy.java | 12 +-
.../strategy/SlidingSizeWindowAccessStrategy.java | 12 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 12 +-
.../UDFAttributeNotProvidedException.java | 2 +-
.../iotdb}/udf/api/exception/UDFException.java | 2 +-
.../UDFInputSeriesDataTypeNotValidException.java | 10 +-
.../UDFInputSeriesIndexNotValidException.java | 2 +-
.../UDFInputSeriesNumberNotValidException.java | 2 +-
.../UDFOutputSeriesDataTypeNotValidException.java | 2 +-
.../exception/UDFParameterNotValidException.java | 2 +-
.../api/exception/UDFRegistrationException.java | 2 +-
.../java/org/apache/iotdb/udf/api/type/Binary.java | 150 +
.../java/org/apache/iotdb/udf/api/type/Type.java | 35 +-
600 files changed, 21901 insertions(+), 12297 deletions(-)
create mode 100644 client-py/iotdb/dbapi/Connection.py
create mode 100644 client-py/iotdb/dbapi/Cursor.py
copy client-py/iotdb/{tsfile/utils/Pair.py => dbapi/Exceptions.py} (61%)
copy client-py/{requirements.txt => iotdb/dbapi/__init__.py} (82%)
copy client-py/iotdb/{ => dbapi/tests}/__init__.py (100%)
create mode 100644 client-py/iotdb/dbapi/tests/test_connection.py
create mode 100644 client-py/iotdb/dbapi/tests/test_cursor.py
create mode 100644 client-py/iotdb/sqlalchemy/IoTDBDialect.py
copy client-py/iotdb/{tsfile/utils/Pair.py =>
sqlalchemy/IoTDBIdentifierPreparer.py} (72%)
create mode 100644 client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py
copy client-py/iotdb/{template/TemplateNode.py =>
sqlalchemy/IoTDBTypeCompiler.py} (56%)
copy client-py/iotdb/{ => sqlalchemy}/__init__.py (100%)
copy client-py/iotdb/{ => sqlalchemy/tests}/__init__.py (100%)
create mode 100644 client-py/iotdb/sqlalchemy/tests/test_dialect.py
copy client-py/iotdb/{tsfile/utils/Pair.py => template/TemplateQueryType.py}
(62%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/conf/{ConfigNodeConf.java
=> ConfigNodeConfig.java} (96%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetRegionLocationsReq.java
copy
consensus/src/test/java/org/apache/iotdb/consensus/standalone/EmptyStateMachine.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/RegionLocationsResp.java
(57%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatWindow.java
rename consensus/src/test/java/org/apache/iotdb/consensus/{standalone =>
}/EmptyStateMachine.java (94%)
copy consensus/src/test/java/org/apache/iotdb/consensus/{standalone =>
multileader}/RecoveryTest.java (88%)
copy {metrics => example/rest-java-example}/pom.xml (57%)
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/HttpExample.java
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/HttpsExample.java
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/SSLClient.java
copy grafana-metrics-example/{Apache IoTDB Dashboard v0.14.0.json =>
cluster/Apache IoTDB ConfigNode Dashboard v0.14.0.json} (71%)
copy grafana-metrics-example/{Apache IoTDB Dashboard v0.13.1.json =>
cluster/Apache IoTDB DataNode Dashboard v0.14.0.json} (97%)
rename grafana-metrics-example/{ => standalone}/Apache IoTDB Dashboard
v0.13.1.json (100%)
rename grafana-metrics-example/{ => standalone}/Apache IoTDB Dashboard
v0.14.0.json (100%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/{Cluster1Env.java
=> IoTDBTestRunner.java} (54%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterResultSetMetaData.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/api/exception/UDFAttributeNotProvidedException.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/InconsistentDataException.java
(71%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/NodeConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ParallelRequestDelegate.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestDelegate.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatCache.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestThreadPool.java
(51%)
copy
library-udf/src/main/java/org/apache/iotdb/library/drepair/util/PreviousFill.java
=>
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/SerialRequestDelegate.java
(52%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBAggregationWithoutValueFilterWithDeletion2IT.java} (71%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBAggregationWithoutValueFilterWithDeletionIT.java
(65%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletion2IT.java
(63%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletionIT.java
(82%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithDeletion2IT.java} (75%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheIT.java
=> IoTDBLastQueryWithDeletionIT.java} (51%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java} (76%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletionIT.java} (70%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java} (71%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
(52%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/BuiltinAggregationFunctionEnum.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/BuiltinTimeSeriesGeneratingFunctionEnum.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFManagementIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDTFBuiltinFunctionIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileWithVirtualSGIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFManagementIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDevice2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDeviceIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/api/exception/UDFException.java
=> cluster/NodeStatus.java} (70%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/api/exception/UDFException.java
=> cluster/RegionStatus.java} (74%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFConcat.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFEndsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFLower.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStartsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrCompare.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLength.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLocate.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFSubstr.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFTrim.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFUpper.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/Cluster1Env.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFBinaryTransformer.java
(51%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{DataTypeMismatchException.java
=> MeasurementAlreadyExistException.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/FlushTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowRegionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/IConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/{source/AlignedLastQueryScanNode.java
=> metedata/write/InternalCreateTimeSeriesNode.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/CreateTimeSeriesByDeviceStatement.java
=> internal/InternalCreateTimeSeriesStatement.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowRegionStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/FlushStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthColumnEncoder.java
copy
tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/{BinaryArrayColumnEncoderTest.java
=> RunLengthColumnEncoderTest.java} (53%)
copy {metrics => udf-api}/pom.xml (73%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/UDF.java (83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/UDTF.java (86%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/Row.java (95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/RowIterator.java (96%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/RowWindow.java (91%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/collector/PointCollector.java
(75%)
copy {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/config/UDFConfigurations.java
(83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/config/UDTFConfigurations.java
(78%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/parameter/UDFParameterValidator.java
(81%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/parameter/UDFParameters.java
(81%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/AccessStrategy.java
(85%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/RowByRowAccessStrategy.java
(83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java
(91%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFAttributeNotProvidedException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java
(79%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesIndexNotValidException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesNumberNotValidException.java
(96%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFOutputSeriesDataTypeNotValidException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFParameterNotValidException.java
(94%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFRegistrationException.java
(95%)
create mode 100644
udf-api/src/main/java/org/apache/iotdb/udf/api/type/Binary.java
rename
node-commons/src/main/java/org/apache/iotdb/commons/udf/api/customizer/config/UDFConfigurations.java
=> udf-api/src/main/java/org/apache/iotdb/udf/api/type/Type.java (61%)
