This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch object_delet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b5a55494ac8 add some IT
add 340a860486f [AINode] Integrate Chronos2 as builtin forecasting model
(#16903)
add 16965de83a0 Implemented the "restrict_object_limit" for object
restriction (#16933)
add 2bdbd41eee8 Pipe: Implemented the processTabletWithCollect api with
tablet collector (#16930)
add ec7fbdaa60c Fix sync objectNode error log (#16939)
add 302864ae1ce Load: Add check for reset memory size to 0 in
LoadTsFileMemoryManager (#16940)
add 7722963223c fix: memory leak during tvlist owner transfer scenario
(#16932)
add 3824f30d86e Merge branch 'master' of github.com:apache/iotdb into
object_delet
add d10c274939b Fix error
No new revisions were added by this update.
Summary of changes:
LICENSE | 10 +
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 4 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 1 +
.../{RowCollector.java => DataCollector.java} | 17 +-
.../{RowCollector.java => TabletCollector.java} | 14 +-
.../event/dml/insertion/TabletInsertionEvent.java | 11 +
.../iotdb/ainode/core/model/chronos2}/__init__.py | 0
.../iotdb/ainode/core/model/chronos2/base.py | 300 +++++++
.../ainode/core/model/chronos2/chronos_bolt.py | 703 ++++++++++++++++
.../iotdb/ainode/core/model/chronos2/config.py | 138 ++++
.../iotdb/ainode/core/model/chronos2/dataset.py | 756 +++++++++++++++++
.../iotdb/ainode/core/model/chronos2/layers.py | 481 +++++++++++
.../iotdb/ainode/core/model/chronos2/model.py | 909 +++++++++++++++++++++
.../core/model/chronos2/pipeline_chronos2.py | 391 +++++++++
.../iotdb/ainode/core/model/chronos2/utils.py | 242 ++++++
.../ainode/iotdb/ainode/core/model/model_info.py | 12 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 -
.../confignode/conf/ConfigNodeDescriptor.java | 5 -
.../confignode/conf/SystemPropertiesUtils.java | 11 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 1 -
.../db/pipe/event/common/row/PipeRowCollector.java | 35 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 12 +
.../common/tablet/PipeRawTabletEventConverter.java | 72 ++
.../common/tablet/PipeRawTabletInsertionEvent.java | 7 +
.../event/common/tablet/PipeTabletCollector.java | 61 ++
.../tablet/parser/TabletInsertionEventParser.java | 4 +
.../TabletInsertionEventTablePatternParser.java | 14 +-
.../TabletInsertionEventTreePatternParser.java | 10 +
.../fragment/FragmentInstanceContext.java | 30 +-
.../plan/planner/LocalExecutionPlanner.java | 8 +
.../memory/FakedMemoryReservationManager.java | 11 +
.../planner/memory/MemoryReservationManager.java | 29 +
.../NotThreadSafeMemoryReservationManager.java | 23 +
.../memory/ThreadSafeMemoryReservationManager.java | 13 +
.../plan/planner/plan/node/write/ObjectNode.java | 8 +-
.../fetcher/TableDeviceSchemaValidator.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../db/storageengine/dataregion/IObjectPath.java | 10 +-
.../load/memory/LoadTsFileMemoryManager.java | 19 +-
.../db/storageengine/rescon/disk/TierManager.java | 3 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 34 +-
.../fragment/FragmentInstanceExecutionTest.java | 149 +++-
.../plan/function/RecordObjectTypeTest.java | 6 +-
.../unary/scalar/ObjectTypeFunctionTest.java | 6 +-
.../object/ObjectTypeCompactionTest.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 6 +
.../apache/iotdb/commons/schema/table/TsTable.java | 3 +
50 files changed, 4477 insertions(+), 147 deletions(-)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> DataCollector.java} (71%)
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/{RowCollector.java
=> TabletCollector.java} (78%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/chronos2}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/base.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/chronos_bolt.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/config.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/dataset.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/layers.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/model.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/chronos2/pipeline_chronos2.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/core/model/chronos2/utils.py
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletEventConverter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java
