This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/SupportFill
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c4f7e0f6773 Add support for helper column
add 43d07b52a25 Support table model insert redirection (#13550)
add 879715174f2 PipePlugin: Add pipe consensus related plugins to
blackList (#13642)
add 8753985882d Pipe: Fix the problem of missing precision when converting
String type to Int32 and int64 types (#13643)
add 6742d4bdf82 Add full outer time join for table model
add bf0666e096c Support global-aggregation in TableModel
add d6598d634e4 Feature/move SBOM check into separate profile (#13649)
add a56ed3ef901 resolve conflicts
No new revisions were added by this update.
Summary of changes:
.github/workflows/dependency-check.yml | 2 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 166 +++++++++++++
.../pool/IoTDBInsertTableSessionPoolIT.java | 245 +++++++++++++++++++
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 76 ++++++
.../org/apache/iotdb/isession/IPooledSession.java | 1 +
.../java/org/apache/iotdb/isession/ISession.java | 9 +
.../org/apache/iotdb/rpc/RedirectException.java | 15 ++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 17 ++
.../java/org/apache/iotdb/session/Session.java | 216 +++++++++++++++-
.../apache/iotdb/session/SessionConnection.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 22 +-
.../apache/iotdb/session/pool/SessionWrapper.java | 8 +-
.../iotdb/session/SessionCacheLeaderTest.java | 271 +++++++++++++++++++--
.../iotdb/session/SessionConnectionTest.java | 2 +-
.../transform/converter/ValueConverter.java | 12 +-
.../fragment/FragmentInstanceContext.java | 5 +-
...erator.java => TableFullOuterJoinOperator.java} | 268 ++++++++++++++------
...inOperator.java => TableInnerJoinOperator.java} | 116 +++++----
.../relational/aggregation/Accumulator.java} | 21 +-
.../aggregation/AccumulatorFactory.java | 114 ++++-----
.../aggregation/AggregationOperator.java | 158 ++++++++++++
.../source/relational/aggregation/Aggregator.java | 81 ++++++
.../relational/aggregation/AvgAccumulator.java | 191 +++++++++++++++
.../relational/aggregation/CountAccumulator.java | 80 ++++++
.../db/queryengine/plan/analyze/Analysis.java | 1 +
.../db/queryengine/plan/analyze/IAnalysis.java | 2 +
.../plan/planner/TableOperatorGenerator.java | 101 +++++++-
.../planner/plan/node/write/InsertTabletNode.java | 10 +-
.../node/write/RelationalInsertTabletNode.java | 43 ++++
.../plan/relational/analyzer/Analysis.java | 5 +
.../relational/analyzer/StatementAnalyzer.java | 5 +-
.../metadata/TableBuiltinAggregationFunction.java | 11 +
.../plan/relational/planner/RelationPlanner.java | 17 +-
.../plan/relational/planner/TableModelPlanner.java | 40 ++-
.../PushLimitOffsetIntoTableScan.java | 6 +-
.../optimizations/PushPredicateIntoTableScan.java | 9 +-
.../column/multi/CoalesceColumnTransformer.java | 1 +
.../plan/relational/analyzer/JoinTest.java | 10 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 5 +-
pom.xml | 179 +++++++-------
40 files changed, 2175 insertions(+), 370 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/session/pool/IoTDBInsertTableSessionPoolIT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{InnerJoinOperator.java
=> TableFullOuterJoinOperator.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{InnerJoinOperator.java
=> TableInnerJoinOperator.java} (87%)
copy
iotdb-core/datanode/src/{test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/PlanTestSymbol.java
=>
main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/Accumulator.java}
(54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/{
=> operator/source/relational}/aggregation/AccumulatorFactory.java (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AggregationOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/Aggregator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AvgAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/CountAccumulator.java
