Commit 39d950d
File tree
- .github/workflows
- .mvn/wrapper
- code-coverage
- distribution
- src/assembly
- docker
- src/main
- DockerCompose
- example
- 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
- odbc
- 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
- java/org/apache/iotdb/mqtt
- resources/META-INF/services
- test/java/org/apache/iotdb/mqtt
- rest-openapi
- src/main/openapi3
- rest
- src/main/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
- env
- utils
- test
- java/org/apache/iotdb
- ainode
- it
- utils
- auth/it
- confignode/it
- cluster
- database
- load
- partition
- procedure
- regionmigration
- pass
- commit
- daily
- datanodecrash
- iotv1
- iotv2
- batch
- stream
- iotv1
- iotv2
- batch
- stream
- utils
- db/it
- aggregation
- alignbydevice
- aligned
- audit
- auth
- iotconsensusv2
- batch
- stream
- last
- mqtt
- orderBy
- path
- query
- schema
- regionscan
- selectinto
- udf
- utils
- it/framework
- pipe/it
- dual
- tablemodel
- manual
- basic
- enhanced
- treemodel
- auto
- basic
- enhanced
- manual
- single
- triple
- relational/it
- db/it
- insertquery
- mqtt
- query
- old
- builtinfunction/scalar
- orderBy
- query
- recent
- copyto
- extract
- informationschema
- scalar
- subquery
- view
- old
- orderby
- 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
- util
- resources
- ainode-example
- iotdb-api
- external-api
- external-service-api
- src/main/java/org/apache/iotdb/externalservice/api
- pipe-api
- src
- main/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
- udf-api
- src/main/java/org/apache/iotdb/udf/api
- relational
- access
- table/argument
- type
- iotdb-client
- client-cpp
- src
- main
- test
- catch2
- cpp
- client-py
- iotdb
- tsfile/utils
- utils
- tests/integration
- sqlalchemy
- cli
- src/main/java/org/apache/iotdb
- cli
- utils
- tool
- backup
- common
- data
- schema
- tsfile
- subscription
- isession
- src/main/java/org/apache/iotdb/isession
- pool
- jdbc
- src
- main/java/org/apache/iotdb/jdbc
- test/java/org/apache/iotdb/jdbc
- service-rpc
- src
- main/java/org/apache/iotdb/rpc
- stmt
- test/java/org/apache/iotdb/rpc
- stmt
- session
- src
- main/java/org/apache/iotdb/session
- pool
- rpccompress
- subscription/payload
- util
- test
- java/org/apache/iotdb/session
- pool
- resources
- subscription
- src/main/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
- ainode/core
- inference
- strategy
- manager
- model
- sundial
- timerxl
- rpc
- util
- iotdb
- ainode
- core
- device
- backend
- inference
- batcher
- dispatcher
- pipeline
- pool_scheduler
- request_scheduler
- ingress
- manager
- model
- chronos2
- moirai2
- common
- module
- position
- transform
- 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
- confignode
- src
- main/java/org/apache/iotdb/confignode
- audit
- client
- async
- handlers
- audit
- heartbeat
- rpc
- sync
- conf
- consensus
- request
- read
- database
- exernalservice
- model
- partition
- write
- auth
- cq
- database
- externalservice
- model
- pipe/payload
- table
- template
- response
- auth
- externalservice
- model
- pipe/task
- table
- template
- exception
- manager
- consensus
- externalservice
- load
- balancer
- region
- router/leader
- cache
- detector
- service
- node
- partition
- pipe
- agent
- plugin
- receiver
- runtime
- task
- connector/protocol
- coordinator
- runtime
- heartbeat
- task
- event
- extractor
- metric
- overview
- sink
- source
- receiver
- protocol
- visitor
- resource
- sink
- client
- payload
- protocol
- source
- schema
- subscription
- persistence
- auth
- executor
- partition
- pipe
- quota
- schema
- mnode
- impl
- info
- procedure
- env
- impl
- cq
- model
- node
- partition
- pipe
- plugin
- runtime
- task
- util
- region
- schema
- table
- view
- sync
- scheduler
- state
- schema
- store
- service
- thrift
- test
- java/org/apache/iotdb/confignode
- consensus
- request
- response/pipe
- manager/pipe
- agent
- connector
- extractor
- sink
- source
- persistence
- pipe
- schema
- pipe/annotation
- procedure
- env
- impl
- partition
- pipe/receiver
- schema
- sync
- resources/oldsnapshot
- consensus
- src
- main/java/org/apache/iotdb/consensus
- common/request
- config
- exception
- iot
- client
- logdispatcher
- service
- pipe
- consensuspipe
- metric
- service
- ratis
- utils
- test/java/org/apache/iotdb/consensus/iot/logdispatcher
- datanode
- src
- assembly/resources/conf
- main
- codegen/templates
- java/org/apache/iotdb/db
- audit
- auth
- conf
- rest
- consensus
- statemachine
- dataregion
- schemaregion
- exception
- ainode
- metadata
- runtime
- partition
- pipe
- agent
- plugin
- dataregion
- schemaregion
- receiver
- runtime
- task
- builder
- connection
- execution
- stage
- subtask
- connector
- processor
- sink
- connector
- client
- payload/evolvable
- batch
- request
- protocol
- airgap
- legacy
- opcda
- opcua
- pipeconsensus
- handler
- payload
- builder
- request
- thrift
- async
- handler
- sync
- websocket
- writeback
- util/sorter
- consensus
- deletion
- persist
- recover
- metric
- event
- common
- deletion
- heartbeat
- row
- schema
- statement
- tablet
- parser
- terminate
- tsfile
- parser
- query
- scan
- table
- util
- realtime
- extractor
- dataregion
- historical
- realtime
- assigner
- epoch
- matcher
- mqtt
- schemaregion
- metric
- overview
- processor
- receiver
- schema
- sink
- source
- processor
- aggregate
- downsampling
- iotconsensusv2
- pipeconsensus
- schemachange
- twostage/exchange
- payload
- receiver
- sender
- 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
- thrift
- async
- handler
- sync
- websocket
- writeback
- util
- builder
- cacher
- sorter
- source
- dataregion
- historical
- realtime
- assigner
- disruptor
- epoch
- listener
- matcher
- schemaregion
- protocol
- client
- an
- rest
- filter
- table/v1
- handler
- impl
- v1
- handler
- impl
- v2
- handler
- impl
- session
- thrift
- handler
- impl
- queryengine
- common
- header
- schematree
- node
- visitor
- execution
- aggregation
- driver
- exchange
- sink
- source
- executor
- fragment
- memory
- operator
- process
- ai
- copyto
- tsfile
- function
- partition
- join/merge
- last
- rowpattern
- expression
- window
- function/value
- partition
- utils
- schema
- source
- sink
- source
- relational
- aggregation
- approximate
- grouped
- array
- hash
- window
- relational
- schedule
- queue
- task
- metric
- plan
- analyze
- cache
- partition
- schema
- dualkeycache
- impl
- load
- schema
- execution
- config
- executor
- metadata
- ai
- externalservice
- region
- relational
- template
- session
- sys
- pipe
- memory
- expression
- multi
- other
- unary
- visitor
- cartesian
- predicate
- optimization
- parser
- planner
- distribution
- memory
- plan
- node
- load
- metadata
- read
- write
- view
- pipe
- process
- AI
- last
- source
- write
- parameter
- model
- relational
- analyzer
- predicate
- function
- tvf
- match
- model
- metadata
- cache
- fetcher
- cache
- planner
- distribute
- ir
- iterative/rule
- node
- optimizations
- security
- sql
- ast
- parser
- rewrite
- util
- type
- utils
- scheduler
- load
- statement
- component
- crud
- internal
- metadata
- externalservice
- model
- pipe
- region
- subscription
- template
- view
- sys
- udf
- statistics
- transformation
- dag
- column
- binary
- factory
- strategies
- multi
- ternary
- utils
- udf
- unary/scalar
- factory
- inteface
- util
- input
- intermediate
- transformer/unary
- scalar
- udf
- util
- datastructure
- row
- tv
- schemaengine
- rescon
- schemaregion
- attribute/update
- impl
- logfile/visitor
- mtree
- impl
- mem
- mnode
- basic
- impl
- info
- iterator
- snapshot
- pbtree
- mnode/iterator
- loader
- traverser
- counter
- read
- req
- impl
- resp
- info/impl
- reader/impl
- tag
- utils
- view/visitor
- write/req
- impl
- table
- template
- service
- externalservice
- metrics
- file
- memory
- storageengine
- buffer
- dataregion
- compaction
- execute
- exception
- performer
- constant
- impl
- recover
- task
- subtask
- utils
- executor
- batch
- utils
- fast
- element
- reader
- readchunk
- writer
- io
- repair
- schedule
- selector
- estimator
- impl
- utils
- settle
- tool
- flush
- memtable
- modification
- read
- control
- filescan
- impl
- model
- reader
- chunk
- metadata
- common
- snapshot
- tsfile
- generator
- timeindex
- utils
- tableDiskUsageIndex
- object
- tsfile
- wal
- allocation
- buffer
- io
- node
- recover/file
- load
- active
- config
- converter
- disk
- limiter
- memory
- splitter
- util
- rescon
- disk
- strategy
- memory
- subscription
- agent
- broker
- event
- batch
- cache
- response
- metric
- receiver
- resource/log
- task
- execution
- stage
- subtask
- tools
- schema
- settle
- utils
- trigger
- executor
- service
- utils
- constant
- cte
- datastructure
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 | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| 23 | + | |
| 24 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
7 | | - | |
8 | | - | |
| 7 | + | |
| 8 | + | |
9 | 9 | | |
10 | | - | |
11 | | - | |
| 10 | + | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
16 | | - | |
| 15 | + | |
| 16 | + | |
17 | 17 | | |
18 | | - | |
19 | | - | |
| 18 | + | |
| 19 | + | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
| |||
35 | 35 | | |
36 | 36 | | |
37 | 37 | | |
38 | | - | |
| 38 | + | |
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
42 | | - | |
| 42 | + | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
| 48 | + | |
| 49 | + | |
48 | 50 | | |
49 | | - | |
| 51 | + | |
50 | 52 | | |
51 | 53 | | |
52 | 54 | | |
| |||
63 | 65 | | |
64 | 66 | | |
65 | 67 | | |
66 | | - | |
67 | | - | |
68 | | - | |
69 | | - | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
70 | 72 | | |
71 | 73 | | |
72 | 74 | | |
| |||
80 | 82 | | |
81 | 83 | | |
82 | 84 | | |
83 | | - | |
| 85 | + | |
84 | 86 | | |
85 | 87 | | |
86 | 88 | | |
87 | 89 | | |
88 | | - | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
37 | | - | |
| 37 | + | |
38 | 38 | | |
39 | 39 | | |
40 | | - | |
| 40 | + | |
41 | 41 | | |
42 | 42 | | |
43 | | - | |
44 | | - | |
45 | | - | |
46 | | - | |
| 43 | + | |
47 | 44 | | |
48 | 45 | | |
49 | 46 | | |
50 | 47 | | |
51 | | - | |
| 48 | + | |
52 | 49 | | |
53 | | - | |
54 | | - | |
| 50 | + | |
| 51 | + | |
55 | 52 | | |
56 | 53 | | |
57 | 54 | | |
58 | 55 | | |
59 | | - | |
| 56 | + | |
60 | 57 | | |
61 | 58 | | |
62 | | - | |
| 59 | + | |
63 | 60 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
7 | | - | |
8 | | - | |
| 7 | + | |
| 8 | + | |
9 | 9 | | |
10 | | - | |
11 | | - | |
| 10 | + | |
| 11 | + | |
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
16 | | - | |
17 | | - | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
18 | 18 | | |
19 | | - | |
20 | | - | |
| 19 | + | |
| 20 | + | |
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
| |||
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
| 39 | + | |
40 | 40 | | |
41 | | - | |
42 | | - | |
| 41 | + | |
| 42 | + | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | | - | |
| 48 | + | |
49 | 49 | | |
| 50 | + | |
| 51 | + | |
50 | 52 | | |
51 | 53 | | |
52 | 54 | | |
| |||
60 | 62 | | |
61 | 63 | | |
62 | 64 | | |
63 | | - | |
| 65 | + | |
64 | 66 | | |
65 | 67 | | |
66 | 68 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
9 | | - | |
10 | | - | |
| 9 | + | |
| 10 | + | |
11 | 11 | | |
12 | | - | |
13 | | - | |
| 12 | + | |
| 13 | + | |
14 | 14 | | |
15 | 15 | | |
16 | 16 | | |
17 | | - | |
18 | | - | |
19 | | - | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
20 | 20 | | |
21 | | - | |
22 | | - | |
| 21 | + | |
| 22 | + | |
23 | 23 | | |
24 | 24 | | |
25 | 25 | | |
| |||
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
41 | | - | |
| 41 | + | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | | - | |
| 48 | + | |
49 | 49 | | |
| 50 | + | |
| 51 | + | |
50 | 52 | | |
51 | 53 | | |
52 | 54 | | |
| |||
0 commit comments