Commit 085ac9d
committed
Merge remote-tracking branch 'upstream/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.java2,216 files changed
Lines changed: 136574 additions & 31218 deletions
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
- pipe-count-point-processor
- pipe-opc-ua-sink
- rest-java-example
- 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
- utils
- test
- java/org/apache/iotdb
- ainode
- it
- utils
- confignode/it/partition
- db/it
- aligned
- audit
- auth
- iotconsensusv2
- batch
- stream
- last
- mqtt
- query
- schema
- selectinto
- udf
- utils
- pipe/it
- dual
- tablemodel
- manual
- basic
- enhanced
- treemodel
- auto
- basic
- enhanced
- manual
- single
- triple
- relational/it
- db/it
- insertquery
- mqtt
- query
- old
- builtinfunction/scalar
- recent
- copyto
- informationschema
- scalar
- subquery
- view/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/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
- type
- iotdb-client
- client-cpp
- src
- main
- test
- catch2
- cpp
- client-py
- iotdb
- tsfile/utils
- utils
- tests/integration
- cli
- src/main/java/org/apache/iotdb
- cli
- tool
- data
- tsfile
- subscription
- isession
- src/main/java/org/apache/iotdb/isession
- 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
- subscription/payload
- util
- test/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
- iotdb/ainode/core
- device
- backend
- inference
- batcher
- dispatcher
- pipeline
- pool_scheduler
- strategy
- 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/rpc
- sync
- conf
- consensus
- request
- read/exernalservice
- write
- externalservice
- model
- pipe/payload
- table
- template
- response
- externalservice
- model
- table
- template
- manager
- externalservice
- node
- pipe
- agent
- plugin
- task
- coordinator
- runtime
- heartbeat
- task
- receiver
- protocol
- visitor
- resource
- sink/protocol
- source
- schema
- subscription
- persistence
- auth
- executor
- pipe
- quota
- schema
- mnode
- impl
- info
- procedure
- env
- impl
- model
- node
- partition
- pipe
- plugin
- task
- region
- schema
- table
- state
- schema
- store
- service
- thrift
- test
- java/org/apache/iotdb/confignode
- consensus/request
- manager/pipe/source
- persistence
- pipe
- schema
- procedure
- env
- impl
- partition
- pipe/receiver
- schema
- resources/oldsnapshot
- consensus
- src/main/java/org/apache/iotdb/consensus
- config
- pipe
- consensuspipe
- metric
- service
- datanode
- src
- assembly/resources/conf
- main/java/org/apache/iotdb/db
- audit
- auth
- conf
- rest
- consensus
- statemachine
- dataregion
- schemaregion
- exception
- ainode
- 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
- tablet
- parser
- tsfile
- parser
- query
- scan
- table
- realtime
- metric
- overview
- receiver
- schema
- sink
- source
- processor
- aggregate
- iotconsensusv2
- twostage/exchange/sender
- receiver
- protocol
- airgap
- iotconsensusv2
- legacy
- loader
- thrift
- transform/converter
- visitor
- resource
- memory
- tsfile
- sink
- client
- payload/evolvable
- batch
- request
- protocol
- airgap
- iotconsensusv2
- handler
- payload
- builder
- request
- legacy
- opcda
- opcua
- client
- server
- thrift
- async
- handler
- sync
- websocket
- writeback
- util
- builder
- sorter
- source
- dataregion
- historical
- realtime
- assigner
- listener
- matcher
- schemaregion
- protocol
- client
- ainode
- an
- rest/filter
- session
- thrift
- handler
- impl
- queryengine
- common
- header
- schematree
- visitor
- execution
- aggregation
- exchange
- 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
- grouped
- array
- hash
- window
- relational
- schedule
- task
- plan
- analyze
- cache
- partition
- schema/dualkeycache/impl
- load
- schema
- execution
- config
- executor
- metadata
- ai
- externalservice
- relational
- template
- session
- sys/pipe
- memory
- expression/visitor/predicate
- optimization
- parser
- planner
- distribution
- memory
- plan
- node
- load
- metadata
- read
- write
- pipe
- process
- AI
- last
- source
- write
- parameter
- model
- relational
- analyzer
- predicate
- function
- tvf
- 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
- pipe
- template
- sys
- udf
- statistics
- transformation
- dag
- column
- udf
- unary/scalar
- input
- transformer/unary
- scalar
- util
- datastructure
- row
- tv
- schemaengine
- rescon
- schemaregion
- attribute/update
- impl
- mtree
- impl
- mem
- mnode
- basic
- impl
- info
- iterator
- pbtree
- mnode/iterator
- traverser
- read
- req
- impl
- resp
- info/impl
- reader/impl
- utils
- view/visitor
- table
- template
- service
- externalservice
- metrics
- file
- memory
- storageengine
- dataregion
- compaction
- execute
- performer/impl
- task
- subtask
- utils
- executor
- batch
- fast
- element
- reader
- readchunk
- writer
- repair
- schedule
- selector
- impl
- utils
- flush
- memtable
- modification
- read/reader/chunk
- metadata
- snapshot
- tsfile
- timeindex
- utils
- tableDiskUsageIndex
- object
- tsfile
- wal
- allocation
- buffer
- node
- recover/file
- load
- active
- converter
- memory
- splitter
- rescon
- disk
- memory
- subscription
- agent
- broker
- receiver
- task
- stage
- subtask
- tools
- utils
- cte
- datastructure
- sort
- windowing/window
- test
- java/org/apache/iotdb/db
- auth
- authorizer
- role
- consensus/statemachine/schemaregion
- metadata
- cache
- schemaRegion
- pipe
- consensus
- event
- pattern
- receiver
- resource
- sink
- util
- source
- protocol/rest
- queryengine
- common/schematree
- execution
- exchange
- fragment
- operator
- process
- join
- window
- function
- schema
- sink
- source/relational
- expression/predicate
- plan
- analyze
- parser
- planner
- distribution
- logical
- node
- load
- source
- statement/sys/pipe
- relational
- analyzer
- metadata/fetcher/cache
- planner
- assertions
- informationschema
- predicate
- sql
- ast
- statement
- transformation/dag/column/unary/scalar
- service
- storageengine
- dataregion
- compaction
- alterDataType
- inner
- repair
- settle
- tablemodel
- utils
- memtable
- read/reader/chunk
- snapshot
- utils
- wal
- allocation
- recover/file
- subscription/receiver
- tools
- utils
- datastructure
- resources
- metrics
- core
- interface
- src/main/java/org/apache/iotdb/metrics/metricsets
- disk
- jvm
- net
- system
- node-commons
- src
- assembly/resources/conf
- main/java/org/apache/iotdb/commons
- audit
- auth
- authorizer
- entity
- binaryallocator/arena
- client
- async
- property
- sync
- concurrent
- conf
- consensus/iotv2/container
- enums
- exception
- pipe
- executable
- externalservice
- file
- model
- partition
- path
- pipe
- agent
- plugin
- builtin
- processor/iotconsensusv2
- sink/iotdb/consensus
- service
- runtime
- task
- connection
- execution
- progress/interval
- subtask
- config
- constant
- datastructure/pattern
- event
- receiver
- sink
- client
- limiter
- payload/iotconsensusv2
- request
- response
- protocol
- source
- schema
- column
- filter
- impl
- multichildren
- singlechild
- values
- table
- column
- template
- tree
- ttl
- service
- metric/enums
- subscription/config
- udf
- builtin
- utils
- utils
- test/java/org/apache/iotdb/commons
- binaryallocator
- pipe
- datastructure
- task
- schema/table
- utils
- relational-grammar
- src/main/antlr4/org/apache/iotdb/db/relational/grammar/sql
- iotdb-protocol
- thrift-ainode
- src/main/thrift
- thrift-commons
- src/main/thrift
- thrift-confignode
- src/main/thrift
- thrift-consensus
- src/main/thrift
- thrift-datanode
- src/main/thrift
- library-udf
- scripts
- sbin
- windows
- tools/ops
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 | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
42 | | - | |
| 42 | + | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
| 51 | + | |
52 | 52 | | |
53 | 53 | | |
54 | 54 | | |
| |||
82 | 82 | | |
83 | 83 | | |
84 | 84 | | |
85 | | - | |
| 85 | + | |
86 | 86 | | |
87 | 87 | | |
88 | 88 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
43 | | - | |
44 | | - | |
45 | | - | |
46 | | - | |
| 43 | + | |
47 | 44 | | |
48 | 45 | | |
49 | 46 | | |
| |||
56 | 53 | | |
57 | 54 | | |
58 | 55 | | |
59 | | - | |
| 56 | + | |
60 | 57 | | |
61 | 58 | | |
62 | 59 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
| |||
62 | 62 | | |
63 | 63 | | |
64 | 64 | | |
65 | | - | |
| 65 | + | |
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | | - | |
| 46 | + | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
| |||
0 commit comments