You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2023/05/12 08:35:46 UTC
[iotdb] branch cpu-monitor updated (9e86dce0929 -> f955a52fe3a)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch cpu-monitor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 9e86dce0929 refactor query thread name
discard 7b4286ce409 add all thread name in datanode
discard ab9809db8b4 temp
discard a69f654bb8e temp
add 44dfbf1b18c [IOTDB-5091] The multi-tenancy design about iotdb - add throtttle quota (#9534)
add c951bb67024 [IOTDB-5752] Python Client supports write redirection (#9467)
add 04688d82c00 Remove the useless generated python code for python client (#9578)
add 5c409fce6a6 [DOC] Remove iotd-deploy.md (#9577)
add 5739b1ca1b6 Added two pieces to the document, respectively the community and download sections (#9575)
add 6a3ade356fd [IOTDB-5767] [IoTDB ML] Support delete model file and metrics (#9573)
add 4dd386b1f1d Add Conditional Expression to sidebar
add 58782685fa9 Bump scalatest_2.12 from 3.0.2 to 3.0.9 (#7617)
add d7fdea51f52 Improve ineffective check in ColumnEncoderFactory
add 274cdab1ce3 [IOTDB-5769] Fix offset doesn't take effect in some special case
add 4128525dd6a Fix NPE when deregister fragmentInstance
add 7c70b218938 Fix potential NPE in SinkChannel
add 5b1d362f7bb [IOTDB-5764] Fix that cannot specify alias successfully when the FROM clause contains multiple path suffixes
add 40f00c6cbb8 [IOTDB-5763] Optimize the memory estimate for INTO operations
add 7486211e962 Optimize updateLastCache interface (#9586)
add 8726b9a32df [IOTDB-5671] add SPRINTZ and RLBE encodor and LZMA2 compressor (#9536)
add 0843ffa8569 Fix MemoryPool free NPE
add f27a09d0abe bump ratis version to 2.5.0 (#9587)
add 83a85b1eafa Fix Performance Overview Dashboard localScheduler record inaccurately (#9549)
add 7538477504a [IOTDB-5766] Refactor listener of ISinkChannel to ensure that ShuffleSinkHandle is closed properly
add c364449170f [IOTDB-5726]Select the last sealed seq file for nonOverlap unseq files to compact in cross compaction (#9501)
add 2ae6ae9c481 Fix unexcepted error message when use raw query with Group By Tag
add 39438b6cb17 Update Metric-Tool.md
add 04f140f8bf2 remove session metrics when close (#9604)
add 88baa23e2c9 [DOC] remove site configuration of stale M4 function document (#9562)
add d2e03dba6fe Fix Group By Tag with empty grouped timeseries
add 6270ed77b5b [ISSUE-9611] Reduce the size of UDF-Library jar (#9610)
add fae06602d5a [IOTDB-5768] Fixed the bug that IoTDB will create pipe dir outside of IoTDB directory (#9616)
add 935b5106ed1 [IOTDB-5762][Metric] add do nothing level(#9615)
add 8cd4c61a1cd Fixed resource stop failure after remote scheduling retry
add df88dc93e48 Distinguish whether an exception has occurred when releasing the QueryExecution resource
add 110ea557860 [IOTDB-5727] pipe task management at config node (#9533)
add 1569d176344 add a notice of time_duration function to indicate some specific situations (#9594)
add f72560bca2c [IOTDB-5570] Move heartbeat thread and statistics thread to load manager (#9608)
add 53eae3d6efd [DOC][Grafana Plugin] Update the user manual for alerting (#9622)
add d4fbe76f918 [IOTDB-5727][hotfix] Hide PipeInfo from PipeManager (#9639)
add 8b163c2f1ce [IOTDB-5675] Recover template activation statistics when redoing MLog (#9571)
add 0547018b23e [IOTDB-5776]Update memory estimation of cross space compaction (#9627)
add b9fa37c9129 [IOTDB-5786] Fix potential deadlock in DriverScheduler
add c97c0dc2a73 [IOTDB-5691] The first level-0 tsfile too large to trigger "Unsequence InnerSpaceComapction" and "CrossSpaceCompaction" (#9503)
add 31d3c089fad Bump jetty-server from 9.4.49.v20220914 to 9.4.51.v20230217 (#9641)
add 544a33b0a6c Fix potential Npe of ShuffleSinkHandle
add e12afecd6eb [IOTDB-5735] Fix result of some UDF with align by device is incorrect (#9642)
add b02502fa143 [IOTDB-4837] Refactor Set Schema Template (#9637)
add f13699611f9 [IOTDB-5798] Fix concurrent problem when sinkChannel acknowledgeTsBlock() and close()
add 98adb10391c [IOTDB-5773] fix set space quota problem (#9596)
add 348763f2087 Add a cache to avoid initialize duplicated device id object in write process (#9644)
add 9870f332d61 Resolve quadratic complexity issue when flushing numerous Internal/Entity nodes in SchemaFile (#9659)
add 3405c49177a Accelerate count all schema via schema statistic (#9660)
add bc9ee590ede [IOTDB-5720] Fix release processor fail to release memory due to writer-preferred starvation (#9661)
add c19bcdc5f18 Double-check protect memory-control boundary to avoid concurrent bug (#9662)
add 4a822f2da1c TemplateSchemaCache in schema fetcher (#9664)
add e15a3c770bd [IOTDB-5774] Fix the syntax that path nodes start or end with a wildcard to fuzzy match is not supported (#9600)
add 2893e362cfd [To master] Change the documentation about OpenID login (#9668)
add 06ee7cca940 [IOTDB-3565] Support Dynamic Schema Template (#9663)
add 9b194dcac6f [IOTDB-5784] Incorrect result when querying with offset push-down and time filter
add 50e419f1324 feat(site): fix display error for docs has table (#9669)
add 3bf31903e49 [IOTDB-3565] Update User-Guide for Dynamic Template (#9672)
add 73fbcd1b2e4 [grafana plugin] update grafanaDependency (>= 9.3.0) in plugin.json (#9678)
add 3412975a4af Fix NPE when using template and executing select into (#9679)
add e3e83fe8aae [IOTDB-5788] Built-in pipe plug-in management mechanism (#9680)
add 8b52e79bb36 [IOTDB-5791] Construct Cluster-LoadPublisher-Thread and IClusterStatusSubscriber (#9645)
add 22b04f1bc8a Remove check of closed state in ISink
add 6767a142ca7 Update Programming-Go-Native-API.md (#9688)
add 6a8d009a725 Remove unecessary synchronized on decrementCnt of SinkListener
add d92ea6e77c6 [IOTDB-5567] improve show cluster slots information (#9665)
add e8bf6ef1a8e [IOTDB-5810] Result handle in memory pool is not be cleaned properly (#9685)
add 104a8bf26fb Fix concurrent state change bug in QueryStateMachine
add 969995276b0 Combine DataNodeSchemaCache of Template and Non-Template Scenarios (#9687)
add ce843c2c060 [IOTDB-5779] PipeConnector reuse strategy based on reference count mechanism (#9629)
add 40202144235 [IoTDB-5721] Streaming query DataPartition and Schema while loading TsFile (#9684)
add 29e7e1a8516 [IOTDB-5662] Fix BufferedUnderflowException occurs in inner space compaction (#9322)
add 04a074b4acb [IOTDB-5841] Remove duplicate schema template IT (#9693)
add e1103a96d66 [IOTDB-5183] Use default snapshot installation path for confignode & schema region
add 7d4fdc781f7 [IOTDB-5812] Reduce useless create of PartialPath in auth module (#9691)
add 809431fd7ef Bump yaml from 2.2.1 to 2.2.2 in /site/src/main (#9705)
add b6f78dcee2f Support update last cache for data insertion when using template (#9696)
add 8d7ca050ccd [IOTDB-5807]Fix decompression error for aligned series in fast compaction (#9701)
add 86be5ea16a7 [IOTDB-5803] Improve query performance by reducing cpu consuming
add c7a6184c01d [IOTDB-5819] Fix npe when booting net metrics (#9698)
add f77f3fd5726 [IOTDB-5704] Change default parameters for wal part (#9394)
add 0a15a9020f4 Correct ASYNC_DATANODE_IOT_CONSENSUS_CLIENT_POOL name
add 33f5f6ec788 [IOTDB-5824] Fix show devices with * cannot display satisfied devices (#9715)
add 5d77c446ea7 [IOTDB-5815] Fix Npe when UDF spilling data to disk
add ed8d5396025 [IOTDB-5739] Pipe realtime event process: listener -> assigner -> matcher -> collector (#9479)
add b5f5d7465c5 Sort the result of AlignedUpdateLastCacheOperator for LastQueryMergeOperator
add c2ce85a3c87 Simplify collect redirect Info logic (#9675)
add 56bcde6d15d [IOTDB-5826] Fix schema query with * cannot display satisfied template series (#9723)
add 89b2b96a6f2 Change default multi_dir_strategy to SequenceStrategy and fix original bug (#9718)
add ba4dea63069 [IOTDB-5765] Support ORDER BY expression [FE Part]
add e2114510329 Avoid Result Handle clean up twice which will cause NPE
add 8db6527e80c [IOTDB-5825]Fix error in aligned empty value chunk in fast compaction (#9719)
add 17711231b88 [IOTDB-5834] Fix unclear error msg when querying nonexistent schema template (#9738)
add 87ea559d63b [rest service] support show data regionid query (#9737)
add ad3c2979610 [IOTDB-5835] Fix wal accumulation caused by datanode restart
add 0a7d2b73d8b [IOTDB-5832] Fix Bug: The size of readyQueue is negative incorrectly
add efc61e2b06a update disk usage and file num when delete wal node (#9730)
add 5fb6e2b76c6 [IOTDB-5701] Upgrade Performance Overview Metrics to Core (#9741)
add f6e8473a8dd [IOTDB-5817] Optimize error message of python client (#9744)
add 970f727721b add dn_consensus_dir doc (#9729)
add dbd1f93dd6a [IOTDB-5831] Fix drop database won't delete totally files in disk during data insertion (#9754)
add d66dff323e7 [IOTDB-5828] Optimize the performance of some parts in metrics, and correcting the metrics count of temporal file size in inner space compaction (#9753)
add bafa3aefb06 [IOTDB-5808] Refactor RouteBalancer to match LoadManager framework (#9694)
add 6acf8db72bc Bump progressbar from 0.9.3 to 0.9.5 (#9752)
add ea66fc5bee0 Bump openapi-generator-maven-plugin from 5.0.0 to 5.0.1 (#9751)
add b0ca86dbff4 update doc of Community material (#9748)
add 4ca333c8e57 Update workbench documentation with installation method and name bug (#9759)
add 3f166ed37a5 [IOTDB-5824] Fix show devices with * cannot display satisfied devices (#9755)
add 18cdc0b75f8 Fix typo in syntax conventions doc (#9760)
add aaa20e3ae26 [IOTDB-5831]Fix drop database won't delete totally files in disk during data insertion (#9763)
add c98016f9962 [IOTDB-5840] Enhance the problem that the insertRecords interface may cause the number of threads to balloon when there are too many data regions (#9768)
add 2ac9b5197c6 Add config min_cross_compaction_unseq_file_level for cross compaction (#9766)
add ee4df02d5b0 [IOTDB-5842] Sync: Delete BufferedPipeDataQueueTest (#9774)
add 478e4d17952 [IOTDB-5839] Pipe task management (CN -> DN): squash all operation rpcs into one (#9750)
add 10b8be2c661 [IOTDB-5765] Support Order By Expression [BE Part] (#9746)
add b754b03ea08 [IOTDB-5787] PipeTaskAgent: Pipe task management on data nodes (#9782)
add aaf7fa2804f [IOTDB-5811] Pipe: PipeHistoricalCollector (#9700)
add 6118e6cec6b [IOTDB-5837] Fix exception in select-into of ALIGN BY DEVICE query
add b5d13d1876b Delete abandoned API in document (#9773)
add 109b15434c3 Use two params to distinguish fsync delay in the wal sync mode and async mode (#9707)
add 6160095863c [IOTDB-5841] Modify IoTConsensus default parameters to improve performance in more scenarios (#9771)
add e39060e1d1b update ratis version to 2.5.1 (#9785)
add 299f33c80ca [IOTDB-5821] Pipe: PipeCollector Stage (#9789)
add db8849fce19 [IOTDB-5740] Fix drop database does not delete its template (#9792)
add f579e3ca0d6 Support Create and Query Schema of Logical View (#9742)
add 3b44a55bb20 [Doc] Fix error path of Dockerfile (#9725)
add 16011faf943 [To rel/1.1] [IOTDB-5844] Fix compaction module getting stuck (#9776) (#9790)
add dde59e204e4 Refactor SchemaIT for Acceleration (#9794)
add 5c20ee49d39 [IOTDB-5831] Fix create region failure after recreate db (#9800)
add f3e7ce22864 [IOTDB-5818][Atmos][Compaction]Cross_space compaction of Aligned timeseries is stucked (#9795)
add c84a66e669f [IOTDB-5827] Fix the description for dn_multi_dir_strategy in iotdb-datanode.properties and update corresponding user manual (#9804)
add 15a3adc2eb2 [IOTDB-5848] Pipe: task construction and life cycle management (#9808)
add a52beb4e996 [IOTDB-5851] Fix Npe with limit clause
add 7533fe5bec6 Fix a bug: crash while restarting caused by logical view (#9815)
add 52eb858616e Follower doesn't need to update last cache when using IoT_consensus (#9811)
add 8346ab743e6 Support FIFO policy for DataNodeSchemaCache Eviction (#9809)
add 921faa061be [IOTDB-5858] Remove useless class cast and update schema cache hit
add 115fc115f94 [IOTDB-5843] Stall write requests when system shutting down (#9819)
add a99aeff5410 [IOTDB-5863]add configNode configuration information print (#9807)
add b938948bc71 Fix only update last cache on follower (#9827)
add f8a41d74c2b Refactor compaction task metrics (#9816)
add b48bc0a4858 [IOTDB-5858] fix the clear of metric in datanode schema cache
add 61a1dc45c4f accquire thread name from ThreadName
add f955a52fe3a split the thread name module in javadoc
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (9e86dce0929)
\
N -- N -- N refs/heads/cpu-monitor (f955a52fe3a)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
LICENSE-binary | 7 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 82 +-
.../org/apache/iotdb/db/qp/sql/PathParser.g4 | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +-
client-cpp/src/main/Session.h | 7 +-
client-py/SessionExample.py | 4 +-
client-py/iotdb/Session.py | 843 ++-
client-py/iotdb/utils/IoTDBConnectionException.py | 29 +
client-py/iotdb/utils/IoTDBConstants.py | 3 +
client-py/iotdb/utils/IoTDBRpcDataSet.py | 10 +-
client-py/pom.xml | 3 +
client-py/tests/test_dataframe.py | 2 +
.../confignode/client/DataNodeRequestType.java | 8 +-
.../client/async/AsyncDataNodeClientPool.java | 42 +-
.../client/async/handlers/AsyncClientHandler.java | 18 +-
.../heartbeat/ConfigNodeHeartbeatHandler.java | 17 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 63 +-
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 87 +
.../async/handlers/rpc/OperatePipeRPCHandler.java | 60 -
.../iotdb/confignode/conf/ConfigNodeConfig.java | 27 +
.../consensus/request/ConfigPhysicalPlan.java | 78 +-
.../consensus/request/ConfigPhysicalPlanType.java | 41 +-
.../consensus/request/auth/AuthorPlan.java | 29 +-
.../read/partition/CountTimeSlotListPlan.java | 133 +
.../read/partition/GetSeriesSlotListPlan.java | 18 +-
.../read/partition/GetTimeSlotListPlan.java | 44 +-
.../request/read/region/GetRegionIdPlan.java | 46 +-
.../request/write/pipe/task/CreatePipePlanV2.java | 66 +
.../request/write/pipe/task/DropPipePlanV2.java | 56 +
.../write/pipe/task/SetPipeStatusPlanV2.java | 66 +
.../request/write/quota/SetThrottleQuotaPlan.java | 113 +
.../request/write/sync/CreatePipeSinkPlan.java | 57 -
.../request/write/sync/CreatePipeSinkPlanV1.java | 59 +
.../consensus/request/write/sync/DropPipePlan.java | 56 -
.../request/write/sync/DropPipePlanV1.java | 58 +
.../request/write/sync/DropPipeSinkPlan.java | 56 -
.../request/write/sync/DropPipeSinkPlanV1.java | 58 +
.../request/write/sync/GetPipeSinkPlan.java | 56 -
.../request/write/sync/GetPipeSinkPlanV1.java | 58 +
.../request/write/sync/PreCreatePipePlan.java | 56 -
.../request/write/sync/PreCreatePipePlanV1.java | 58 +
.../request/write/sync/RecordPipeMessagePlan.java | 4 +-
.../request/write/sync/SetPipeStatusPlan.java | 72 -
.../request/write/sync/SetPipeStatusPlanV1.java | 68 +
.../consensus/request/write/sync/ShowPipePlan.java | 56 -
.../request/write/sync/ShowPipePlanV1.java | 58 +
.../template/CommitSetSchemaTemplatePlan.java | 80 +
.../write/template/ExtendSchemaTemplatePlan.java | 58 +
.../write/template/PreSetSchemaTemplatePlan.java | 80 +
.../response/partition/CountTimeSlotListResp.java | 56 +
.../response/partition/GetRegionIdResp.java | 2 +-
.../response/partition/GetSeriesSlotListResp.java | 2 +-
.../response/partition/GetTimeSlotListResp.java | 2 +-
.../statemachine/ConfigRegionStateMachine.java | 11 +-
.../confignode/manager/ClusterQuotaManager.java | 77 +-
.../confignode/manager/ClusterSchemaManager.java | 189 +-
.../iotdb/confignode/manager/ConfigManager.java | 207 +-
.../apache/iotdb/confignode/manager/IManager.java | 82 +-
.../confignode/manager/PermissionManager.java | 3 +-
.../iotdb/confignode/manager/ProcedureManager.java | 148 +-
.../confignode/manager/RetryFailedTasksThread.java | 85 +-
.../iotdb/confignode/manager/SyncManager.java | 306 -
.../manager/consensus/ConsensusManager.java | 12 +-
.../iotdb/confignode/manager/cq/CQManager.java | 4 +-
.../iotdb/confignode/manager/load/LoadManager.java | 486 +-
.../manager/load/balancer/RegionBalancer.java | 7 +-
.../manager/load/balancer/RouteBalancer.java | 276 +-
.../load/balancer/router/RegionRouteMap.java | 171 -
.../confignode/manager/load/cache/LoadCache.java | 599 ++
.../manager/load/cache/node/BaseNodeCache.java | 149 +
.../load/cache/node/ConfigNodeHeartbeatCache.java | 83 +
.../load/cache/node/DataNodeHeartbeatCache.java | 79 +
.../load/cache/node/NodeHeartbeatSample.java | 95 +
.../manager/load/cache/node/NodeStatistics.java | 144 +
.../manager/load/cache/region/RegionCache.java | 74 +
.../load/cache/region/RegionGroupCache.java | 170 +
.../load/cache/region/RegionGroupStatistics.java | 139 +
.../load/cache/region/RegionHeartbeatSample.java | 50 +
.../load/cache/region/RegionStatistics.java | 86 +
.../manager/load/cache/route/RegionRouteCache.java | 138 +
.../manager/load/service/HeartbeatService.java | 191 +
.../manager/load/service/StatisticsService.java | 247 +
.../load/subscriber/IClusterStatusSubscriber.java | 34 +
.../manager/load/subscriber/RouteChangeEvent.java | 49 +
.../load/subscriber/StatisticsChangeEvent.java | 53 +
.../iotdb/confignode/manager/node/NodeManager.java | 328 +-
.../manager/node/heartbeat/BaseNodeCache.java | 144 -
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 84 -
.../node/heartbeat/DataNodeHeartbeatCache.java | 76 -
.../node/heartbeat/NodeHeartbeatSample.java | 94 -
.../manager/node/heartbeat/NodeStatistics.java | 139 -
.../iotdb/confignode/manager/observer/IEvent.java | 21 -
.../manager/observer/NodeStatisticsEvent.java | 39 -
.../manager/partition/PartitionManager.java | 232 +-
.../manager/partition/PartitionMetrics.java | 18 +-
.../manager/partition/RegionGroupStatus.java | 21 +-
.../manager/partition/heartbeat/RegionCache.java | 73 -
.../partition/heartbeat/RegionGroupCache.java | 166 -
.../partition/heartbeat/RegionGroupStatistics.java | 135 -
.../partition/heartbeat/RegionHeartbeatSample.java | 49 -
.../partition/heartbeat/RegionStatistics.java | 86 -
.../iotdb/confignode/manager/pipe/PipeManager.java | 12 +-
.../manager/pipe/PipePluginCoordinator.java | 10 +-
.../manager/pipe/PipeTaskCoordinator.java | 73 +
.../iotdb/confignode/persistence/AuthorInfo.java | 34 +-
.../persistence/executor/ConfigPlanExecutor.java | 71 +-
.../confignode/persistence/node/NodeInfo.java | 47 +-
.../partition/DatabasePartitionTable.java | 85 +-
.../persistence/partition/PartitionInfo.java | 183 +-
.../persistence/partition/RegionGroup.java | 13 +-
.../confignode/persistence/pipe/PipeInfo.java | 59 +-
.../persistence/pipe/PipePluginInfo.java | 82 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 221 +
.../persistence/pipe/PipeTaskOperation.java | 28 +
.../confignode/persistence/quota/QuotaInfo.java | 122 +-
.../persistence/schema/ClusterSchemaInfo.java | 108 +-
.../persistence/schema/TemplatePreSetTable.java | 195 +
.../persistence/schema/TemplateTable.java | 48 +-
.../persistence/sync/ClusterSyncInfo.java | 225 -
.../procedure/env/ConfigNodeProcedureEnv.java | 87 +-
.../procedure/env/DataNodeRemoveHandler.java | 19 +-
.../procedure/impl/model/DropModelProcedure.java | 4 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 30 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 30 +-
.../pipe/task/AbstractOperatePipeProcedureV2.java | 203 +
.../impl/pipe/task/CreatePipeProcedureV2.java | 253 +
.../impl/pipe/task/DropPipeProcedureV2.java | 147 +
.../impl/pipe/task/StartPipeProcedureV2.java | 159 +
.../impl/pipe/task/StopPipeProcedureV2.java | 159 +
.../impl/schema/DataNodeRegionTaskExecutor.java | 4 +-
.../impl/schema/DeleteDatabaseProcedure.java | 4 +-
.../impl/schema/SetTemplateProcedure.java | 534 ++
.../statemachine/CreateRegionGroupsProcedure.java | 1 -
.../impl/statemachine/RegionMigrateProcedure.java | 3 +
.../impl/sync/AbstractOperatePipeProcedure.java | 147 -
.../procedure/impl/sync/CreatePipeProcedure.java | 131 +-
.../procedure/impl/sync/DropPipeProcedure.java | 97 +-
.../procedure/impl/sync/StartPipeProcedure.java | 136 +-
.../procedure/impl/sync/StopPipeProcedure.java | 136 +-
.../state/pipe/task/OperatePipeTaskState.java | 27 +
.../procedure/state/schema/SetTemplateState.java | 29 +
.../procedure/state/sync/OperatePipeState.java | 26 -
.../procedure/store/ProcedureFactory.java | 22 +
.../confignode/procedure/store/ProcedureType.java | 11 +-
.../iotdb/confignode/service/ConfigNode.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 92 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 205 +-
.../load/balancer/router/RegionRouteMapTest.java | 82 -
.../router/priority/GreedyPriorityTest.java | 8 +-
.../priority/LeaderPriorityBalancerTest.java | 8 +-
.../confignode/manager/node/NodeCacheTest.java | 8 +-
.../manager/partition/RegionGroupCacheTest.java | 4 +-
.../confignode/persistence/AuthorInfoTest.java | 30 +-
.../persistence/ClusterSchemaInfoTest.java | 153 -
.../persistence/ClusterSyncInfoTest.java | 164 -
.../iotdb/confignode/persistence/PipeInfoTest.java | 100 +
.../confignode/persistence/QuotaInfoTest.java | 25 +-
.../confignode/persistence/TemplateTableTest.java | 109 -
.../persistence/node/NodeStatisticsTest.java | 2 +-
.../statistics/RegionGroupStatisticsTest.java | 4 +-
.../partition/statistics/RegionStatisticsTest.java | 2 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 152 +
.../schema/TemplatePreSetTableTest.java | 114 +
.../persistence/schema/TemplateTableTest.java | 108 +
.../impl/pipe/CreatePipePluginProcedureTest.java | 60 -
.../impl/pipe/DropPipePluginProcedureTest.java | 53 -
.../pipe/plugin/CreatePipePluginProcedureTest.java | 59 +
.../pipe/plugin/DropPipePluginProcedureTest.java | 52 +
.../impl/pipe/task/CreatePipeProcedureV2Test.java | 69 +
.../impl/pipe/task/DropPipeProcedureV2Test.java | 53 +
.../impl/pipe/task/StartPipeProcedureV2Test.java | 53 +
.../impl/pipe/task/StopPipeProcedureV2Test.java | 53 +
consensus/pom.xml | 2 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 36 +-
.../consensus/iot/IoTConsensusServerImpl.java | 13 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 11 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 22 +
.../consensus/iot/logdispatcher/SyncStatus.java | 2 -
.../ratis/ApplicationStateMachineProxy.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 8 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 17 +
docs/Community/Materials.md | 201 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 98 -
.../UserGuide/API/Programming-Python-Native-API.md | 6 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 176 +-
docs/UserGuide/Data-Concept/Compression.md | 2 +
docs/UserGuide/Data-Concept/Encoding.md | 24 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 60 +-
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 8 +-
docs/UserGuide/Operate-Metadata/Template.md | 15 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 1 +
docs/UserGuide/Operators-Functions/Sample.md | 50 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 49 +-
docs/UserGuide/QuickStart/Files.md | 2 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 62 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 18 +-
.../Syntax-Conventions/Session-And-TsFile-API.md | 4 +-
docs/zh/Download/README.md | 7 +
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 1 +
.../UserGuide/API/Programming-Java-Native-API.md | 93 -
.../UserGuide/API/Programming-Python-Native-API.md | 6 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 177 +-
docs/zh/UserGuide/Cluster/IoTDB-Deploy.md | 361 -
docs/zh/UserGuide/Data-Concept/Compression.md | 1 +
docs/zh/UserGuide/Data-Concept/Encoding.md | 29 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 68 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
.../UserGuide/Ecosystem-Integration/Workbench.md | 79 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 27 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 14 +
.../UserGuide/Operators-Functions/Aggregation.md | 1 +
docs/zh/UserGuide/Operators-Functions/Sample.md | 58 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 48 +-
docs/zh/UserGuide/QuickStart/Files.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 59 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 27 +-
.../Syntax-Conventions/Session-And-TsFile-API.md | 4 +-
grafana-plugin/README.md | 63 +-
grafana-plugin/src/plugin.json | 2 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 1 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 18 +
.../it/env/cluster/MppSharedCommonConfig.java | 21 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 15 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 88 +-
.../it/partition/IoTDBPartitionGetterIT.java | 96 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 40 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 23 +
.../db/it/last/IoTDBLastQueryLastCache2IT.java | 60 +
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 145 +
.../iotdb/db/it/orderBy/IoTDBOrderBy2IT.java | 48 +
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 1226 +++
.../iotdb/db/it/query/IoTDBPaginationIT.java | 59 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 2 +
.../iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java | 535 ++
.../iotdb/db/it/schema/AbstractSchemaIT.java | 92 -
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 18 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 18 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 19 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 18 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 30 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 19 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 18 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 19 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 228 +
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 113 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 210 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 21 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 18 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 18 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 30 +
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 304 -
.../it/udf/IoTDBUDTFBuiltinScalarFunctionIT.java | 688 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 17 +
.../session/it/IoTDBSessionSchemaTemplateIT.java | 116 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 128 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 14 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 +
library-udf/Readme.md | 27 +
library-udf/pom.xml | 45 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 6 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 6 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 3 -
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 5 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 5 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 10 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 6 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 10 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 6 +-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 6 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 7 +-
.../dprofile/util/ExactOrderStatistics.java | 41 +-
.../java/org/apache/iotdb/library/util/Util.java | 5 +-
.../metricsets/cpu/AbstractCpuMetricsManager.java | 63 -
.../iotdb/metrics/metricsets/cpu/CpuMetrics.java | 56 -
.../metrics/metricsets/cpu/CpuMetricsConstant.java | 103 -
.../metricsets/cpu/LinuxCpuMetricsManager.java | 147 -
.../metricsets/cpu/MacCpuMetricsManager.java | 22 -
.../metricsets/cpu/WindowsCpuMetricsManager.java | 22 -
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 6 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 31 +-
.../metricsets/net/LinuxNetMetricManager.java | 27 +-
.../iotdb/metrics/metricsets/net/NetMetrics.java | 12 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 3 +-
mlnode/.gitignore | 6 +-
mlnode/iotdb/mlnode/client.py | 107 +-
mlnode/iotdb/mlnode/config.py | 14 +-
mlnode/iotdb/mlnode/constant.py | 10 +
mlnode/iotdb/mlnode/handler.py | 29 +-
mlnode/iotdb/mlnode/model_storage.py | 95 -
mlnode/iotdb/mlnode/service.py | 6 +-
mlnode/iotdb/mlnode/storage.py | 102 +
mlnode/iotdb/mlnode/util.py | 18 +-
mlnode/pyproject.toml | 1 +
mlnode/requirements.txt | 2 +-
mlnode/test/test_model_storage.py | 37 +-
.../resources/conf/iotdb-common.properties | 46 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 35 +-
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 33 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 29 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 13 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 13 +-
.../iotdb/commons/auth/role/BasicRoleManager.java | 5 +-
.../iotdb/commons/auth/role/IRoleManager.java | 6 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 5 +-
.../iotdb/commons/auth/user/IUserManager.java | 6 +-
.../iotdb/commons/concurrent/ThreadName.java | 124 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 42 +-
.../iotdb/commons/constant/QueryThreadName.java | 55 -
.../apache/iotdb/commons/enums/SpaceQuotaType.java | 26 -
.../commons/exception/RpcThrottlingException.java | 26 +
.../commons/partition/DataPartitionTable.java | 45 +-
.../commons/partition/SchemaPartitionTable.java | 10 +
.../commons/partition/SeriesPartitionTable.java | 32 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 6 +
.../org/apache/iotdb/commons/path/PartialPath.java | 48 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 59 +
.../plugin/builtin/collector/DefaultCollector.java | 60 +
.../builtin/connector/DoNothingConnector.java | 72 +
.../builtin/processor/DoNothingProcessor.java | 68 +
.../meta/ConfigNodePipePluginMetaKeeper.java | 47 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 28 +-
.../commons/pipe/plugin/meta/PipePluginMeta.java | 65 +-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 76 +-
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 101 +
.../commons/pipe/task/meta/PipeMetaKeeper.java | 101 +
.../commons/pipe/task/meta/PipeRuntimeMeta.java | 125 +
.../commons/pipe/task/meta/PipeStaticMeta.java | 183 +
.../iotdb/commons/pipe/task/meta/PipeStatus.java | 50 +
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 143 +
.../pipe/task/meta/PipeTaskMetaAccessor.java | 22 -
.../iotdb/commons/quotas/SpaceQuotaType.java | 26 +
.../node/common/AbstractMeasurementMNode.java | 4 +
.../schema/node/role/IMeasurementMNode.java | 2 +
.../commons/schema/node/utils/IMNodeFactory.java | 4 +
.../commons/schema/tree/AbstractTreeVisitor.java | 122 +-
.../iotdb/commons/sync/pipe/SyncOperation.java | 1 -
.../BuiltinTimeSeriesGeneratingFunction.java | 10 +
.../commons/udf/service/UDFClassLoaderManager.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 96 +-
.../org/apache/iotdb/commons/utils/IOUtils.java | 8 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 12 +-
.../client/mock/MockInternalRPCService.java | 6 +-
.../apache/iotdb/commons/path/PartialPathTest.java | 2 +-
.../org/apache/iotdb/pipe/api/PipeCollector.java | 99 +
.../org/apache/iotdb/pipe/api/PipeConnector.java | 6 +-
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 6 +-
.../iotdb/pipe/api/collector/EventCollector.java | 6 +-
.../iotdb/pipe/api/collector/RowCollector.java | 2 +-
.../iotdb/pipe/api/customizer/PipeParameters.java | 22 +
.../PipeCollectorRuntimeConfiguration.java | 30 +
.../org/apache/iotdb/pipe/api/event/Event.java | 6 +-
.../org/apache/iotdb/pipe/api/event/EventType.java | 26 +
.../pipe/api/event/deletion/DeletionEvent.java | 42 -
.../pipe/api/event/dml/deletion/DeletionEvent.java | 48 +
.../event/dml/insertion/TabletInsertionEvent.java | 62 +
.../event/dml/insertion/TsFileInsertionEvent.java | 50 +
.../api/event/insertion/TabletInsertionEvent.java | 56 -
.../api/event/insertion/TsFileInsertionEvent.java | 44 -
.../api/exception/PipeConnectionException.java | 31 +
.../exception/PipeRuntimeCriticalException.java | 40 +
.../pipe/api/exception/PipeRuntimeException.java | 40 +
.../exception/PipeRuntimeNonCriticalException.java | 40 +
pom.xml | 19 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 9 +-
.../rocksdb/mnode/RMeasurementMNode.java | 5 +
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 9 +-
server/pom.xml | 6 +-
.../resources/conf/iotdb-datanode.properties | 17 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../apache/iotdb/db/auth/AuthorizerManager.java | 15 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 38 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 95 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 146 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 71 +-
.../directories/strategy/SequenceStrategy.java | 2 +-
.../statemachine/DataRegionStateMachine.java | 3 +-
.../iotdb/db/engine/TsFileMetricManager.java | 63 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../compaction/constant/CompactionTaskStatus.java | 27 +
.../compaction/constant/CompactionTaskType.java | 26 +
.../CompactionMemoryNotEnoughException.java | 27 +
.../performer/impl/FastCompactionPerformer.java | 30 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../impl/ReadPointCompactionPerformer.java | 24 +-
.../execute/task/AbstractCompactionTask.java | 13 +-
.../execute/task/CompactionTaskSummary.java | 18 +
.../execute/task/CrossSpaceCompactionTask.java | 17 +-
.../execute/task/InnerSpaceCompactionTask.java | 7 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 4 +-
.../fast/AlignedSeriesCompactionExecutor.java | 19 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 6 -
.../readchunk/SingleSeriesCompactionExecutor.java | 38 +-
.../utils/writer/AbstractCompactionWriter.java | 10 +-
.../compaction/schedule/CompactionTaskManager.java | 74 +-
.../compaction/schedule/CompactionWorker.java | 3 -
.../estimator/AbstractCompactionEstimator.java | 7 +
.../ReadPointCrossCompactionEstimator.java | 110 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 43 +-
.../utils/CrossCompactionTaskResource.java | 12 +
.../utils/CrossSpaceCompactionCandidate.java | 15 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 99 +-
.../db/engine/storagegroup/TsFileProcessor.java | 17 +-
.../template/TemplateImcompatibeException.java | 19 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 6 +
.../db/metadata/cache/DataNodeDevicePathCache.java | 69 +
.../db/metadata/cache/DataNodeSchemaCache.java | 233 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 31 +-
.../cache/DeviceUsingTemplateSchemaCache.java | 177 +
.../db/metadata/cache/TimeSeriesSchemaCache.java | 300 +
.../metadata/cache/dualkeycache/IDualKeyCache.java | 4 +
.../dualkeycache/impl/CacheEntryGroupImpl.java | 2 +-
.../dualkeycache/impl/DualKeyCacheBuilder.java | 18 +-
.../cache/dualkeycache/impl/DualKeyCacheImpl.java | 102 +-
.../dualkeycache/impl/DualKeyCachePolicy.java | 3 +-
.../dualkeycache/impl/FIFOCacheEntryManager.java | 189 +
.../mnode/config/factory/ConfigMNodeFactory.java | 7 +
.../mnode/mem/factory/MemMNodeFactory.java | 14 +
.../metadata/mnode/mem/impl/LogicalViewMNode.java | 63 +
.../metadata/mnode/mem/impl/LogicalViewSchema.java | 215 +
.../metadata/mnode/mem/impl/MeasurementMNode.java | 5 +
.../metadata/mnode/mem/info/LogicalViewInfo.java | 161 +
.../schemafile/factory/CacheMNodeFactory.java | 7 +
.../schemafile/impl/CachedMeasurementMNode.java | 5 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 4 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 19 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 112 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 48 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 4 +-
.../store/disk/schemafile/SchemaFileConfig.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 1 +
.../store/disk/schemafile/pagemgr/PageManager.java | 90 +-
.../db/metadata/mtree/traverser/Traverser.java | 61 +
.../traverser/TraverserWithLimitOffsetWrapper.java | 5 +
.../mtree/traverser/basic/DatabaseTraverser.java | 5 +
.../mtree/traverser/basic/EntityTraverser.java | 8 +
.../mtree/traverser/basic/MNodeTraverser.java | 5 +
.../traverser/basic/MeasurementTraverser.java | 5 +
.../plan/schemaregion/SchemaRegionPlanType.java | 2 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../impl/SchemaRegionPlanDeserializer.java | 24 +
.../impl/SchemaRegionPlanSerializer.java | 27 +
.../impl/SchemaRegionPlanTxtSerializer.java | 21 +
.../impl/write/CreateLogicalViewPlanImpl.java | 75 +
.../schemaregion/result/ShowTimeSeriesResult.java | 14 +-
.../schemaregion/write/ICreateLogicalViewPlan.java | 66 +
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 6 +-
.../metadata/rescon/MemSchemaEngineStatistics.java | 26 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 8 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 7 +-
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 42 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 24 +-
.../metadata/template/ClusterTemplateManager.java | 306 +-
.../db/metadata/template/ITemplateManager.java | 10 +-
.../iotdb/db/metadata/template/Template.java | 16 +-
.../template/TemplateAlterOperationType.java | 58 +
.../template/TemplateInternalRPCUpdateType.java | 20 +-
.../metadata/template/TemplateInternalRPCUtil.java | 50 +-
.../metadata/template/alter/TemplateAlterInfo.java | 43 +
.../template/alter/TemplateAlterOperationUtil.java | 51 +
.../template/alter/TemplateExtendInfo.java | 161 +
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 11 +-
.../view/viewExpression/ViewExpression.java | 318 +
.../view/viewExpression/ViewExpressionType.java | 76 +
.../binary/BinaryViewExpression.java | 119 +
.../binary/arithmetic/AdditionViewExpression.java | 61 +
.../arithmetic/ArithmeticBinaryViewExpression.java | 52 +
.../binary/arithmetic/DivisionViewExpression.java | 61 +
.../binary/arithmetic/ModuloViewExpression.java | 61 +
.../arithmetic/MultiplicationViewExpression.java | 63 +
.../arithmetic/SubtractionViewExpression.java | 61 +
.../compare/CompareBinaryViewExpression.java | 52 +
.../binary/compare/EqualToViewExpression.java | 57 +
.../binary/compare/GreaterEqualViewExpression.java | 57 +
.../binary/compare/GreaterThanViewExpression.java | 57 +
.../binary/compare/LessEqualViewExpression.java | 57 +
.../binary/compare/LessThanViewExpression.java | 57 +
.../binary/compare/NonEqualViewExpression.java | 57 +
.../binary/logic/LogicAndViewExpression.java | 57 +
.../binary/logic/LogicBinaryViewExpression.java | 52 +
.../binary/logic/LogicOrViewExpression.java | 57 +
.../viewExpression/leaf/ConstantViewOperand.java | 98 +
.../view/viewExpression/leaf/LeafViewOperand.java | 39 +
.../view/viewExpression/leaf/NullViewOperand.java | 61 +
.../viewExpression/leaf/TimeSeriesViewOperand.java | 87 +
.../viewExpression/leaf/TimestampViewOperand.java | 72 +
.../multi/FunctionViewExpression.java | 198 +
.../ternary/BetweenViewExpression.java | 111 +
.../ternary/TernaryViewExpression.java | 105 +
.../viewExpression/unary/InViewExpression.java | 106 +
.../viewExpression/unary/IsNullViewExpression.java | 89 +
.../viewExpression/unary/LikeViewExpression.java | 163 +
.../unary/LogicNotViewExpression.java | 61 +
.../unary/NegationViewExpression.java | 61 +
.../unary/RegularViewExpression.java | 105 +
.../viewExpression/unary/UnaryViewExpression.java | 73 +
.../visitor/GetSourcePathsVisitor.java | 95 +
.../visitor/TransformToExpressionVisitor.java | 320 +
.../visitor/ViewExpressionVisitor.java | 219 +
.../metadata/visitor/SchemaExecutionVisitor.java | 22 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 38 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 8 +
.../visitor/SchemaTreeDeviceVisitor.java | 5 +
.../visitor/SchemaTreeMeasurementVisitor.java | 5 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 6 +
.../db/mpp/exception/CpuNotEnoughException.java | 28 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 78 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 11 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 23 +-
.../db/mpp/execution/driver/DriverContext.java | 9 +
.../iotdb/db/mpp/execution/driver/IDriver.java | 4 +
.../execution/exchange/MPPDataExchangeManager.java | 106 +-
.../execution/exchange/MPPDataExchangeService.java | 10 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 6 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 32 +-
.../execution/exchange/sink/LocalSinkChannel.java | 21 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 85 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 65 +-
.../exchange/source/LocalSourceHandle.java | 2 +-
.../exchange/source/PipelineSourceHandle.java | 39 +
.../execution/exchange/source/SourceHandle.java | 25 +-
.../execution/executor/RegionWriteExecutor.java | 49 +
.../fragment/FragmentInstanceContext.java | 10 +
.../fragment/FragmentInstanceExecution.java | 28 +-
.../fragment/FragmentInstanceManager.java | 14 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 25 +-
.../operator/process/AbstractIntoOperator.java | 64 +-
.../operator/process/DeviceViewIntoOperator.java | 13 +-
.../execution/operator/process/IntoOperator.java | 7 +-
.../operator/process/MergeSortOperator.java | 9 +-
.../execution/operator/process/OffsetOperator.java | 4 +-
.../execution/operator/process/SortOperator.java | 258 +-
.../operator/process/TransformOperator.java | 13 +-
.../process/join/merge/MergeSortComparator.java | 199 +-
.../process/join/merge/SortKeyComparator.java | 52 +
.../operator/schema/SchemaCountOperator.java | 23 +-
.../operator/schema/SchemaQueryScanOperator.java | 2 +-
.../operator/schema/source/DeviceSchemaSource.java | 12 +
.../operator/schema/source/ISchemaSource.java | 4 +
.../operator/schema/source/NodeSchemaSource.java | 10 +
.../schema/source/PathsUsingTemplateSource.java | 10 +
.../schema/source/SchemaSourceFactory.java | 5 +
.../schema/source/TimeSeriesSchemaSource.java | 26 +-
.../execution/operator/source/SeriesScanUtil.java | 24 +-
.../execution/schedule/AbstractDriverThread.java | 9 +
.../db/mpp/execution/schedule/DriverScheduler.java | 172 +-
.../mpp/execution/schedule/DriverTaskThread.java | 11 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IndexedBlockingQueue.java | 1 +
.../multilevelqueue/MultilevelPriorityQueue.java | 4 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 16 +-
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 140 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 20 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 68 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 354 +-
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 30 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 40 +-
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 3 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 10 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 254 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 7 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 197 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 10 +-
.../plan/analyze/schema/NormalSchemaFetcher.java | 203 +
.../plan/analyze/schema/TemplateSchemaFetcher.java | 246 +
.../db/mpp/plan/execution/IQueryExecution.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 57 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +-
.../plan/execution/config/ConfigTaskVisitor.java | 33 +-
.../config/executor/ClusterConfigTaskExecutor.java | 198 +-
.../config/executor/IConfigTaskExecutor.java | 21 +-
.../config/metadata/CountTimeSlotListTask.java | 69 +
.../config/metadata/GetTimeSlotListTask.java | 9 +-
.../config/metadata/ShowPipePluginsTask.java | 18 +-
.../metadata/template/AlterSchemaTemplateTask.java | 45 +
.../metadata/template/SetSchemaTemplateTask.java | 7 +-
.../config/sys/quota/SetThrottleQuotaTask.java | 42 +
.../config/sys/quota/ShowSpaceQuotaTask.java | 15 +-
.../config/sys/quota/ShowThrottleQuotaTask.java | 191 +
.../visitor/ColumnTransformerVisitor.java | 40 +-
.../visitor/IntermediateLayerVisitor.java | 4 +-
.../visitor/TransformToViewExpressionVisitor.java | 391 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 463 +-
.../db/mpp/plan/parser/StatementGenerator.java | 66 +-
.../plan/planner/LocalExecutionPlanContext.java | 6 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 14 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 187 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 40 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 62 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 7 +-
.../planner/distribution/DistributionPlanner.java | 5 +-
.../planner/distribution/ExchangeNodeAdder.java | 6 +
.../plan/planner/distribution/SourceRewriter.java | 52 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 59 +-
.../planner/plan/node/load/LoadTsFileNode.java | 16 +-
.../node/metedata/write/CreateLogicalViewNode.java | 250 +
.../source/AlignedSeriesAggregationScanNode.java | 50 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +
.../node/source/SeriesAggregationScanNode.java | 50 +-
.../node/source/SeriesAggregationSourceNode.java | 49 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +
.../plan/planner/plan/node/write/InsertNode.java | 9 +
.../planner/plan/node/write/InsertRowNode.java | 4 +
.../planner/plan/node/write/InsertRowsNode.java | 5 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 7 +
.../planner/plan/node/write/InsertTabletNode.java | 8 +
.../planner/plan/parameter/SeriesScanOptions.java | 5 +-
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 74 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 27 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 4 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 50 +-
.../db/mpp/plan/scheduler/IQueryTerminator.java | 2 +-
.../iotdb/db/mpp/plan/scheduler/IScheduler.java | 2 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 35 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 20 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 203 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 5 +
.../db/mpp/plan/statement/StatementVisitor.java | 30 +
.../mpp/plan/statement/component/NullOrdering.java | 33 +
.../plan/statement/component/OrderByComponent.java | 56 +-
.../mpp/plan/statement/component/OrderByKey.java | 30 +
.../db/mpp/plan/statement/component/SortItem.java | 61 +-
.../db/mpp/plan/statement/component/SortKey.java | 30 -
.../plan/statement/crud/InsertBaseStatement.java | 4 -
.../crud/InsertMultiTabletsStatement.java | 18 -
.../plan/statement/crud/InsertRowStatement.java | 19 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 9 -
.../plan/statement/crud/InsertRowsStatement.java | 17 -
.../plan/statement/crud/InsertTabletStatement.java | 13 -
.../db/mpp/plan/statement/crud/QueryStatement.java | 82 +-
.../metadata/CountTimeSlotListStatement.java | 116 +
.../metadata/CreateLogicalViewStatement.java | 246 +
.../statement/metadata/GetRegionIdStatement.java | 54 +-
.../metadata/GetSeriesSlotListStatement.java | 20 +-
.../metadata/GetTimeSlotListStatement.java | 46 +-
.../template/AlterSchemaTemplateStatement.java | 85 +
.../plan/statement/sys/ShowQueriesStatement.java | 4 +-
.../sys/quota/SetThrottleQuotaStatement.java | 94 +
.../sys/quota/ShowThrottleQuotaStatement.java | 63 +
.../dag/builder/EvaluationDAGBuilder.java | 4 +-
.../dag/input/QueryDataSetInputLayer.java | 5 +-
.../intermediate/ConstantIntermediateLayer.java | 3 +-
.../dag/intermediate/IntermediateLayer.java | 4 +-
.../MultiInputColumnIntermediateLayer.java | 2 +-
...InputColumnMultiReferenceIntermediateLayer.java | 2 +-
...nputColumnSingleReferenceIntermediateLayer.java | 2 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 2 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 2 +-
.../datastructure/SerializableList.java | 6 +-
.../row/ElasticSerializableRowRecordList.java | 6 +-
.../row/SerializableRowRecordList.java | 2 +-
.../tv/ElasticSerializableBinaryTVList.java | 2 +-
.../tv/ElasticSerializableTVList.java | 8 +-
.../datastructure/tv/SerializableTVList.java | 2 +-
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 11 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 89 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 17 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 290 +-
.../db/pipe/agent/task/PipeTaskRegionAgent.java | 22 -
.../db/pipe/config/PipeCollectorConstant.java | 31 +
.../apache/iotdb/db/pipe/config/PipeConfig.java | 65 +
.../db/pipe/config/PipeConnectorConstant.java | 29 +
.../db/pipe/config/PipeProcessorConstant.java | 29 +
.../core/collector/IoTDBDataRegionCollector.java | 85 +
.../collector/PipeCollectorEventPendingQueue.java | 22 -
.../core/collector/PipeCollectorEventSelector.java | 22 -
.../historical/PipeHistoricalCollector.java | 22 -
.../PipeHistoricalDataRegionTsFileCollector.java | 103 +
.../collector/realtime/PipeRealtimeCollector.java | 22 -
.../realtime/PipeRealtimeDataRegionCollector.java | 76 +
.../PipeRealtimeDataRegionHybridCollector.java | 174 +
.../realtime/assigner/DisruptorQueue.java | 111 +
.../realtime/assigner/PipeDataRegionAssigner.java | 74 +
.../realtime/cache/PipeRealtimeEventCache.java | 22 -
.../realtime/listener/IoTLogListerner.java | 22 -
.../listener/PipeInsertionDataNodeListener.java | 115 +
.../realtime/listener/RatisLogListener.java | 22 -
.../realtime/listener/SimpleLogListener.java | 22 -
.../listener/TsFileGenerationListener.java | 22 -
.../matcher/CachedSchemaPatternMatcher.java | 200 +
.../realtime/matcher/PipeDataRegionMatcher.java | 47 +
.../pipe/core/collector/realtime/matcher/Rule.java | 22 -
.../realtime/matcher/RulePrefixMatchTree.java | 22 -
.../collector/realtime/recorder/TsFileEpoch.java | 22 -
.../realtime/recorder/TsFileEpochRecorder.java | 22 -
.../core/connector/PipeConnectorContainer.java | 22 -
.../pipe/core/connector/PipeConnectorManager.java | 22 -
.../PipeConnectorPluginRuntimeWrapper.java | 73 -
.../connector/PipeConnectorSubtaskLifeCycle.java | 125 +
.../connector/PipeConnectorSubtaskManager.java | 122 +
.../pipe/core/event/PipeTabletInsertionEvent.java | 46 -
.../pipe/core/event/PipeTsFileInsertionEvent.java | 36 -
.../iotdb/db/pipe/core/event/access/PipeRow.java | 102 -
.../db/pipe/core/event/access/PipeRowIterator.java | 60 -
.../core/event/collector/PipeEventCollector.java | 39 -
.../core/event/collector/PipeRowCollector.java | 31 -
.../core/event/impl/PipeTabletInsertionEvent.java | 58 +
.../core/event/impl/PipeTsFileInsertionEvent.java | 48 +
.../pipe/core/event/indexer/PipeEventIndexer.java | 22 -
.../core/event/indexer/PipeIoTEventIndexer.java | 22 -
.../core/event/indexer/PipeRatisEventIndexer.java | 22 -
.../core/event/indexer/PipeSimpleEventIndexer.java | 22 -
.../core/event/indexer/PipeTsFileEventIndexer.java | 22 -
.../event/realtime/PipeRealtimeCollectEvent.java | 66 +
.../realtime/PipeRealtimeCollectEventFactory.java | 49 +
.../db/pipe/core/event/realtime/TsFileEpoch.java | 68 +
.../core/event/realtime/TsFileEpochManager.java | 70 +
.../event/realtime/TsFileEpochStateMigrator.java | 25 +
.../db/pipe/core/event/view/access/PipeRow.java | 102 +
.../core/event/view/access/PipeRowIterator.java | 60 +
.../event/view/collector/PipeEventCollector.java | 90 +
.../event/view/collector/PipeRowCollector.java | 31 +
.../PipeProcessorPluginRuntimeWrapper.java | 77 -
.../execution/executor/PipeSubtaskExecutor.java | 12 +-
.../executor/PipeSubtaskExecutorManager.java | 67 +
.../executor/PipeTaskExecutorManager.java | 67 -
.../execution/scheduler/PipeTaskScheduler.java | 18 +-
.../db/pipe/resource/PipeResourceManager.java | 45 +
.../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 66 +
.../org/apache/iotdb/db/pipe/task/PipeTask.java | 9 +-
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 60 +-
.../apache/iotdb/db/pipe/task/PipeTaskManager.java | 96 +
.../db/pipe/task/callable/DecoratingLock.java | 44 -
.../db/pipe/task/callable/PipeAssignerSubtask.java | 32 -
.../pipe/task/callable/PipeConnectorSubtask.java | 37 -
.../pipe/task/callable/PipeProcessorSubtask.java | 37 -
.../iotdb/db/pipe/task/callable/PipeSubtask.java | 135 -
.../iotdb/db/pipe/task/queue/EventSupplier.java | 33 +
.../task/queue/ListenableBlockingPendingQueue.java | 31 +
.../db/pipe/task/queue/ListenablePendingQueue.java | 159 +
.../queue/ListenableUnblockingPendingQueue.java | 31 +
.../queue/PendingQueueEmptyToNotEmptyListener.java | 26 +
.../queue/PendingQueueFullToNotFullListener.java | 26 +
.../queue/PendingQueueNotEmptyToEmptyListener.java | 26 +
.../queue/PendingQueueNotFullToFullListener.java | 26 +
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 82 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 45 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 109 +-
.../iotdb/db/pipe/task/stage/PipeTaskStage.java | 101 +-
.../iotdb/db/pipe/task/subtask/DecoratingLock.java | 44 +
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 138 +
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 95 +
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 135 +
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../rest/v1/handler/ExecuteStatementHandler.java | 4 +-
.../rest/v1/handler/QueryDataSetHandler.java | 5 +-
.../v1/handler/StatementConstructionHandler.java | 5 +-
.../rest/v2/handler/ExecuteStatementHandler.java | 4 +-
.../rest/v2/handler/QueryDataSetHandler.java | 5 +-
.../v2/handler/StatementConstructionHandler.java | 5 +-
.../iotdb/db/query/context/QueryContext.java | 2 +
.../db/query/control/QueryResourceManager.java | 7 +-
.../iotdb/db/query/control/SessionManager.java | 7 +
.../query/control/clientsession/ClientSession.java | 3 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 12 +-
.../db/quotas/AverageIntervalRateLimiter.java | 75 +
.../db/quotas/DataNodeThrottleQuotaManager.java | 153 +
.../iotdb/db/quotas/DefaultOperationQuota.java | 189 +
.../iotdb/db/quotas/FixedIntervalRateLimiter.java | 57 +
.../apache/iotdb/db/quotas/NoopOperationQuota.java | 48 +
.../org/apache/iotdb/db/quotas/OperationQuota.java | 50 +
.../org/apache/iotdb/db/quotas/QuotaLimiter.java | 198 +
.../org/apache/iotdb/db/quotas/RateLimiter.java | 130 +
.../apache/iotdb/db/quotas/ThrottleQuotaLimit.java | 76 +
.../org/apache/iotdb/db/rescon/SystemInfo.java | 33 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +
.../db/service/DataNodeInternalRPCService.java | 6 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 6 +-
.../db/service/TemporaryQueryDataFileService.java | 14 +-
.../db/service/basic/QueryFrequencyRecorder.java | 4 +-
.../db/service/metrics/CompactionMetrics.java | 12 +-
.../iotdb/db/service/metrics/FileMetrics.java | 26 +-
.../metrics/recorder/CompactionMetricsManager.java | 87 +-
.../db/service/thrift/ProcessorWithMetrics.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 159 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 270 +-
.../service/thrift/impl/MLNodeRPCServiceImpl.java | 22 +-
.../org/apache/iotdb/db/tools/DiskSpiller.java | 166 +
.../apache/iotdb/db/tools/FileSpillerReader.java | 143 +
.../org/apache/iotdb/db/tools/MemoryReader.java | 56 +
.../apache/iotdb/db/tools/SortBufferManager.java | 73 +
.../java/org/apache/iotdb/db/tools/SortReader.java | 37 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +
.../datastructure/FixedPriorityBlockingQueue.java | 10 +
.../db/utils/datastructure/MergeSortHeap.java | 4 +-
.../iotdb/db/utils/datastructure/MergeSortKey.java | 25 +-
.../iotdb/db/utils/datastructure/SortKey.java | 33 +
.../java/org/apache/iotdb/db/wal/WALManager.java | 8 +-
.../db/wal/allocation/FirstCreateStrategy.java | 3 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 41 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 9 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 14 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 -
.../iotdb/db/auth/AuthorizerManagerTest.java | 26 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 9 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 8 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 8 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 6 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 8 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 6 +-
.../db/auth/user/LocalFileUserManagerTest.java | 8 +-
.../engine/compaction/AbstractCompactionTest.java | 6 +
.../compaction/CompactionTaskComparatorTest.java | 8 +-
.../compaction/FastAlignedCrossCompactionTest.java | 1098 ++-
.../FastInnerCompactionPerformerTest.java | 30 +-
.../FastNonAlignedCrossCompactionTest.java | 1114 ++-
.../compaction/ReadChunkInnerCompactionTest.java | 377 +
.../ReadPointAlignedCrossCompactionTest.java | 7951 ++++++++++++++++++++
.../ReadPointNonAlignedCrossCompactionTest.java | 7920 +++++++++++++++++++
.../CrossSpaceCompactionWithFastPerformerTest.java | 7 +-
...eCompactionWithFastPerformerValidationTest.java | 715 ++
...actionWithReadPointPerformerValidationTest.java | 721 +-
.../cross/RewriteCompactionFileSelectorTest.java | 12 +
.../ReadChunkCompactionPerformerNoAlignedTest.java | 274 +
.../utils/CompactionFileGeneratorUtils.java | 60 +
.../utils/MultiTsFileDeviceIteratorTest.java | 12 +-
.../compaction/utils/TsFileGeneratorUtils.java | 116 +-
.../cache/DataNodeDevicePathCacheTest.java | 62 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 59 +-
.../cache/dualkeycache/DualKeyCacheTest.java | 17 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 137 +-
.../schemaRegion/SchemaRegionBasicTest.java | 103 +-
.../schemaRegion/SchemaRegionManagementTest.java | 4 +-
.../metadata/view/ViewExpressionToStringTest.java | 183 +
.../apache/iotdb/db/metric/MetricServiceTest.java | 3 -
.../db/mpp/execution/ConfigExecutionTest.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 2 +-
.../db/mpp/execution/QueryStateMachineTest.java | 2 +
.../execution/operator/MergeSortOperatorTest.java | 61 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 87 +
.../mpp/execution/operator/OperatorMemoryTest.java | 91 +-
.../mpp/execution/operator/SortOperatorTest.java | 273 +
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../schedule/DefaultDriverSchedulerTest.java | 28 +-
.../execution/schedule/DriverSchedulerTest.java | 10 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 18 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 236 +
.../mpp/plan/analyze/ExpressionAnalyzerTest.java | 3 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 18 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 14 +-
.../db/mpp/plan/optimization/TestPlanBuilder.java | 6 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 16 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 13 +-
.../node/process/AggregationNodeSerdeTest.java | 7 +-
.../plan/node/process/DeviceViewNodeSerdeTest.java | 6 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 8 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 5 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 4 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 7 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 15 +-
.../collector/CachedSchemaPatternMatcherTest.java | 175 +
.../core/collector/PipeRealtimeCollectTest.java | 277 +
.../executor/PipeAssignerSubtaskExecutorTest.java | 40 -
.../executor/PipeConnectorSubtaskExecutorTest.java | 12 +-
.../executor/PipeProcessorSubtaskExecutorTest.java | 14 +-
.../executor/PipeSubtaskExecutorTest.java | 2 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 36 +-
.../series/SeriesScanLimitOffsetPushDownTest.java | 23 +-
.../udf/datastructure/SerializableListTest.java | 2 +-
.../security/encrypt/MessageDigestEncryptTest.java | 6 +-
.../DataNodeInternalRPCServiceImplTest.java | 31 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 658 --
server/src/test/resources/logback-test.xml | 1 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 11 +-
site/src/main/.vuepress/sidebar/V0.13.x/en.ts | 3 +-
site/src/main/.vuepress/sidebar/V0.13.x/zh.ts | 3 +-
site/src/main/.vuepress/sidebar/V1.0.x/zh.ts | 1 -
site/src/main/.vuepress/sidebar/V1.1.x/zh.ts | 1 -
site/src/main/.vuepress/sidebar/en.ts | 1 +
site/src/main/.vuepress/sidebar/zh.ts | 2 +-
site/src/main/.vuepress/styles/index.scss | 6 +-
site/src/main/package-lock.json | 2881 +++----
spark-iotdb-connector/pom.xml | 2 +-
thrift-commons/src/main/thrift/common.thrift | 25 +
.../src/main/thrift/confignode.thrift | 72 +-
thrift-mlnode/src/main/thrift/mlnode.thrift | 2 +-
thrift/src/main/thrift/client.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 54 +-
tsfile/pom.xml | 5 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +
.../apache/iotdb/tsfile/compress/ICompressor.java | 85 +
.../iotdb/tsfile/compress/IUnCompressor.java | 49 +
.../iotdb/tsfile/encoding/decoder/Decoder.java | 26 +
.../tsfile/encoding/decoder/DoubleRLBEDecoder.java | 197 +
.../encoding/decoder/DoubleSprintzDecoder.java | 139 +
.../tsfile/encoding/decoder/FloatRLBEDecoder.java | 197 +
.../encoding/decoder/FloatSprintzDecoder.java | 141 +
.../tsfile/encoding/decoder/IntRLBEDecoder.java | 196 +
.../tsfile/encoding/decoder/IntSprintzDecoder.java | 129 +
.../tsfile/encoding/decoder/LongRLBEDecoder.java | 196 +
.../encoding/decoder/LongSprintzDecoder.java | 127 +
.../tsfile/encoding/decoder/SprintzDecoder.java | 54 +
.../iotdb/tsfile/encoding/encoder/DoubleRLBE.java | 272 +
.../encoding/encoder/DoubleSprintzEncoder.java | 157 +
.../iotdb/tsfile/encoding/encoder/FloatRLBE.java | 273 +
.../encoding/encoder/FloatSprintzEncoder.java | 156 +
.../iotdb/tsfile/encoding/encoder/IntRLBE.java | 263 +
.../tsfile/encoding/encoder/IntSprintzEncoder.java | 153 +
.../iotdb/tsfile/encoding/encoder/LongRLBE.java | 257 +
.../encoding/encoder/LongSprintzEncoder.java | 154 +
.../apache/iotdb/tsfile/encoding/encoder/RLBE.java | 61 +
.../tsfile/encoding/encoder/SprintzEncoder.java | 70 +
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 50 +
.../apache/iotdb/tsfile/encoding/fire/Fire.java | 56 +
.../apache/iotdb/tsfile/encoding/fire/IntFire.java | 52 +
.../iotdb/tsfile/encoding/fire/LongFire.java | 48 +
.../file/metadata/enums/CompressionType.java | 6 +-
.../tsfile/file/metadata/enums/TSDataType.java | 17 +
.../tsfile/file/metadata/enums/TSEncoding.java | 9 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../common/block/column/ColumnEncoderFactory.java | 5 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 13 +-
.../read/filter/PredicateRemoveNotRewriter.java | 50 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 158 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 179 +-
.../tsfile/read/filter/basic/BinaryFilter.java | 5 -
.../iotdb/tsfile/read/filter/basic/Filter.java | 11 +-
.../tsfile/read/filter/factory/FilterFactory.java | 10 +-
.../tsfile/read/filter/operator/AndFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Between.java | 127 +-
.../iotdb/tsfile/read/filter/operator/Eq.java | 25 +-
.../iotdb/tsfile/read/filter/operator/Gt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/GtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/In.java | 34 +-
.../iotdb/tsfile/read/filter/operator/Like.java | 55 +-
.../iotdb/tsfile/read/filter/operator/Lt.java | 23 +-
.../iotdb/tsfile/read/filter/operator/LtEq.java | 23 +-
.../iotdb/tsfile/read/filter/operator/NotEq.java | 25 +-
.../tsfile/read/filter/operator/NotFilter.java | 26 +-
.../tsfile/read/filter/operator/OrFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 57 +-
.../read/reader/chunk/AlignedChunkReader.java | 40 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 4 +
.../iotdb/tsfile/read/reader/page/PageReader.java | 12 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 42 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 4 -
.../apache/iotdb/tsfile/compress/LZMA2Test.java | 104 +
.../tsfile/encoding/decoder/RLBEDecoderTest.java | 257 +
.../encoding/decoder/SprintzDecoderTest.java | 593 ++
.../tsfile/read/filter/FilterSerializeTest.java | 21 +-
.../read/filter/MinTimeMaxTimeFilterTest.java | 42 +-
.../iotdb/tsfile/read/filter/OperatorTest.java | 4 +-
.../filter/PredicateRemoveNotRewriterTest.java | 121 +
.../tsfile/read/filter/StatisticsFilterTest.java | 113 +-
960 files changed, 64381 insertions(+), 16235 deletions(-)
create mode 100644 client-py/iotdb/utils/IoTDBConnectionException.py
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/CheckTimeSeriesExistenceRPCHandler.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/OperatePipeRPCHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/partition/CountTimeSlotListPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/CreatePipePlanV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/DropPipePlanV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/SetPipeStatusPlanV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/quota/SetThrottleQuotaPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/CreatePipeSinkPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/CreatePipeSinkPlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/DropPipePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/DropPipePlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/DropPipeSinkPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/DropPipeSinkPlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/GetPipeSinkPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/GetPipeSinkPlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/PreCreatePipePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/PreCreatePipePlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/SetPipeStatusPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/SetPipeStatusPlanV1.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlanV1.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/CommitSetSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/ExtendSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/PreSetSchemaTemplatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/partition/CountTimeSlotListResp.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMap.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/LoadCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/BaseNodeCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/ConfigNodeHeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/DataNodeHeartbeatCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/NodeHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/NodeStatistics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionGroupStatistics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionHeartbeatSample.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/region/RegionStatistics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/route/RegionRouteCache.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/HeartbeatService.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/StatisticsService.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/IClusterStatusSubscriber.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/RouteChangeEvent.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/StatisticsChangeEvent.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/BaseNodeCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/ConfigNodeHeartbeatCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/DataNodeHeartbeatCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/NodeHeartbeatSample.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/heartbeat/NodeStatistics.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/IEvent.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/NodeStatisticsEvent.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionGroupCache.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionGroupStatistics.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionHeartbeatSample.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/heartbeat/RegionStatistics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipeTaskCoordinator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskOperation.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/TemplatePreSetTable.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/AbstractOperatePipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/pipe/task/OperatePipeTaskState.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/SetTemplateState.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/sync/OperatePipeState.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSchemaInfoTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterSyncInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/PipeInfoTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/TemplateTableTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfoTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TemplatePreSetTableTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TemplateTableTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/CreatePipePluginProcedureTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/DropPipePluginProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedureTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2Test.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/DropPipeProcedureV2Test.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StartPipeProcedureV2Test.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/StopPipeProcedureV2Test.java
delete mode 100644 docs/zh/UserGuide/Cluster/IoTDB-Deploy.md
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryLastCache2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryLastCacheIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderBy2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/quotas/IoTDBSpaceQuotaIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/AbstractSchemaIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBExtendTemplateIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/util/AbstractSchemaIT.java
create mode 100644 library-udf/Readme.md
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/AbstractCpuMetricsManager.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetrics.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/CpuMetricsConstant.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/LinuxCpuMetricsManager.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/MacCpuMetricsManager.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/cpu/WindowsCpuMetricsManager.java
delete mode 100644 mlnode/iotdb/mlnode/model_storage.py
create mode 100644 mlnode/iotdb/mlnode/storage.py
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/constant/QueryThreadName.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/enums/SpaceQuotaType.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/RpcThrottlingException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/BuiltinPipePlugin.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/collector/DefaultCollector.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/DoNothingConnector.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/DoNothingProcessor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMeta.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeMetaKeeper.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeRuntimeMeta.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeStaticMeta.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeStatus.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTaskMeta.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeTaskMetaAccessor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/quotas/SpaceQuotaType.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeCollector.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/collector/PipeCollectorRuntimeConfiguration.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/EventType.java
delete mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/deletion/DeletionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/dml/deletion/DeletionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/dml/insertion/TabletInsertionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/dml/insertion/TsFileInsertionEvent.java
delete mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TabletInsertionEvent.java
delete mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TsFileInsertionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeConnectionException.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeCriticalException.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeException.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeRuntimeNonCriticalException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionTaskStatus.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionTaskType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/exception/CompactionMemoryNotEnoughException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/DeviceUsingTemplateSchemaCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/TimeSeriesSchemaCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/FIFOCacheEntryManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl/LogicalViewMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl/LogicalViewSchema.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/info/LogicalViewInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/CreateLogicalViewPlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ICreateLogicalViewPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateAlterOperationType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/alter/TemplateAlterInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/alter/TemplateAlterOperationUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/alter/TemplateExtendInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ViewExpressionType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/BinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/AdditionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/ArithmeticBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/DivisionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/ModuloViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/MultiplicationViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/arithmetic/SubtractionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/CompareBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/EqualToViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/GreaterEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/GreaterThanViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/LessEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/LessThanViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/compare/NonEqualViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicAndViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicBinaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/binary/logic/LogicOrViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/ConstantViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/LeafViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/NullViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/TimeSeriesViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/leaf/TimestampViewOperand.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/multi/FunctionViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ternary/BetweenViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/ternary/TernaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/InViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/IsNullViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/LikeViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/LogicNotViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/NegationViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/RegularViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/unary/UnaryViewExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/GetSourcePathsVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/TransformToExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/view/viewExpression/visitor/ViewExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/exception/CpuNotEnoughException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/source/PipelineSourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/merge/SortKeyComparator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/NormalSchemaFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/TemplateSchemaFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/CountTimeSlotListTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/AlterSchemaTemplateTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/quota/SetThrottleQuotaTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/quota/ShowThrottleQuotaTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/TransformToViewExpressionVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateLogicalViewNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/NullOrdering.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderByKey.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/SortKey.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountTimeSlotListStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateLogicalViewStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/AlterSchemaTemplateStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/quota/SetThrottleQuotaStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/quota/ShowThrottleQuotaStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskRegionAgent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/config/PipeCollectorConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/config/PipeConfig.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/config/PipeConnectorConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/config/PipeProcessorConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/IoTDBDataRegionCollector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/PipeCollectorEventPendingQueue.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/PipeCollectorEventSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/PipeHistoricalCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/PipeHistoricalDataRegionTsFileCollector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/PipeRealtimeCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/PipeRealtimeDataRegionCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/PipeRealtimeDataRegionHybridCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/assigner/DisruptorQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/assigner/PipeDataRegionAssigner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/cache/PipeRealtimeEventCache.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/IoTLogListerner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/PipeInsertionDataNodeListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/RatisLogListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/SimpleLogListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/TsFileGenerationListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/CachedSchemaPatternMatcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/PipeDataRegionMatcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/Rule.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/RulePrefixMatchTree.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/recorder/TsFileEpoch.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/recorder/TsFileEpochRecorder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorContainer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorPluginRuntimeWrapper.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorSubtaskLifeCycle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorSubtaskManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/PipeTabletInsertionEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/PipeTsFileInsertionEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/access/PipeRow.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/access/PipeRowIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/collector/PipeEventCollector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/collector/PipeRowCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/PipeTabletInsertionEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/PipeTsFileInsertionEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeEventIndexer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeIoTEventIndexer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeRatisEventIndexer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeSimpleEventIndexer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeTsFileEventIndexer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/realtime/PipeRealtimeCollectEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/realtime/PipeRealtimeCollectEventFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/realtime/TsFileEpoch.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/realtime/TsFileEpochManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/realtime/TsFileEpochStateMigrator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/access/PipeRow.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/access/PipeRowIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/collector/PipeEventCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/collector/PipeRowCollector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/core/processor/PipeProcessorPluginRuntimeWrapper.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeTaskExecutorManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeResourceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/PipeBuilder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/PipeTaskManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/DecoratingLock.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeAssignerSubtask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeConnectorSubtask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeProcessorSubtask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/callable/PipeSubtask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/EventSupplier.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBlockingPendingQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenablePendingQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableUnblockingPendingQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/PendingQueueEmptyToNotEmptyListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/PendingQueueFullToNotFullListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/PendingQueueNotEmptyToEmptyListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/queue/PendingQueueNotFullToFullListener.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/DecoratingLock.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeProcessorSubtask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeSubtask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/AverageIntervalRateLimiter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/DataNodeThrottleQuotaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/DefaultOperationQuota.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/FixedIntervalRateLimiter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/NoopOperationQuota.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/OperationQuota.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/QuotaLimiter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/RateLimiter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/quotas/ThrottleQuotaLimit.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/DiskSpiller.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/FileSpillerReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/MemoryReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/SortBufferManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/tools/SortReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/datastructure/SortKey.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadChunkInnerCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadPointAlignedCrossCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadPointNonAlignedCrossCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/DataNodeDevicePathCacheTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/view/ViewExpressionToStringTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SortOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/pipe/core/collector/CachedSchemaPatternMatcherTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/pipe/core/collector/PipeRealtimeCollectTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/BufferedPipeDataQueueTest.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/DoubleRLBEDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/DoubleSprintzDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/FloatRLBEDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/FloatSprintzDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/IntRLBEDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/IntSprintzDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongRLBEDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongSprintzDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/SprintzDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/DoubleRLBE.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/DoubleSprintzEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/FloatRLBE.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/FloatSprintzEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/IntRLBE.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/IntSprintzEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/LongRLBE.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/LongSprintzEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/RLBE.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SprintzEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/fire/Fire.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/fire/IntFire.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/fire/LongFire.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriter.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/compress/LZMA2Test.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/RLBEDecoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/SprintzDecoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/PredicateRemoveNotRewriterTest.java