This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch tableTraining
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard f071a7529f2 support training in table model
add f706aacccaf Fix multiple bugs in window function
add 2b60aa5eecc [AINode] Unify .safetensors model loading through
huggingface interfaces (#15756)
add cb24cb7f936 update go:package_prefix to v2 (#15795)
add 0505dfb9cb2 Fix the returning state of NotifyRegionMigrationProcedure
(#15797)
add fb2684a8249 Export TsFile: manual commit instead of auto commit
(#15798)
add f207084f03c Pipe: Add upper bound check for Pipe request decompression
buffer (#15699)
add e1bd11b9d6e Fixed the issue with deeply nested Or Filter in
NonAlignedTreeViewScan
add 89649f1d67d Prevent the contents of log_datanode_sample_query.log and
log_explain_ananlyze.log from being output to log_datanode_all.log (#15800)
add 817150d29d9 Avoid NPE in fetch FI Info
add 71ef45d9e1c Add new parameter [ignoreNull] and supported data type for
VARIATION Function (#15628)
add 5cb388190ae Parallel disptach read fragment instance
add 5054ff6fbbc Throw CANNOT_FETCH_FI_STATE(722) instead of 301/305 while
DN restarting
add 037ef649ad6 Fix sort elimination when table join self in TableModel
add b3435b79f42 Pause remove DN tests
add 35f2ff6fc5a Clarify the exception message when using a closed session
(#15811)
add 7a7dbecb0b7 Avoid 301/305 code about fetch schema failed
add 71563ed372f Make timecol be case-insensitive
add 7afc2b65b41 [AINode] Update the class fields of IoTDB dataset (#15799)
add 1dc47d48e07 Rest Service add FastLastQuery method
add 88abd3e3097 Enhance it for cluster-restart tests (#15794)
add b8fd08984cb IoTV2: Refactor replicate index so that it is shared at
the pipe task level & Add some log for delete local peer (#15815)
add 72a020b7692 support training in table model
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 (f071a7529f2)
\
N -- N -- N refs/heads/tableTraining (72a020b7692)
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:
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 77 +++++-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 266 +++++++++++++++++----
.../it/env/cluster/node/AbstractNodeWrapper.java | 9 +-
.../IoTDBRemoveDataNodeNormalIT.java | 4 +-
.../IoTDBRemoveUnknownDataNodeIT.java | 4 +-
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 127 +++++++++-
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 170 ++++++++++++-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 175 ++++++++++++++
.../org/apache/iotdb/session/it/SessionIT.java | 133 +++++++++--
...eption.java => UDFColumnNotFoundException.java} | 7 +-
...xception.java => UDFTypeMismatchException.java} | 7 +-
.../table/argument/ScalarArgumentChecker.java | 8 +
.../java/org/apache/iotdb/udf/api/type/Type.java | 10 +
.../org/apache/iotdb/tool/common/Constants.java | 3 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
.../java/org/apache/iotdb/isession/ISession.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 244 ++++++++++---------
.../apache/iotdb/session/SessionConnection.java | 6 +-
.../subscription/AbstractSubscriptionSession.java | 2 +-
.../subscription/SubscriptionSessionWrapper.java | 4 +-
.../base/AbstractSubscriptionProvider.java | 30 +--
iotdb-core/ainode/ainode/core/config.py | 10 +-
iotdb-core/ainode/ainode/core/constant.py | 22 +-
iotdb-core/ainode/ainode/core/ingress/dataset.py | 18 +-
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 69 +++---
.../ainode/core/manager/inference_manager.py | 22 +-
.../ainode/ainode/core/manager/model_manager.py | 48 +++-
.../ainode/core/model/built_in_model_factory.py | 72 ++++--
.../ainode/ainode/core/model/model_storage.py | 97 +++++---
.../ainode/core/model/sundial/modeling_sundial.py | 22 +-
.../ainode/core/model/timerxl/modeling_timer.py | 22 +-
.../region/NotifyRegionMigrationProcedure.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 12 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 3 +-
.../pipe/consensuspipe/ConsensusPipeConnector.java | 4 +-
.../consensuspipe/ReplicateProgressManager.java | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 12 +-
.../assembly/resources/conf/logback-datanode.xml | 6 +-
.../connector/PipeConnectorSubtaskManager.java | 4 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 13 +-
.../ReplicateProgressDataNodeManager.java | 21 +-
.../event/realtime/PipeRealtimeEventFactory.java | 50 +---
...oricalDataRegionTsFileAndDeletionExtractor.java | 8 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 18 +-
.../listener/PipeInsertionDataNodeListener.java | 11 +-
.../protocol/rest/v2/handler/FastLastHandler.java | 71 ++++++
.../rest/v2/handler/RequestValidationHandler.java | 8 +
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 230 +++++++++++++-----
.../queryengine/execution/QueryStateMachine.java | 30 +--
.../fragment/FragmentInstanceContext.java | 2 +-
.../process/window/TableWindowOperator.java | 1 -
.../window/partition/PartitionExecutor.java | 6 +-
.../process/window/partition/frame/RangeFrame.java | 6 +-
.../process/window/utils/RowComparator.java | 20 ++
.../iotdb/db/queryengine/plan/Coordinator.java | 13 +
.../queryengine/plan/execution/QueryExecution.java | 8 +-
.../plan/planner/TableOperatorGenerator.java | 37 ++-
.../queryengine/plan/planner/TreeModelPlanner.java | 2 +-
.../SimpleFragmentParallelPlanner.java | 1 +
.../plan/planner/plan/PlanFragment.java | 9 +
.../relational/analyzer/ExpressionAnalyzer.java | 5 +-
.../relational/analyzer/StatementAnalyzer.java | 18 +-
.../function/tvf/ForecastTableFunction.java | 22 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 18 +-
.../plan/relational/planner/QueryPlanner.java | 42 ++--
.../plan/relational/planner/TableModelPlanner.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 18 +-
.../distribute/TableModelQueryFragmentPlanner.java | 1 +
.../planner/optimizations/SortElimination.java | 60 ++++-
.../optimizations/TransformSortToStreamSort.java | 33 ++-
.../plan/relational/sql/ast/Identifier.java | 6 +-
.../plan/scheduler/ClusterScheduler.java | 11 +-
.../scheduler/FixedRateFragInsStateTracker.java | 34 +--
.../scheduler/FragmentInstanceDispatcherImpl.java | 101 +++++++-
.../plan/scheduler/IFragInstanceDispatcher.java | 6 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 13 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 39 +++
.../plan/relational/analyzer/AnalyzerTest.java | 5 +-
.../plan/relational/analyzer/JoinTest.java | 52 ++++
.../relational/analyzer/TableFunctionTest.java | 82 +++++++
.../apache/iotdb/commons/client/ClientManager.java | 5 +
.../iotdb/commons/client/IClientManager.java | 3 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 28 +++
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 18 ++
...meException.java => PortOccupiedException.java} | 14 +-
.../task/progress/PipeEventCommitManager.java | 11 -
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../thrift/request/PipeTransferCompressedReq.java | 15 ++
.../relational/tvf/VariationTableFunction.java | 196 ++++++++++++---
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 6 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 14 ++
.../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 25 ++
pom.xml | 2 +-
99 files changed, 2495 insertions(+), 739 deletions(-)
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/exception/{UDFException.java
=> UDFColumnNotFoundException.java} (82%)
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/exception/{UDFException.java
=> UDFTypeMismatchException.java} (83%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2/handler/FastLastHandler.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{IoTDBIORuntimeException.java
=> PortOccupiedException.java} (75%)
