Commit dbf5583
File tree
246 files changed
+2949
-563
lines changed- example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server
- integration-test
- src
- main/java/org/apache/iotdb
- itbase/runtime
- it/env/cluster
- node
- test/java/org/apache/iotdb
- confignode/it
- db/it
- it/framework
- pipe/it/dual/treemodel/manual
- relational/it/query
- old/orderBy
- view/old/orderby
- session/it
- util
- iotdb-client
- cli
- src/main/java/org/apache/iotdb
- cli
- utils
- tool
- data
- schema
- tsfile
- subscription
- jdbc
- src/main/java/org/apache/iotdb/jdbc
- iotdb-core
- confignode
- src
- main/java/org/apache/iotdb/confignode
- conf
- consensus/request/write/cq
- manager/load/cache/detector
- persistence/schema
- procedure/impl/cq
- test/java/org/apache/iotdb/confignode/persistence
- schema
- consensus
- src/main/java/org/apache/iotdb/consensus
- iot
- client
- logdispatcher
- pipe/consensuspipe
- ratis
- datanode
- src
- main
- codegen/templates
- java/org/apache/iotdb/db
- conf
- pipe
- agent/runtime
- receiver
- protocol
- legacy
- pipeconsensus
- transform/converter
- visitor
- resource
- sink
- protocol
- legacy
- thrift
- async/handler
- sync
- websocket
- util/builder
- protocol
- mqtt
- rest
- table/v1/handler
- v1
- handler
- impl
- v2
- handler
- impl
- session
- queryengine
- execution
- exchange
- sink
- source
- memory
- operator/process
- join/merge
- plan
- analyze/load
- execution
- config/executor
- memory
- expression
- other
- unary
- visitor/cartesian
- optimization
- parser
- planner
- distribution
- plan
- node
- process
- source
- parameter
- relational
- planner/distribute
- sql/ast
- scheduler
- statement/component
- transformation/dag/column
- schemaengine
- schemaregion/tag
- template
- service
- storageengine
- dataregion
- compaction
- execute
- exception
- recover
- selector/estimator
- flush
- snapshot
- wal/recover/file
- load
- active
- config
- converter
- rescon/disk
- trigger/service
- utils
- test/java/org/apache/iotdb/db
- auth
- role
- user
- metadata/schemaRegion
- pipe/source
- queryengine/execution/exchange
- security/encrypt
- storageengine
- buffer
- dataregion
- compaction
- inner
- recover
- utils
- flush
- memtable
- tsfile
- wal/compression
- tools
- utils
- datastructure
- node-commons
- src/main/java/org/apache/iotdb/commons
- auth
- role
- user
- client
- async
- executable
- external/collections4
- bidimap
- collection
- iterators
- keyvalue
- map
- file
- path
- fa/dfa
- graph
- transition
- pipe
- agent/plugin/service
- datastructure/pattern
- receiver
- schema/view/viewExpression
- leaf
- unary
- udf/service
- utils
- library-udf
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
246 files changed
+2949
-563
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
317 | 317 | | |
318 | 318 | | |
319 | 319 | | |
320 | | - | |
| 320 | + | |
| 321 | + | |
| 322 | + | |
| 323 | + | |
| 324 | + | |
| 325 | + | |
| 326 | + | |
| 327 | + | |
| 328 | + | |
| 329 | + | |
| 330 | + | |
| 331 | + | |
| 332 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
216 | 216 | | |
217 | 217 | | |
218 | 218 | | |
219 | | - | |
220 | | - | |
221 | | - | |
222 | | - | |
223 | 219 | | |
224 | 220 | | |
225 | 221 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
43 | 43 | | |
44 | 44 | | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
| |||
67 | 67 | | |
68 | 68 | | |
69 | 69 | | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
70 | 74 | | |
71 | 75 | | |
72 | 76 | | |
73 | 77 | | |
74 | 78 | | |
| 79 | + | |
| 80 | + | |
75 | 81 | | |
76 | 82 | | |
77 | 83 | | |
| |||
92 | 98 | | |
93 | 99 | | |
94 | 100 | | |
95 | | - | |
96 | 101 | | |
97 | 102 | | |
98 | 103 | | |
| 104 | + | |
99 | 105 | | |
100 | 106 | | |
101 | 107 | | |
| |||
108 | 114 | | |
109 | 115 | | |
110 | 116 | | |
| 117 | + | |
111 | 118 | | |
112 | 119 | | |
113 | 120 | | |
| |||
162 | 169 | | |
163 | 170 | | |
164 | 171 | | |
165 | | - | |
| 172 | + | |
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
62 | 62 | | |
63 | 63 | | |
64 | 64 | | |
65 | | - | |
| 65 | + | |
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
157 | 157 | | |
158 | 158 | | |
159 | 159 | | |
160 | | - | |
161 | | - | |
162 | | - | |
163 | | - | |
164 | 160 | | |
165 | 161 | | |
166 | 162 | | |
167 | 163 | | |
168 | | - | |
169 | | - | |
170 | | - | |
171 | | - | |
172 | 164 | | |
173 | 165 | | |
174 | 166 | | |
| |||
188 | 180 | | |
189 | 181 | | |
190 | 182 | | |
191 | | - | |
192 | | - | |
193 | | - | |
194 | | - | |
195 | 183 | | |
196 | 184 | | |
197 | 185 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
19 | 19 | | |
20 | 20 | | |
21 | 21 | | |
22 | | - | |
| 22 | + | |
23 | 23 | | |
24 | 24 | | |
25 | 25 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
| 25 | + | |
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
| |||
Lines changed: 3 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | | - | |
32 | | - | |
33 | | - | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
| |||
0 commit comments