You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2022/08/16 09:33:20 UTC
[iotdb] branch IOTDB-3771 updated (1002eb38ab -> 66996203c0)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-3771
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1002eb38ab edit according to review
add db0b6fd14f [IOTDB-4073] Add SessionTimeWindowAccessStrategy in UDF (#6928)
add 2cae6a8c15 [IOTDB-4055] Add remove-confignode.bat (#6996)
add 371b3b4d3c [IOTDB-3938] Fix SeriesSlotExecutor initialization logic for insertion performance (#7007)
add b04489ebdd [IOTDB-3843] Refine the using of setting read-only (#6968)
add ea4bbfe7cb Bump kafka_2.10 from 0.8.2.0 to 0.8.2.2 (#6881)
add 66996203c0 merge with master
No new revisions were added by this update.
Summary of changes:
...{start-confignode.bat => remove-confignode.bat} | 8 +-
.../statemachine/PartitionRegionStateMachine.java | 6 +
.../org/apache/iotdb/consensus/IStateMachine.java | 4 +
.../multileader/MultiLeaderConsensus.java | 12 +-
.../multileader/MultiLeaderServerImpl.java | 4 +
.../service/MultiLeaderRPCServiceProcessor.java | 8 +
.../ratis/ApplicationStateMachineProxy.java | 34 ++-
.../consensus/standalone/StandAloneConsensus.java | 12 +-
.../consensus/standalone/StandAloneServerImpl.java | 5 +
docs/UserGuide/Cluster/Cluster-Setup.md | 5 +
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 5 +
example/pom.xml | 2 +-
.../db/query/udf/example/ExampleUDFConstant.java | 2 +
.../iotdb/db/query/udf/example/WindowStartEnd.java | 16 +-
.../iotdb/itbase/constant/UDFTestConstant.java | 2 +
.../db/it/udf/IoTDBUDFSessionWindowQueryIT.java | 283 +++++++++++++++++++++
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 7 +-
.../apache/iotdb/commons/partition/Partition.java | 2 +
.../executor/SeriesPartitionExecutor.java | 37 ++-
.../schemaregion/rocksdb/RSchemaRegion.java | 3 +-
.../resources/conf/iotdb-datanode.properties | 4 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 44 +++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../org/apache/iotdb/db/conf/SystemStatus.java | 24 +-
.../db/conf/directories/DirectoryManager.java | 60 ++---
.../iotdb/db/conf/directories/FolderManager.java | 18 +-
.../directories/strategy/DirectoryStrategy.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 6 +
.../statemachine/SchemaRegionStateMachine.java | 6 +
.../compaction/task/CompactionRecoverTask.java | 3 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 46 ++--
.../db/engine/storagegroup/TsFileProcessor.java | 42 ++-
.../db/metadata/idtable/IDTableHashmapImpl.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 25 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 3 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 3 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +-
.../plan/expression/binary/BinaryExpression.java | 1 +
.../plan/expression/leaf/TimeSeriesOperand.java | 1 +
.../visitor/IntermediateLayerVisitor.java | 1 +
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 8 +
.../intermediate/ConstantIntermediateLayer.java | 8 +
.../dag/intermediate/IntermediateLayer.java | 8 +
.../MultiInputColumnIntermediateLayer.java | 119 +++++++++
...InputColumnMultiReferenceIntermediateLayer.java | 117 +++++++++
...nputColumnSingleReferenceIntermediateLayer.java | 117 +++++++++
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 5 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +-
.../allocation/AbstractNodeAllocationStrategy.java | 8 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 15 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 9 +-
.../engine/modification/DeletionFileNodeTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 +-
.../api/customizer/strategy/AccessStrategy.java | 5 +-
.../strategy/SessionTimeWindowAccessStrategy.java | 95 +++++++
58 files changed, 1129 insertions(+), 166 deletions(-)
copy confignode/src/assembly/resources/sbin/{start-confignode.bat => remove-confignode.bat} (96%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFSessionWindowQueryIT.java
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureYieldException.java => server/src/main/java/org/apache/iotdb/db/conf/SystemStatus.java (70%)
create mode 100644 udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/strategy/SessionTimeWindowAccessStrategy.java