Commit a8303a5
committed
Merge branch 'master' of https://github.com/apache/iotdb into last-cache-fix
1,444 files changed
Lines changed: 37759 additions & 11847 deletions
File tree
- .github/workflows
- external-service-impl
- mqtt
- src/main
- i18n
- en/org/apache/iotdb/mqtt/i18n
- zh/org/apache/iotdb/mqtt/i18n
- java/org/apache/iotdb/mqtt
- rest
- src/main
- i18n
- en/org/apache/iotdb/rest/i18n
- zh/org/apache/iotdb/rest/i18n
- java/org/apache/iotdb/rest
- protocol
- table/v1/handler
- v1/handler
- v2/handler
- integration-test/src/test/java/org/apache/iotdb
- ainode/it
- db/it
- aggregation
- aligned
- auth
- fill
- mqtt
- schema
- specialwords
- strangepath
- trigger
- udaf
- udf
- pipe/it/dual/treemodel/auto/basic
- relational/it/db/it
- iotdb-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/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/table
- argument
- specification
- type
- utils
- iotdb-client
- cli
- src/main
- i18n
- en/org/apache/iotdb/cli/i18n
- zh/org/apache/iotdb/cli/i18n
- java/org/apache/iotdb
- cli
- utils
- tool
- backup
- data
- schema
- tsfile
- 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
- service-rpc
- src/main
- i18n
- en/org/apache/iotdb/rpc/i18n
- zh/org/apache/iotdb/rpc/i18n
- 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
- template
- util
- subscription
- src/main
- i18n
- en/org/apache/iotdb/rpc/subscription/i18n
- zh/org/apache/iotdb/rpc/subscription/i18n
- java/org/apache/iotdb
- rpc/subscription
- config
- payload/poll
- session/subscription
- consumer/base
- util
- iotdb-core
- ainode
- calc-commons
- src/main
- i18n
- en/org/apache/iotdb/calc/i18n
- zh/org/apache/iotdb/calc/i18n
- java/org/apache/iotdb/calc
- execution
- operator
- process
- function
- partition
- join/merge
- comparator
- rowpattern
- expression
- matcher
- window
- partition
- frame
- utils
- source/relational/aggregation
- approximate
- grouped
- array
- relational
- schedule/queue
- plan
- planner
- relational/planner
- ir
- service
- transformation
- dag
- column
- binary
- multi
- unary
- scalar
- factory
- util
- util
- datastructure
- row
- tv
- utils
- sort
- confignode
- src/main
- i18n
- en/org/apache/iotdb/confignode/i18n
- zh/org/apache/iotdb/confignode/i18n
- java/org/apache/iotdb/confignode
- client
- async
- handlers/rpc
- subscription
- sync
- conf
- consensus
- request
- write/pipe/task
- statemachine
- manager
- consensus
- cq
- externalservice
- load
- balancer
- partition
- region
- router/leader
- cache
- detector
- node
- service
- node
- partition
- pipe
- agent
- runtime
- task
- coordinator
- plugin
- runtime
- heartbeat
- task
- event
- metric
- overview
- sink
- source
- receiver/protocol
- resource
- sink/protocol
- source
- schema
- subscription
- persistence
- auth
- cq
- executor
- node
- partition
- maintainer
- pipe
- schema
- mnode
- basic
- factory
- impl
- subscription
- procedure
- env
- impl
- cq
- node
- partition
- pipe
- plugin
- runtime
- task
- util
- region
- schema
- table
- view
- subscription
- consumer
- runtime
- subscription
- topic
- runtime
- sync
- testonly
- trigger
- store
- service
- thrift
- writelog/io
- consensus
- src/main
- i18n
- en/org/apache/iotdb/consensus/i18n
- zh/org/apache/iotdb/consensus/i18n
- java/org/apache/iotdb/consensus
- common
- exception
- iot
- client
- logdispatcher
- service
- pipe
- consensuspipe
- service
- ratis
- metrics
- utils
- simple
- datanode
- src
- main
- i18n
- en/org/apache/iotdb/db/i18n
- zh/org/apache/iotdb/db/i18n
- java/org/apache/iotdb/db
- auth
- conf
- rest
- consensus/statemachine
- dataregion
- schemaregion
- partition
- pipe
- agent
- plugin
- runtime
- task
- builder
- connection
- subtask
- processor
- sink
- consensus/deletion
- persist
- recover
- event/common
- row
- schema
- statement
- tablet
- parser
- tsfile
- aggregator
- parser
- query
- scan
- table
- util
- metric
- overview
- processor
- schema
- sink
- source
- processor
- aggregate
- operator/intermediateresult
- sametype/numeric
- specifictype/doubletype
- window/datastructure
- downsampling
- changing
- sdt
- tumbling
- twostage
- combiner
- exchange
- payload
- receiver
- sender
- plugin
- receiver
- protocol
- airgap
- iotconsensusv2
- legacy
- loader
- 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
- thrift
- async
- handler
- sync
- websocket
- writeback
- util/builder
- source
- dataregion
- historical
- realtime
- assigner
- disruptor
- epoch
- matcher
- schemaregion
- protocol
- client
- an
- cn
- dn
- session
- thrift
- handler
- impl
- queryengine
- common/schematree
- node
- execution
- aggregation
- slidingwindow
- driver
- exchange
- sink
- source
- executor
- fragment
- memory
- operator
- process
- copyto
- tsfile
- join
- last
- schema
- source
- relational
- window/ainode
- schedule
- warnings
- metric
- plan
- analyze
- cache/partition
- load
- execution
- config
- executor
- metadata
- relational
- sys/quota
- expression
- binary
- multi/builtin/helper
- visitor
- cartesian
- predicate
- optimization
- parser
- planner
- distribution
- plan
- node
- load
- metadata
- read
- write
- view
- source
- write
- parameter
- relational
- analyzer
- predicate
- schema
- metadata
- fetcher
- planner
- distribute
- ir
- iterative
- rule
- node
- optimizations
- rowpattern/rowpattern
- security
- sql
- ast
- parser
- util
- scheduler
- load
- statement
- crud
- literal
- metadata
- sys
- transformation/dag
- adapter
- input
- transformer
- binary
- unary
- scalar
- udf
- util
- schemaengine
- rescon
- schemaregion
- attribute
- update
- impl
- logfile
- visitor
- mtree
- impl
- mem
- mnode
- basic
- factory
- impl
- info
- iterator
- snapshot
- pbtree
- flush
- memory
- mnode
- basic
- container
- factory
- impl
- schemafile
- log
- pagemgr
- loader
- tag
- utils
- view/visitor
- write/req
- table
- template
- service
- externalservice
- metrics
- file
- storageengine
- buffer
- dataregion
- compaction
- execute
- performer/impl
- recover
- task
- utils
- executor
- batch/utils
- readchunk
- reader
- writer
- repair
- schedule
- selector
- constant
- estimator
- impl
- settle
- tool
- flush
- pool
- memtable
- modification
- v1
- io
- read
- control
- filescan/impl
- reader/chunk
- metadata
- snapshot
- tsfile
- generator
- timeindex
- utils
- fileTimeIndexCache
- tableDiskUsageIndex
- tsfile
- wal
- allocation
- buffer
- checkpoint
- io
- node
- recover
- file
- utils
- listener
- load
- active
- config
- converter
- disk
- memory
- metrics
- splitter
- util
- rescon
- disk
- strategy
- memory
- quotas
- subscription
- agent
- broker
- event
- batch
- cache
- response
- receiver
- task/subtask
- tools
- schema
- settle
- utils
- validate
- trigger
- executor
- service
- utils
- columngenerator/parameter
- concurrent
- datastructure
- windowing/runtime
- writelog
- test/java/org/apache/iotdb/db/queryengine/plan/relational/planner
- metrics
- core
- src/main
- i18n
- en/org/apache/iotdb/metrics/core/i18n
- zh/org/apache/iotdb/metrics/core/i18n
- java/org/apache/iotdb/metrics/core
- reporter
- utils
- interface
- src/main
- i18n
- en/org/apache/iotdb/metrics/i18n
- zh/org/apache/iotdb/metrics/i18n
- java/org/apache/iotdb/metrics
- config
- metricsets
- disk
- net
- reporter
- iotdb
- prometheus
- utils
- node-commons
- src/main
- i18n
- en/org/apache/iotdb/commons/i18n
- zh/org/apache/iotdb/commons/i18n
- java/org/apache/iotdb/commons
- auth
- authorizer
- entity
- role
- user
- binaryallocator
- autoreleaser
- evictor
- client
- async
- exception
- factory
- request
- cluster
- concurrent
- threadpool
- conf
- consensus
- iotv2/container
- cq
- enums
- exception
- pipe
- externalservice
- external/collections4
- bidimap
- collection
- iterators
- keyvalue
- map
- file
- memory
- path
- pipe
- agent
- plugin
- builtin/processor/throwing
- service
- runtime
- task
- connection
- execution
- meta
- progress
- subtask
- config
- constant
- datastructure
- options
- pattern
- queue
- listening
- serializer
- event
- metric
- receiver
- resource
- ref
- snapshot
- sink
- client
- compressor
- payload/thrift/common
- protocol
- source
- queryengine
- common
- execution/operator/source/relational/aggregation/grouped/hash
- plan
- planner/plan/node
- process
- relational
- function
- tvf
- match
- metadata
- planner
- node
- rowpattern
- sql
- ast
- util
- type
- utils
- udf
- utils
- schema
- filter
- impl
- node
- common
- role
- table
- column
- template
- view
- viewExpression
- unary
- security/encrypt
- service
- metric
- cpu
- subscription/config
- sync
- udf
- builtin
- relational/tvf
- service
- utils
- utils
- KillPoint
- library-udf
- src/main
- i18n
- en/org/apache/iotdb/library/i18n
- zh/org/apache/iotdb/library/i18n
- java/org/apache/iotdb/library
- anomaly
- dlearn
- util/cluster
- dmatch/util
- dprofile/util
- dquality/util
- drepair
- util
- frequency
- util
- match
- utils
- util
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 | |
|---|---|---|---|
| |||
30 | 30 | | |
31 | 31 | | |
32 | 32 | | |
33 | | - | |
| 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 | + | |
34 | 74 | | |
35 | 75 | | |
36 | | - | |
37 | 76 | | |
38 | | - | |
39 | | - | |
| 77 | + | |
| 78 | + | |
40 | 79 | | |
41 | 80 | | |
42 | 81 | | |
| |||
54 | 93 | | |
55 | 94 | | |
56 | 95 | | |
57 | | - | |
58 | 96 | | |
59 | 97 | | |
60 | 98 | | |
61 | 99 | | |
62 | 100 | | |
63 | 101 | | |
64 | | - | |
65 | | - | |
| 102 | + | |
66 | 103 | | |
67 | | - | |
68 | | - | |
69 | | - | |
70 | | - | |
71 | | - | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
72 | 121 | | |
73 | 122 | | |
74 | | - | |
75 | | - | |
76 | 123 | | |
77 | 124 | | |
78 | 125 | | |
79 | 126 | | |
80 | 127 | | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
81 | 131 | | |
82 | 132 | | |
83 | 133 | | |
84 | 134 | | |
85 | 135 | | |
86 | 136 | | |
87 | | - | |
| 137 | + | |
88 | 138 | | |
89 | 139 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
119 | 119 | | |
120 | 120 | | |
121 | 121 | | |
| 122 | + | |
| 123 | + | |
122 | 124 | | |
123 | 125 | | |
124 | 126 | | |
| |||
128 | 130 | | |
129 | 131 | | |
130 | 132 | | |
| 133 | + | |
131 | 134 | | |
132 | 135 | | |
133 | 136 | | |
| |||
147 | 150 | | |
148 | 151 | | |
149 | 152 | | |
| 153 | + | |
| 154 | + | |
| 155 | + | |
| 156 | + | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
150 | 168 | | |
151 | 169 | | |
152 | 170 | | |
| |||
164 | 182 | | |
165 | 183 | | |
166 | 184 | | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
167 | 188 | | |
168 | 189 | | |
169 | 190 | | |
| |||
201 | 222 | | |
202 | 223 | | |
203 | 224 | | |
204 | | - | |
| 225 | + | |
205 | 226 | | |
206 | 227 | | |
| 228 | + | |
| 229 | + | |
207 | 230 | | |
208 | 231 | | |
209 | 232 | | |
| |||
214 | 237 | | |
215 | 238 | | |
216 | 239 | | |
| 240 | + | |
217 | 241 | | |
218 | 242 | | |
219 | 243 | | |
| |||
233 | 257 | | |
234 | 258 | | |
235 | 259 | | |
| 260 | + | |
| 261 | + | |
| 262 | + | |
| 263 | + | |
| 264 | + | |
| 265 | + | |
| 266 | + | |
| 267 | + | |
| 268 | + | |
| 269 | + | |
| 270 | + | |
| 271 | + | |
| 272 | + | |
| 273 | + | |
| 274 | + | |
236 | 275 | | |
237 | 276 | | |
238 | 277 | | |
| |||
250 | 289 | | |
251 | 290 | | |
252 | 291 | | |
| 292 | + | |
| 293 | + | |
| 294 | + | |
253 | 295 | | |
254 | 296 | | |
255 | 297 | | |
| |||
287 | 329 | | |
288 | 330 | | |
289 | 331 | | |
290 | | - | |
| 332 | + | |
291 | 333 | | |
292 | 334 | | |
| 335 | + | |
| 336 | + | |
293 | 337 | | |
294 | 338 | | |
295 | 339 | | |
| |||
300 | 344 | | |
301 | 345 | | |
302 | 346 | | |
| 347 | + | |
303 | 348 | | |
304 | 349 | | |
305 | 350 | | |
| |||
319 | 364 | | |
320 | 365 | | |
321 | 366 | | |
| 367 | + | |
| 368 | + | |
| 369 | + | |
| 370 | + | |
| 371 | + | |
| 372 | + | |
| 373 | + | |
| 374 | + | |
| 375 | + | |
| 376 | + | |
| 377 | + | |
| 378 | + | |
| 379 | + | |
| 380 | + | |
| 381 | + | |
322 | 382 | | |
323 | 383 | | |
324 | 384 | | |
| |||
336 | 396 | | |
337 | 397 | | |
338 | 398 | | |
| 399 | + | |
| 400 | + | |
| 401 | + | |
339 | 402 | | |
340 | 403 | | |
341 | 404 | | |
| |||
373 | 436 | | |
374 | 437 | | |
375 | 438 | | |
376 | | - | |
| 439 | + | |
377 | 440 | | |
378 | 441 | | |
379 | 442 | | |
| |||
720 | 783 | | |
721 | 784 | | |
722 | 785 | | |
| 786 | + | |
| 787 | + | |
723 | 788 | | |
724 | 789 | | |
725 | 790 | | |
| |||
729 | 794 | | |
730 | 795 | | |
731 | 796 | | |
| 797 | + | |
732 | 798 | | |
733 | 799 | | |
734 | 800 | | |
| |||
748 | 814 | | |
749 | 815 | | |
750 | 816 | | |
| 817 | + | |
| 818 | + | |
| 819 | + | |
| 820 | + | |
| 821 | + | |
| 822 | + | |
| 823 | + | |
| 824 | + | |
| 825 | + | |
| 826 | + | |
| 827 | + | |
| 828 | + | |
| 829 | + | |
| 830 | + | |
| 831 | + | |
751 | 832 | | |
752 | 833 | | |
753 | 834 | | |
| |||
765 | 846 | | |
766 | 847 | | |
767 | 848 | | |
| 849 | + | |
| 850 | + | |
| 851 | + | |
768 | 852 | | |
769 | 853 | | |
770 | 854 | | |
| |||
802 | 886 | | |
803 | 887 | | |
804 | 888 | | |
805 | | - | |
| 889 | + | |
806 | 890 | | |
807 | 891 | | |
| 892 | + | |
| 893 | + | |
808 | 894 | | |
809 | 895 | | |
810 | 896 | | |
| |||
814 | 900 | | |
815 | 901 | | |
816 | 902 | | |
| 903 | + | |
817 | 904 | | |
818 | 905 | | |
819 | 906 | | |
| |||
833 | 920 | | |
834 | 921 | | |
835 | 922 | | |
| 923 | + | |
| 924 | + | |
| 925 | + | |
| 926 | + | |
| 927 | + | |
| 928 | + | |
| 929 | + | |
| 930 | + | |
| 931 | + | |
| 932 | + | |
| 933 | + | |
| 934 | + | |
| 935 | + | |
| 936 | + | |
| 937 | + | |
836 | 938 | | |
837 | 939 | | |
838 | 940 | | |
| |||
850 | 952 | | |
851 | 953 | | |
852 | 954 | | |
| 955 | + | |
| 956 | + | |
| 957 | + | |
853 | 958 | | |
854 | 959 | | |
855 | 960 | | |
| |||
887 | 992 | | |
888 | 993 | | |
889 | 994 | | |
890 | | - | |
| 995 | + | |
891 | 996 | | |
892 | 997 | | |
893 | 998 | | |
| |||
0 commit comments