Commit 6d5fb38
committed
Merge branch 'master' into feat/Statistical-Aggregate-Functions
# Conflicts:
# integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTableAggregationIT.java
# iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AccumulatorFactory.java
# iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/TableBuiltinAggregationFunction.java
# iotdb-protocol/thrift-commons/src/main/thrift/common.thrift2,165 files changed
Lines changed: 107221 additions & 27338 deletions
File tree
- .github/workflows
- docker
- src/main
- DockerCompose
- example
- client-cpp-example
- src
- jdbc
- mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server
- mqtt/src/main/java/org/apache/iotdb/mqtt
- odbc
- rest-java-example/src/main/java/org/apache/iotdb
- session/src/main/java/org/apache/iotdb
- 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
- 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
- extract
- scalar
- view
- old
- orderby
- query
- recent
- rest/it
- schema
- session
- session/it
- subscription/it
- cluster
- dual
- tablemodel
- treemodel
- local
- tablemodel
- triple
- treemodel/regression
- pullconsumer/autocommit
- tools/it
- util
- resources
- iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/argument
- iotdb-client
- client-cpp
- src
- main
- test
- cpp
- client-py
- 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
- test/java/org/apache/iotdb/rpc
- session/src
- main/java/org/apache/iotdb/session
- pool
- rpccompress
- util
- test/java/org/apache/iotdb/session
- pool
- iotdb-core
- ainode
- ainode/core
- inference
- rpc
- iotdb
- ainode
- core
- inference
- batcher
- dispatcher
- pool_scheduler
- request_scheduler
- strategy
- ingress
- manager
- model
- sundial
- timerxl
- 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
- model
- partition
- write
- auth
- cq
- database
- pipe/payload
- response
- auth
- model
- pipe/task
- exception
- manager
- consensus
- load
- balancer
- region
- router/leader
- cache
- detector
- service
- node
- partition
- pipe
- agent
- plugin
- receiver
- runtime
- task
- coordinator
- runtime
- heartbeat
- task
- event
- metric
- overview
- sink
- source
- receiver
- protocol
- visitor
- sink
- client
- payload
- protocol
- source
- schema
- persistence
- auth
- executor
- partition
- pipe
- schema
- procedure
- impl
- cq
- model
- node
- pipe
- runtime
- task
- util
- schema
- table
- view
- sync
- scheduler
- state
- schema
- store
- service
- thrift
- test/java/org/apache/iotdb/confignode
- consensus
- request
- response/pipe
- manager/pipe
- agent
- sink
- source
- persistence
- schema
- pipe/annotation
- procedure/impl
- pipe/receiver
- schema
- sync
- 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
- consensus
- statemachine
- dataregion
- schemaregion
- exception/metadata
- pipe
- agent
- plugin
- dataregion
- schemaregion
- runtime
- task
- builder
- connection
- execution
- stage
- subtask/sink
- connector/payload/evolvable/batch
- consensus
- deletion
- persist
- recover
- metric
- event
- common
- deletion
- heartbeat
- schema
- statement
- tablet
- parser
- terminate
- tsfile
- parser
- query
- scan
- table
- util
- realtime
- extractor
- dataregion/realtime
- mqtt
- metric
- overview
- processor
- schema
- sink
- source
- processor
- aggregate
- downsampling
- schemachange
- twostage/exchange
- payload
- receiver
- sender
- receiver
- protocol
- airgap
- legacy
- loader
- pipeconsensus
- thrift
- transform
- converter
- statement
- visitor
- resource
- log
- memory
- tsfile
- sink
- client
- payload
- evolvable
- batch
- request
- legacy
- protocol
- airgap
- legacy
- opcda
- opcua
- pipeconsensus
- handler
- payload
- builder
- request
- thrift
- async
- handler
- sync
- websocket
- writeback
- util
- builder
- cacher
- sorter
- source
- dataregion
- historical
- realtime
- assigner
- disruptor
- epoch
- listener
- matcher
- schemaregion
- protocol
- client
- ainode
- mqtt
- rest
- filter
- handler
- table/v1
- handler
- impl
- v1
- handler
- impl
- v2
- handler
- impl
- session
- thrift
- handler
- impl
- queryengine
- common
- header
- schematree
- node
- execution
- aggregation
- driver
- exchange
- sink
- source
- executor
- fragment
- memory
- operator
- process
- ai
- function
- join/merge
- rowpattern/expression
- schema
- source
- source
- relational
- aggregation
- approximate
- grouped
- array
- window
- relational
- schedule/queue
- metric
- plan
- analyze
- cache
- partition
- schema
- dualkeycache
- impl
- load
- schema
- execution
- config
- executor
- metadata
- ai
- region
- template
- sys
- pipe
- memory
- expression
- multi
- other
- unary
- visitor
- cartesian
- optimization
- parser
- planner
- distribution
- plan
- node
- load
- metadata/write
- view
- pipe
- process
- 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
- type
- scheduler
- load
- statement
- component
- crud
- internal
- metadata
- model
- pipe
- region
- subscription
- template
- view
- sys
- udf
- statistics
- transformation
- dag
- column
- binary
- factory
- strategies
- multi
- ternary
- utils
- unary/scalar
- factory
- inteface
- util
- input
- intermediate
- udf
- util
- datastructure
- tv
- schemaengine
- rescon
- schemaregion
- attribute/update
- impl
- logfile/visitor
- mtree
- impl
- mem
- snapshot
- pbtree
- loader
- traverser/counter
- read/resp/reader/impl
- tag
- utils
- write/req
- impl
- table
- template
- service
- metrics
- storageengine
- buffer
- dataregion
- compaction
- execute
- exception
- performer
- constant
- impl
- recover
- task
- subtask
- utils
- executor
- batch
- utils
- fast
- readchunk
- writer
- io
- repair
- schedule
- selector
- estimator
- impl
- utils
- settle
- tool
- flush
- memtable
- modification
- read
- control
- filescan
- impl
- model
- reader
- chunk
- common
- snapshot
- tsfile
- generator
- utils
- wal
- io
- recover/file
- load
- active
- config
- converter
- disk
- limiter
- memory
- splitter
- util
- rescon
- disk
- strategy
- memory
- subscription
- agent
- broker
- event
- batch
- cache
- response
- metric
- resource/log
- task
- execution
- stage
- subtask
- tools
- schema
- settle
- utils
- trigger
- executor
- service
- utils
- constant
- datastructure
- test/java/org/apache/iotdb/db
- auth
- authorizer
- entity
- role
- user
- conf
- metadata
- cache
- path
- schemaRegion
- pipe
- agent
- plugin
- task
- connector
- consensus
- event
- common/tsfile/parser/util
- pattern
- plugin/annotation
- sink
- source
- queryengine
- execution
- exchange
- operator
- process
- rowpattern
- window/function
- schema
- plan
- analyze
- load
- parser
- planner
- distribution
- node
- process
- write
- relational
- analyzer
- planner/assertions
- sql/parser
- transformation/dag
- column
- binary/hmac
- ternary
- unary/scalar
- IntegerEncoding
- base64Encoding
- hashing
- hexEncoding
- util
- security/encrypt
- storageengine
- buffer
- dataregion
- compaction
- cross
- inner
- sizetiered
- recover
- tablemodel
- utils
- flush
- memtable
- read
- control
- reader/chunk
- snapshot
- tsfile
- wal
- compression
- io
- rescon/disk
- tools
- utils
- datastructure
- metrics
- interface
- src
- main/java/org/apache/iotdb/metrics
- config
- reporter
- iotdb
- prometheus
- type
- test/java/org/apache/iotdb/metrics/config
- node-commons
- src
- assembly/resources/conf
- main/java/org/apache/iotdb/commons
- audit
- auth
- authorizer
- entity
- role
- user
- utils
- client
- async
- sync
- concurrent
- conf
- consensus/iotv2/container
- enums
- exception
- pipe
- executable
- external/collections4
- bidimap
- collection
- iterators
- keyvalue
- map
- file
- partition
- path
- fa/dfa
- graph
- transition
- pipe
- agent
- plugin
- builtin
- extractor/mqtt
- sink
- donothing
- iotdb
- airgap
- consensus
- thrift
- opcda
- opcua
- websocket
- writeback
- source
- donothing
- iotdb
- constructor
- service
- task
- meta
- progress
- interval
- subtask
- config
- constant
- plugin/env
- datastructure
- interval
- options
- pattern
- queue/listening
- visibility
- event
- receiver
- resource/log
- sink
- client
- compressor
- limiter
- payload
- airgap
- pipeconsensus
- request
- response
- thrift
- common
- request
- response
- protocol
- source
- schema
- column
- table
- ttl
- view/viewExpression
- leaf
- unary
- service
- metric/enums
- subscription/meta
- consumer
- topic
- udf
- builtin
- relational
- service
- utils
- test/java/org/apache/iotdb/commons
- exception/pipe
- pipe
- datastructure
- plugin
- annotation
- builtin
- task
- utils
- relational-grammar/src/main/antlr4/org/apache/iotdb/db/relational/grammar/sql
- iotdb-protocol
- openapi/src/main/openapi3
- thrift-ainode/src/main/thrift
- thrift-confignode/src/main/thrift
- thrift-consensus/src/main/thrift
- thrift-datanode/src/main/thrift
- library-udf
- src/main/java/org/apache/iotdb/library/match
- scripts
- conf
- windows
- sbin
- windows
- tools
- ops
- schema
- tsfile
- wal
- windows
- ops
- schema
- tsfile
- wal
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 | |
|---|---|---|---|
| |||
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 | | |
| |||
63 | 65 | | |
64 | 66 | | |
65 | 67 | | |
66 | | - | |
67 | | - | |
68 | | - | |
69 | | - | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
70 | 72 | | |
71 | 73 | | |
72 | 74 | | |
| |||
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 | 43 | | |
| |||
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
| 51 | + | |
52 | 52 | | |
53 | | - | |
54 | | - | |
| 53 | + | |
| 54 | + | |
55 | 55 | | |
56 | 56 | | |
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
60 | 60 | | |
61 | 61 | | |
62 | | - | |
| 62 | + | |
63 | 63 | | |
| 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 | | |
| |||
| 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