This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch integrate-chronos2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 4cf5430e907 Update AINodeConcurrentForecastIT.java
discard 920df32b8af runnable version
discard 28760304d32 submit 4 test
add 44409934426 Avoid CN OOM by Pulling User/Roles to DN When Cache
Misses. (#16888)
add b71401a4227 fix showQueries (#16855)
add 2710cb3db65 Add state predicate push down for system table
current_queries (#16904)
add c77bb57cb2e Optimized the error message & prevented stack printing of
information_schema selection when the cluster is closing (#16905)
add 1bf79ca4713 Fix folderManager NPE issue in WALNode when starting iotdb
in a disk-full state (#16869)
add 79e10af5fd1 Fixed the warn log of internal/MQTT session's close
session method (#16909)
add c663477e82a Fix queryCostStatWindow process of current queries (#16912)
add 02e3517c536 Fix the issue of SQL conversion in export tool (#16913)
add 664f485ddf8 Add datanode_id column for queries_costs_histogram table
and add memory usage metric for Coordinator (#16918)
add 76d02a58f00 Modify pipeline and automap (#16923)
add b6c13d7e3e8 [AINode] Forecast table function version2 (#16922)
add 05364f0aa68 submit 4 test
add 52751f5344d runnable version
add 7eef5f6e549 Update AINodeConcurrentForecastIT.java
add 046d3d7c3bb revert updates
add 6a3b8a4aa8d Update model_info.py
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (4cf5430e907)
\
N -- N -- N refs/heads/integrate-chronos2 (6a3b8a4aa8d)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../ainode/it/AINodeConcurrentForecastIT.java | 2 +-
.../apache/iotdb/ainode/it/AINodeForecastIT.java | 100 +++++-
.../informationschema/IoTDBCurrentQueriesIT.java | 66 +++-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 6 +
.../org/apache/iotdb/tool/data/ExportData.java | 5 +-
.../ainode/core/inference/inference_request.py | 19 +-
.../core/inference/inference_request_pool.py | 4 +
.../core/inference/pipeline/basic_pipeline.py | 43 ++-
.../iotdb/ainode/core/manager/inference_manager.py | 48 ++-
.../ainode/iotdb/ainode/core/model/model_info.py | 24 +-
.../ainode/iotdb/ainode/core/model/model_loader.py | 19 +-
.../ainode/core/model/sktime/pipeline_sktime.py | 45 ++-
.../ainode/core/model/sundial/modeling_sundial.py | 13 +-
.../ainode/core/model/sundial/pipeline_sundial.py | 30 +-
.../ainode/core/model/timer_xl/modeling_timer.py | 6 +-
.../ainode/core/model/timer_xl/pipeline_timer.py | 29 +-
iotdb-core/ainode/iotdb/ainode/core/util/serde.py | 24 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 59 ++--
.../sink/protocol/writeback/WriteBackSink.java | 4 +-
.../db/protocol/session/InternalClientSession.java | 4 +-
.../db/protocol/session/MqttClientSession.java | 3 +-
.../iotdb/db/protocol/session/SessionManager.java | 9 +-
.../InformationSchemaContentSupplierFactory.java | 31 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 39 ++-
.../db/queryengine/plan/parser/ASTVisitor.java | 22 +-
.../plan/planner/TableOperatorGenerator.java | 26 +-
.../planner/distribution/ExchangeNodeAdder.java | 6 +-
.../planner/plan/node/source/ShowQueriesNode.java | 2 +-
.../function/TableBuiltinTableFunction.java | 6 +-
.../function/tvf/ClassifyTableFunction.java | 383 +++++++++++++++++++++
.../function/tvf/ForecastTableFunction.java | 263 ++++----------
.../distribute/TableDistributedPlanGenerator.java | 8 +-
.../optimizations/PushPredicateIntoTableScan.java | 100 ++++++
.../relational/utils/ResultColumnAppender.java | 145 ++++++++
.../plan/statement/component/OrderByComponent.java | 6 +
.../db/queryengine/plan/udf/UDTFForecast.java | 2 +
.../FragmentInstanceStatisticsDrawer.java | 2 +-
.../metrics/memory/QueryEngineMemoryMetrics.java | 12 +-
.../allocation/AbstractNodeAllocationStrategy.java | 21 +-
.../plan/parser/StatementGeneratorTest.java | 33 ++
...NodeSerdeTest.java => SourceNodeSerdeTest.java} | 20 +-
.../relational/analyzer/TableFunctionTest.java | 4 +-
.../planner/assertions/ColumnReference.java | 10 +-
.../planner/assertions/PlanMatchPattern.java | 20 +-
.../informationschema/CurrentQueriesTest.java | 79 ++++-
.../wal/allocation/FirstCreateStrategyTest.java | 81 +++++
.../commons/schema/table/InformationSchema.java | 2 +
47 files changed, 1456 insertions(+), 429 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/tvf/ClassifyTableFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/utils/ResultColumnAppender.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/{LastQueryScanNodeSerdeTest.java
=> SourceNodeSerdeTest.java} (76%)
