You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/01/09 11:31:21 UTC
[iotdb] branch pipeline updated (ada2dde43d -> 66bba5fb90)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch pipeline
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ada2dde43d fix conflicts with master
add 48002969a5 update javadoc (#8789)
add cea3c5ce21 [IOTDB-4982] Replace recursion algorithm in Traverser with iteration algorithm (#8765)
add d55ca83df7 [IoTDB-5374] Implement MLNode basic service framework (#8772)
add 5f914f014e [IOTDB-3662] upgrade audit log (#8791)
add 362f56cdf5 Change version to 1.1.0-SNAPSHOT (#8796)
add 5de6adf3de [IOTDB-5386] Implement SchemaSource Component to Simplify Schema Operators (#8792)
add c1dde58682 Jenkins disable integration (#8787)
add 66bba5fb90 fix conflicts with master
No new revisions were added by this update.
Summary of changes:
Jenkinsfile | 42 +-
antlr/pom.xml | 2 +-
cli/pom.xml | 2 +-
client-cpp/pom.xml | 2 +-
client-py/pom.xml | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 14 -
consensus/pom.xml | 2 +-
distribution/pom.xml | 2 +-
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 2 +-
grafana-plugin/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/pom.xml | 5 +-
integration/pom.xml | 2 +-
isession/pom.xml | 2 +-
jdbc/pom.xml | 2 +-
library-udf/pom.xml | 2 +-
metrics/dropwizard-metrics/pom.xml | 2 +-
metrics/interface/pom.xml | 2 +-
metrics/micrometer-metrics/pom.xml | 4 +-
metrics/pom.xml | 2 +-
mlnode/.flake8 | 33 ++
mlnode/.gitignore | 5 +
external-pipe-api/pom.xml => mlnode/README.md | 42 +-
{client-py => mlnode}/iotdb/__init__.py | 0
.../iotdb => mlnode/iotdb/mlnode}/__init__.py | 0
mlnode/iotdb/mlnode/client.py | 51 +++
mlnode/iotdb/mlnode/config.py | 107 +++++
mlnode/iotdb/mlnode/constant.py | 21 +
mlnode/iotdb/mlnode/exception.py | 26 ++
mlnode/iotdb/mlnode/handler.py | 53 +++
mlnode/iotdb/mlnode/log.py | 34 ++
mlnode/iotdb/mlnode/script.py | 36 ++
mlnode/iotdb/mlnode/service.py | 60 +++
mlnode/iotdb/mlnode/util.py | 48 +++
mlnode/pom.xml | 2 +-
mlnode/pyproject.toml | 54 +++
mlnode/resources/conf/iotdb-mlnode.toml | 50 +++
mlnode/resources/conf/logging_config.ini | 40 ++
node-commons/pom.xml | 2 +-
.../iotdb/commons/client/IClientManager.java | 8 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 92 ++++-
.../iotdb/commons/schema/tree/ITreeNode.java | 4 +-
openapi/pom.xml | 2 +-
pom.xml | 3 +-
rewrite-tsfile-tool/pom.xml | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 2 +-
.../schemaregion/rocksdb/mnode/RMNode.java | 5 +
schema-engine-tag/pom.xml | 2 +-
server/pom.xml | 2 +-
.../apache/iotdb/db/audit/AuditLogOperation.java | 14 +-
.../org/apache/iotdb/db/audit/AuditLogStorage.java | 12 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 236 +++++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 48 +++
.../idtable/entry/InsertMeasurementMNode.java | 5 +
.../db/metadata/mnode/AboveDatabaseMNode.java | 20 +-
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 7 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 5 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 5 +
.../mnode/iterator/AbstractTraverserIterator.java | 115 ++++++
.../iterator/CachedTraverserIterator.java} | 27 +-
.../iterator/MemoryTraverserIterator.java} | 22 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 229 +++++------
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 46 ++-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 315 +++++++-------
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 366 ++++++++++-------
.../db/metadata/mtree/store/CachedMTreeStore.java | 18 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 6 +
.../db/metadata/mtree/store/MemMTreeStore.java | 19 +
.../db/metadata/mtree/traverser/Traverser.java | 452 ++-------------------
.../traverser/TraverserWithLimitOffsetWrapper.java | 122 ++++++
.../DatabaseTraverser.java} | 49 ++-
.../EntityTraverser.java} | 60 ++-
.../mtree/traverser/basic/MNodeTraverser.java | 103 +++++
.../MeasurementTraverser.java} | 41 +-
.../traverser/collector/CollectorTraverser.java | 96 -----
...eGroupCollector.java => DatabaseCollector.java} | 38 +-
.../mtree/traverser/collector/EntityCollector.java | 48 +--
.../traverser/collector/MNodeAboveSGCollector.java | 25 +-
.../mtree/traverser/collector/MNodeCollector.java | 58 +--
.../traverser/collector/MeasurementCollector.java | 58 +--
.../metadata/mtree/traverser/counter/Counter.java | 8 +-
...orageGroupCounter.java => DatabaseCounter.java} | 31 +-
...StorageGroupCounter.java => EntityCounter.java} | 29 +-
.../mtree/traverser/updater/EntityUpdater.java | 65 +++
.../traverser/updater/MeasurementUpdater.java | 66 +++
.../metadata/mtree/traverser/updater/Updater.java | 11 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 107 ++---
.../schemaregion/SchemaRegionSchemaFileImpl.java | 43 +-
.../visitor/SchemaTreeDeviceVisitor.java | 2 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 3 +-
.../schema/CountGroupByLevelMergeOperator.java | 7 +
...tor.java => CountGroupByLevelScanOperator.java} | 76 ++--
.../operator/schema/CountMergeOperator.java | 7 +
.../operator/schema/DevicesCountOperator.java | 65 ---
.../operator/schema/SchemaCountOperator.java | 30 +-
.../operator/schema/SchemaQueryScanOperator.java | 32 +-
.../operator/schema/TimeSeriesCountOperator.java | 85 ----
.../DeviceSchemaSource.java} | 66 +--
.../operator/schema/source/ISchemaSource.java | 50 +++
.../operator/schema/source/NodeSchemaSource.java | 81 ++++
.../PathsUsingTemplateSource.java} | 55 +--
.../schema/source/SchemaSourceFactory.java | 78 ++++
.../TimeSeriesSchemaSource.java} | 76 ++--
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 107 ++---
.../iotdb/db/query/control/SessionManager.java | 45 +-
.../query/control/clientsession/ClientSession.java | 2 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 117 +++++-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 25 --
.../schemaRegion/SchemaRegionBasicTest.java | 13 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 62 +++
.../mpp/execution/operator/OperatorMemoryTest.java | 183 +--------
.../schema/CountGroupByLevelMergeOperatorTest.java | 61 +--
.../operator/schema/SchemaCountOperatorTest.java | 205 ++--------
.../schema/SchemaQueryScanOperatorTest.java | 64 ++-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 7 +-
service-rpc/pom.xml | 2 +-
session/pom.xml | 2 +-
site/pom.xml | 2 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-confignode/pom.xml | 2 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift-mlnode/src/main/thrift/mlnode.thrift | 10 +-
thrift/pom.xml | 2 +-
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 2 +-
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
161 files changed, 3294 insertions(+), 2320 deletions(-)
create mode 100644 mlnode/.flake8
copy external-pipe-api/pom.xml => mlnode/README.md (54%)
copy {client-py => mlnode}/iotdb/__init__.py (100%)
copy {client-py/iotdb => mlnode/iotdb/mlnode}/__init__.py (100%)
create mode 100644 mlnode/iotdb/mlnode/client.py
create mode 100644 mlnode/iotdb/mlnode/config.py
create mode 100644 mlnode/iotdb/mlnode/constant.py
create mode 100644 mlnode/iotdb/mlnode/exception.py
create mode 100644 mlnode/iotdb/mlnode/handler.py
create mode 100644 mlnode/iotdb/mlnode/log.py
create mode 100644 mlnode/iotdb/mlnode/script.py
create mode 100644 mlnode/iotdb/mlnode/service.py
create mode 100644 mlnode/iotdb/mlnode/util.py
create mode 100644 mlnode/pyproject.toml
create mode 100644 mlnode/resources/conf/iotdb-mlnode.toml
create mode 100644 mlnode/resources/conf/logging_config.ini
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => server/src/main/java/org/apache/iotdb/db/audit/AuditLogOperation.java (83%)
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => server/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java (84%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => server/src/main/java/org/apache/iotdb/db/metadata/mnode/AboveDatabaseMNode.java (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/AbstractTraverserIterator.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/CounterTraverser.java => mnode/iterator/CachedTraverserIterator.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/CounterTraverser.java => mnode/iterator/MemoryTraverserIterator.java} (64%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/TraverserWithLimitOffsetWrapper.java
copy server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{collector/StorageGroupCollector.java => basic/DatabaseTraverser.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{collector/EntityCollector.java => basic/EntityTraverser.java} (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/basic/MNodeTraverser.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{counter/CounterTraverser.java => basic/MeasurementTraverser.java} (52%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/CollectorTraverser.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{StorageGroupCollector.java => DatabaseCollector.java} (58%)
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/Counter.java (80%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{StorageGroupCounter.java => DatabaseCounter.java} (62%)
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{StorageGroupCounter.java => EntityCounter.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/EntityUpdater.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/MeasurementUpdater.java
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/Updater.java (61%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{LevelTimeSeriesCountOperator.java => CountGroupByLevelScanOperator.java} (64%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesCountOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java => source/DeviceSchemaSource.java} (58%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/ISchemaSource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/NodeSchemaSource.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{PathsUsingTemplateScanOperator.java => source/PathsUsingTemplateSource.java} (65%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/SchemaSourceFactory.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{TimeSeriesSchemaScanOperator.java => source/TimeSeriesSchemaSource.java} (69%)