This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch object_ttl
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 48d49017bae update compaction read operation rate
add a572c1c9da1 [AINode] Prevent auto_map gets covered and add model_list
for AINodeConcurrentForecastIT (#16928)
add ca26dd36ce4 Pipe: Optimized the key reducer logic & OPC UA sink reuse
logic & value + quality in OPC UA tree client-server model (#16921)
add fd7a3f2c237 Update pyproject.toml (#16931)
add b67f57c2f27 Correct the getObjectPathFromBinary method in
ObjectTypeUtils (#16934)
add 029fbed3d40 fixed the bug that caused incompatible behavior when
comparing int64 or int32 column with double literals in query filter
conditions. (#16917)
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 c5b4507a101 Merge branch 'master' into object_ttl
No new revisions were added by this update.
Summary of changes:
LICENSE | 10 +
.../ainode/it/AINodeConcurrentForecastIT.java | 10 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 4 +-
.../it/query/IoTDBPredicateConversionTreeIT.java | 293 +++++++
.../recent/IoTDBPredicateConversionTableIT.java | 379 +++++++++
.../iotdb/relational/it/schema/IoTDBTableIT.java | 1 +
iotdb-api/pipe-api/pom.xml | 5 +
.../{RowCollector.java => DataCollector.java} | 17 +-
.../{RowCollector.java => TabletCollector.java} | 14 +-
.../api/customizer/parameter/PipeParameters.java | 31 +-
.../event/dml/insertion/TabletInsertionEvent.java | 11 +
.../customizer/parameter/PipeParametersTest.java | 19 +-
.../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 | 14 +
.../iotdb/ainode/core/model/model_storage.py | 9 +-
iotdb-core/ainode/pyproject.toml | 2 +-
.../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 +
.../pipe/sink/protocol/opcua/OpcUaNameSpace.java | 128 +--
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 71 +-
.../fragment/FragmentInstanceContext.java | 30 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 134 ++-
.../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 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 116 ++-
.../fetcher/TableDeviceSchemaValidator.java | 4 +
.../db/storageengine/dataregion/IObjectPath.java | 10 +-
.../load/memory/LoadTsFileMemoryManager.java | 19 +-
.../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 11 +-
.../pipe/event/TsFileInsertionEventParserTest.java | 34 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 101 +++
.../fragment/FragmentInstanceExecutionTest.java | 149 +++-
.../predicate/TreePredicateConversionTest.java | 572 +++++++++++++
.../plan/function/RecordObjectTypeTest.java | 6 +-
.../predicate/TablePredicateConversionTest.java | 506 ++++++++++++
.../unary/scalar/ObjectTypeFunctionTest.java | 6 +-
.../object/ObjectTypeCompactionTest.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 6 +
.../pipe/config/constant/PipeSinkConstant.java | 12 +
.../apache/iotdb/commons/schema/table/TsTable.java | 3 +
pom.xml | 2 +-
66 files changed, 6777 insertions(+), 243 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBPredicateConversionTreeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBPredicateConversionTableIT.java
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/service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java
=>
iotdb-api/pipe-api/src/test/java/org/apache/iotdb/pipe/api/customizer/parameter/PipeParametersTest.java
(57%)
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
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/expression/predicate/TreePredicateConversionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/predicate/TablePredicateConversionTest.java
