Commit d65dcc6
committed
Merge remote-tracking branch 'iotdb/master' into feature/iotconsensus-snap-multi-dir
# Conflicts:
# iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/builder/PipeTsFileBuilder.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/task/InnerSpaceCompactionTask.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/SizeTieredCompactionSelector.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotLoader.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/generator/TsFileNameGenerator.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/allocation/AbstractNodeAllocationStrategy.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/util/LoadUtil.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/TierManager.java
# iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/IoTDBSnapshotTest.java
# iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/FolderManager.java
# iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/DirectoryStrategy.java
# iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/disk/strategy/MinFolderOccupiedSpaceFirstStrategy.java4,905 files changed
Lines changed: 259712 additions & 98431 deletions
File tree
- .claude
- .github/workflows
- .idea
- .mvn/wrapper
- code-coverage
- distribution
- src/assembly
- docker
- src/main
- DockerCompose
- example
- client-c-example
- src
- client-cpp-example
- src
- jdbc
- src/main/java/org/apache/iotdb
- mqtt-customize
- src/main
- java/org/apache/iotdb/mqtt/server
- resources/META-INF/services
- mqtt
- src/main/java/org/apache/iotdb/mqtt
- pipe-count-point-processor
- pipe-opc-ua-sink
- rest-java-example
- src/main/java/org/apache/iotdb
- schema
- session
- src/main/java/org/apache/iotdb
- subscription
- src/main/java/org/apache/iotdb
- trigger
- udf
- external-service-impl
- mqtt
- src
- main
- i18n
- en/org/apache/iotdb/mqtt/i18n
- zh/org/apache/iotdb/mqtt/i18n
- java/org/apache/iotdb/mqtt
- resources/META-INF/services
- test/java/org/apache/iotdb/mqtt
- rest-openapi
- src/main/openapi3
- rest
- src/main
- i18n
- en/org/apache/iotdb/rest/i18n
- zh/org/apache/iotdb/rest/i18n
- java/org/apache/iotdb/rest
- protocol
- filter
- handler
- impl
- table/v1
- handler
- impl
- utils
- v1
- handler
- impl
- v2
- handler
- impl
- integration-test
- src
- assembly
- main/java/org/apache/iotdb
- itbase
- constant
- env
- runtime
- it
- env
- cluster
- config
- env
- node
- remote/config
- utils
- test
- java/org/apache/iotdb
- ainode
- it
- utils
- confignode/it
- load
- partition
- procedure
- regionmigration
- pass/commit
- db/it
- aggregation
- aligned
- audit
- auth
- fill
- iotconsensusv2
- batch
- stream
- last
- mqtt
- query
- schema
- regionscan
- selectinto
- specialwords
- strangepath
- trigger
- udaf
- udf
- utils
- libudf/it/dlearn
- pipe/it
- dual
- tablemodel/manual
- basic
- enhanced
- treemodel
- auto
- basic
- enhanced
- manual
- single
- triple
- relational/it
- db/it
- udf
- insertquery
- mqtt
- query
- old
- builtinfunction/scalar
- query
- recent
- copyto
- informationschema
- scalar
- subquery
- view
- old/query
- recent
- rest/it
- schema
- session
- session/it
- pool
- subscription/it
- cluster
- dual
- tablemodel
- treemodel
- local
- tablemodel
- triple
- treemodel
- regression
- auto_create_db
- mix
- param
- pullconsumer
- autocommit
- format
- loose_range
- mode
- multi
- pattern
- time
- pushconsumer
- format
- loose_range
- mode
- multi
- pattern
- time
- topic
- user
- tools/it
- resources
- ainode-example
- iotdb-api
- external-api
- external-service-api
- src/main/java/org/apache/iotdb/externalservice/api
- pipe-api
- src
- main
- i18n
- en/org/apache/iotdb/pipe/api/i18n
- zh/org/apache/iotdb/pipe/api/i18n
- java/org/apache/iotdb/pipe/api
- collector
- customizer/parameter
- event/dml/insertion
- exception
- type
- test/java/org/apache/iotdb/pipe/api/customizer/parameter
- trigger-api
- src/main
- i18n
- en/org/apache/iotdb/trigger/api/i18n
- zh/org/apache/iotdb/trigger/api/i18n
- java/org/apache/iotdb/trigger/api/enums
- udf-api
- src/main
- i18n
- en/org/apache/iotdb/udf/api/i18n
- zh/org/apache/iotdb/udf/api/i18n
- java/org/apache/iotdb/udf/api
- customizer
- analysis
- config
- strategy
- relational
- access
- table
- argument
- specification
- type
- utils
- iotdb-client
- client-cpp
- src
- main
- test
- catch2
- cpp
- client-py
- iotdb
- tsfile/utils
- utils
- tests/integration
- cli
- src/main
- i18n
- en/org/apache/iotdb/cli/i18n
- zh/org/apache/iotdb/cli/i18n
- java/org/apache/iotdb
- cli
- utils
- tool
- backup
- common
- data
- schema
- tsfile
- subscription
- isession
- src/main
- i18n
- en/org/apache/iotdb/isession/i18n
- zh/org/apache/iotdb/isession/i18n
- java/org/apache/iotdb/isession
- template
- jdbc
- src
- main
- i18n
- en/org/apache/iotdb/jdbc/i18n
- zh/org/apache/iotdb/jdbc/i18n
- java/org/apache/iotdb/jdbc
- relational
- test/java/org/apache/iotdb/jdbc
- service-rpc
- src
- main
- i18n
- en/org/apache/iotdb/rpc/i18n
- zh/org/apache/iotdb/rpc/i18n
- java/org/apache/iotdb/rpc
- stmt
- test/java/org/apache/iotdb/rpc/stmt
- session
- src
- main
- i18n
- en/org/apache/iotdb/session/i18n
- zh/org/apache/iotdb/session/i18n
- java/org/apache/iotdb/session
- pool
- subscription/payload
- template
- util
- test/resources
- subscription
- src/main
- i18n
- en/org/apache/iotdb/rpc/subscription/i18n
- zh/org/apache/iotdb/rpc/subscription/i18n
- java/org/apache/iotdb
- rpc/subscription
- annotation
- config
- exception
- payload
- poll
- request
- response
- session/subscription
- consumer
- base
- table
- tree
- model
- payload
- util
- iotdb-core
- ainode
- iotdb/ainode/core
- device
- backend
- inference
- batcher
- dispatcher
- pipeline
- pool_scheduler
- strategy
- ingress
- manager
- model
- chronos2
- moirai2
- common
- module
- position
- transform
- moment
- sktime
- arima
- exponential_smoothing
- gaussian_hmm
- gmm_hmm
- naive_forecaster
- stl_forecaster
- stray
- sundial
- timer_xl
- toto
- data
- util
- inference
- model
- rpc
- util
- resources
- conf
- antlr
- src/main/antlr4/org/apache/iotdb/db/qp/sql
- calc-commons
- src/main
- codegen
- dataModel
- templates
- i18n
- en/org/apache/iotdb/calc/i18n
- zh/org/apache/iotdb/calc/i18n
- java/org/apache/iotdb/calc
- exception
- execution
- aggregation
- operator
- process
- fill
- filter
- identity
- linear
- function
- partition
- gapfill
- join
- merge
- comparator
- rowpattern
- expression
- matcher
- window
- function
- aggregate
- rank
- value
- partition
- frame
- utils
- source/relational
- aggregation
- approximate
- grouped
- array
- builder
- relational
- schedule/queue
- metric
- plan
- planner
- memory
- relational
- metadata
- planner
- ir
- utils/matching
- pattern
- service
- transformation
- dag
- adapter
- column
- binary
- factory
- strategies
- leaf
- multi
- ternary
- utils
- udf
- unary
- scalar
- factory
- inteface
- util
- udf
- util
- datastructure
- iterator
- row
- tv
- util
- utils
- constant
- datastructure
- sort
- confignode
- src
- assembly
- main
- i18n
- en/org/apache/iotdb/confignode/i18n
- zh/org/apache/iotdb/confignode/i18n
- java/org/apache/iotdb/confignode
- audit
- client
- async
- handlers/rpc
- subscription
- sync
- conf
- consensus
- request
- read
- cq
- exernalservice
- model
- region
- ttl
- write
- cq
- externalservice
- model
- pipe
- payload
- task
- table
- template
- response
- externalservice
- model
- partition
- pipe
- plugin
- task
- table
- template
- statemachine
- manager
- consensus
- cq
- externalservice
- load
- balancer
- partition
- region
- router/leader
- cache
- detector
- node
- service
- node
- partition
- pipe
- agent
- plugin
- runtime
- task
- coordinator
- plugin
- runtime
- heartbeat
- task
- event
- metric
- overview
- sink
- source
- receiver
- protocol
- visitor
- resource
- sink
- payload
- protocol
- source
- schema
- subscription
- persistence
- auth
- cq
- executor
- node
- partition
- maintainer
- pipe
- quota
- schema
- mnode
- basic
- factory
- impl
- info
- subscription
- procedure
- env
- impl
- cq
- model
- node
- partition
- pipe
- plugin
- runtime
- task
- util
- region
- schema
- table
- view
- subscription
- consumer
- runtime
- subscription
- topic
- runtime
- sync
- testonly
- trigger
- state
- schema
- store
- service
- thrift
- writelog/io
- test
- java/org/apache/iotdb/confignode
- consensus
- request
- response/pipe
- cq
- manager
- load/balancer/region
- pipe
- coordinator/runtime/heartbeat
- source
- persistence
- pipe
- schema
- procedure
- env
- impl
- cq
- partition
- pipe
- receiver
- runtime
- task
- schema
- subscription/subscription
- resources/oldsnapshot
- consensus
- src
- main
- i18n
- en/org/apache/iotdb/consensus/i18n
- zh/org/apache/iotdb/consensus/i18n
- java/org/apache/iotdb/consensus
- common
- request
- config
- exception
- iot
- client
- logdispatcher
- log
- service
- pipe
- consensuspipe
- metric
- service
- ratis
- metrics
- utils
- simple
- test/java/org/apache/iotdb/consensus
- iot
- util
- ratis
- simple
- datanode
- src
- assembly
- resources/conf
- main
- i18n
- en/org/apache/iotdb/db/i18n
- zh/org/apache/iotdb/db/i18n
- java/org/apache/iotdb/db
- audit
- auth
- conf
- rest
- consensus
- statemachine
- dataregion
- schemaregion
- exception
- ainode
- load
- query
- sql
- partition
- pipe
- agent
- plugin
- dataregion
- schemaregion
- receiver
- runtime
- task
- builder
- connection
- execution
- stage
- subtask
- processor
- sink
- consensus
- deletion
- persist
- recover
- metric
- event
- common
- deletion
- heartbeat
- row
- schema
- statement
- tablet
- parser
- terminate
- tsfile
- aggregator
- parser
- query
- scan
- table
- util
- realtime
- metric
- overview
- processor
- receiver
- schema
- sink
- source
- processor
- aggregate
- operator/intermediateresult
- sametype/numeric
- specifictype/doubletype
- window
- datastructure
- processor
- downsampling
- changing
- sdt
- tumbling
- iotconsensusv2
- pipeconsensus
- twostage
- combiner
- exchange
- payload
- receiver
- sender
- plugin
- receiver
- protocol
- airgap
- iotconsensusv2
- legacy
- loader
- pipeconsensus
- thrift
- transform
- converter
- statement
- visitor
- resource
- log
- memory
- tsfile
- sink
- client
- payload
- evolvable
- batch
- request
- legacy
- protocol
- airgap
- iotconsensusv2
- handler
- payload
- builder
- request
- legacy
- opcda
- opcua
- client
- server
- pipeconsensus
- handler
- payload
- builder
- request
- thrift
- async
- handler
- sync
- websocket
- writeback
- util
- builder
- sorter
- source
- dataregion
- historical
- realtime
- assigner
- disruptor
- epoch
- listener
- matcher
- schemaregion
- protocol
- client
- ainode
- an
- cn
- dn
- rest
- filter
- table/v1
- handler
- impl
- v1
- handler
- impl
- v2
- handler
- impl
- session
- thrift
- handler
- impl
- queryengine
- common
- header
- schematree
- node
- visitor
- execution
- aggregation
- slidingwindow
- timerangeiterator
- driver
- exchange
- sink
- source
- executor
- fragment
- memory
- operator
- process
- ai
- copyto
- tsfile
- function/partition
- join
- merge
- last
- window
- function
- partition
- schema
- source
- sink
- source
- relational
- aggregation
- approximate
- grouped
- array
- window
- ainode
- schedule
- queue
- multilevelqueue
- task
- warnings
- metric
- plan
- analyze
- cache/partition
- load
- schema
- execution
- config
- executor
- metadata
- ai
- externalservice
- relational
- template
- session
- sys
- pipe
- quota
- memory
- expression
- binary
- leaf
- multi
- builtin
- helper
- other
- ternary
- unary
- visitor
- cartesian
- predicate
- optimization
- parser
- planner
- distribution
- memory
- plan
- node
- load
- metadata
- read
- write
- view
- pipe
- process
- AI
- join
- last
- sink
- source
- write
- parameter
- model
- relational
- analyzer
- predicate
- schema
- tablefunction
- function/tvf
- metadata
- fetcher
- cache
- planner
- distribute
- ir
- iterative
- rule
- node
- schema
- optimizations
- rowpattern
- rowpattern
- security
- sql
- ast
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| 23 | + | |
| 24 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
| 153 | + | |
| 154 | + | |
| 155 | + | |
| 156 | + | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
| 175 | + | |
| 176 | + | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
| 197 | + | |
| 198 | + | |
| 199 | + | |
| 200 | + | |
| 201 | + | |
| 202 | + | |
| 203 | + | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
| 211 | + | |
| 212 | + | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
| 217 | + | |
| 218 | + | |
| 219 | + | |
| 220 | + | |
| 221 | + | |
| 222 | + | |
| 223 | + | |
| 224 | + | |
| 225 | + | |
| 226 | + | |
| 227 | + | |
| 228 | + | |
| 229 | + | |
| 230 | + | |
| 231 | + | |
| 232 | + | |
| 233 | + | |
| 234 | + | |
| 235 | + | |
| 236 | + | |
| 237 | + | |
| 238 | + | |
0 commit comments