[iotdb] branch virtual_partition_2_merge updated (4ffc4c7 -> a00d8a1)

[xu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xuekaifeng pushed a change to branch virtual_partition_2_merge
in repository https://gitbox.apache.org/repos/asf/iotdb.git.


    from 4ffc4c7  fix path bug
     add e4ddf81  [IOTDB-1098] Add interface `validate` for UDF (#2406)
     add e28208c  change udf and tracing ut root path to target (#2411)
     add 6d25ba5  refactor node management
     add d99432a  remove a done todo
     add 31c4d43  Merge branch 'master' into cluster_node_management
     add 44a6155  fix tests
     add 0255b85  fix test
     add e7b1421  fix no waiting after time_out
     add 6f3d021  Merge branch 'master' into cluster_node_management
     add 90cc875  fix import
     add 08400ad  Merge pull request #2359 from apache/cluster_node_management
     add a00d8a1  Merge branch 'master' of https://github.com/apache/iotdb into virtual_partition_2_merge

No new revisions were added by this update.

Summary of changes:
 .../cluster/client/async/AsyncClientPool.java      |  79 +++-----
 .../iotdb/cluster/client/sync/SyncClientPool.java  |  24 ++-
 .../iotdb/cluster/coordinator/Coordinator.java     |   2 +-
 .../apache/iotdb/cluster/log/LogDispatcher.java    |   4 +-
 .../cluster/log/applier/AsyncDataLogApplier.java   |   4 +-
 .../iotdb/cluster/log/catchup/CatchUpTask.java     |   2 +-
 .../iotdb/cluster/log/manage/RaftLogManager.java   |   2 +-
 .../cluster/query/manage/QueryCoordinator.java     | 115 +-----------
 .../iotdb/cluster/server/DataClusterServer.java    |   2 +-
 .../iotdb/cluster/server/MetaClusterServer.java    |  10 +
 .../handlers/caller/AppendNodeEntryHandler.java    |   6 +-
 .../server/handlers/caller/HeartbeatHandler.java   |   2 +-
 .../cluster/server/member/DataGroupMember.java     |  13 +-
 .../cluster/server/member/MetaGroupMember.java     |  45 ++++-
 .../iotdb/cluster/server/member/RaftMember.java    |  83 +++-----
 .../cluster/server/{ => monitor}/NodeReport.java   |   3 +-
 .../manage => server/monitor}/NodeStatus.java      |  41 +++-
 .../monitor/NodeStatusManager.java}                |  87 +++++----
 .../iotdb/cluster/server/{ => monitor}/Peer.java   |   2 +-
 .../iotdb/cluster/server/{ => monitor}/Timer.java  |   2 +-
 .../cluster/server/service/MetaAsyncService.java   |   6 +
 .../cluster/server/service/MetaSyncService.java    |   5 +
 .../cluster/utils/nodetool/ClusterMonitor.java     |   2 +-
 .../cluster/log/applier/DataLogApplierTest.java    |  10 +-
 .../iotdb/cluster/log/catchup/CatchUpTaskTest.java |   7 +-
 .../cluster/log/catchup/LogCatchUpTaskTest.java    |   6 +
 .../log/catchup/SnapshotCatchUpTaskTest.java       |   6 +
 .../cluster/log/snapshot/DataSnapshotTest.java     |   5 +
 .../cluster/log/snapshot/PullSnapshotTaskTest.java |   5 +
 .../apache/iotdb/cluster/query/BaseQueryTest.java  |   5 +-
 .../cluster/query/manage/QueryCoordinatorTest.java |  15 +-
 .../caller/AppendNodeEntryHandlerTest.java         |   2 +-
 .../server/heartbeat/DataHeartbeatThreadTest.java  |   5 +
 .../server/heartbeat/HeartbeatThreadTest.java      |   5 +
 .../server/heartbeat/MetaHeartbeatThreadTest.java  |   5 +
 .../cluster/server/member/DataGroupMemberTest.java |   5 +
 .../iotdb/cluster/server/member/MemberTest.java    |   9 +
 .../cluster/server/member/MetaGroupMemberTest.java |  14 +-
 .../Operation Manual/UDF User Defined Function.md  |  56 ++++--
 .../Operation Manual/UDF User Defined Function.md  |  58 ++++--
 .../resources/conf/iotdb-engine.properties         |  14 ++
 .../org/apache/iotdb/db/conf/IoTDBDescriptor.java  |   4 +
 .../org/apache/iotdb/db/query/udf/api/UDF.java     |  15 ++
 .../org/apache/iotdb/db/query/udf/api/UDTF.java    |  10 +-
 .../parameter/UDFParameterValidator.java           | 209 +++++++++++++++++++++
 .../api/customizer/parameter/UDFParameters.java    |   4 +
 .../UDFAttributeNotProvidedException.java          |   9 +-
 .../udf/api/exception/UDFException.java}           |  10 +-
 .../UDFInputSeriesDataTypeNotValidException.java}  |  30 ++-
 .../UDFInputSeriesIndexNotValidException.java      |  10 +-
 .../UDFInputSeriesNumberNotValidException.java}    |  29 ++-
 .../exception/UDFParameterNotValidException.java   |   8 +-
 .../db/query/udf/core/executor/UDTFExecutor.java   |  14 +-
 .../integration/IoTDBUDTFAlignByTimeQueryIT.java   |  44 +++++
 .../iotdb/db/query/udf/example/Accumulator.java    |   8 +
 .../apache/iotdb/db/query/udf/example/Adder.java   |  11 ++
 .../org/apache/iotdb/db/query/udf/example/Max.java |   8 +
 .../iotdb/db/query/udf/example/Multiplier.java     |   8 +
 .../SlidingSizeWindowConstructorTester1.java       |   8 +
 .../SlidingTimeWindowConstructionTester.java       |   8 +
 .../{Multiplier.java => ValidateTester.java}       | 100 +++++-----
 server/src/test/resources/iotdb-engine.properties  |   2 +
 thrift/src/main/thrift/cluster.thrift              |   7 +
 63 files changed, 874 insertions(+), 455 deletions(-)
 rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/NodeReport.java (98%)
 rename cluster/src/main/java/org/apache/iotdb/cluster/{query/manage => server/monitor}/NodeStatus.java (59%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/{query/manage/QueryCoordinator.java => server/monitor/NodeStatusManager.java} (72%)
 rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/Peer.java (97%)
 rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/Timer.java (99%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/parameter/UDFParameterValidator.java
 copy cluster/src/main/java/org/apache/iotdb/cluster/exception/ConfigInconsistentException.java => server/src/main/java/org/apache/iotdb/db/query/udf/api/exception/UDFAttributeNotProvidedException.java (72%)
 copy server/src/main/java/org/apache/iotdb/db/{exception/index/DistanceMetricException.java => query/udf/api/exception/UDFException.java} (78%)
 copy server/src/main/java/org/apache/iotdb/db/{qp/physical/crud/GroupByTimeFillPlan.java => query/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java} (54%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/exception/TruncateCommittedEntryException.java => server/src/main/java/org/apache/iotdb/db/query/udf/api/exception/UDFInputSeriesIndexNotValidException.java (68%)
 copy server/src/main/java/org/apache/iotdb/db/{rescon/CachedStringPool.java => query/udf/api/exception/UDFInputSeriesNumberNotValidException.java} (57%)
 copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/api/exception/UDFParameterNotValidException.java (80%)
 copy server/src/test/java/org/apache/iotdb/db/query/udf/example/{Multiplier.java => ValidateTester.java} (64%)