#9871

Committed 18 Aug 2023 08:01AM UTC coverage: 47.982% (-0.02%) from 48.003%

Build # #9871

Build Type

push

travis_ci

Committed by

web-flow

Commit Message

[IOTDB-6117] Pipe: Optimize RPC requests from CN to DN. CN send exactly one pipeMeta to each DN upon create/start/stop/drop pipe (#10875) (#10905)

Currently, CN sends pipeMeta of all existing pipes to each dn upon create/start/stop/drop pipe, which may be time-comsuming.

In this commit, CN will send exactly one pipeMeta to each DN upon create/start/stop/drop pipe.

---------

Co-authored-by: Steve Yurong Su <rong@apache.org>
(cherry picked from commit 38b36006b)

Run Details

95 of 95 new or added lines in 12 files covered. (100.0%)

79801 of 166313 relevant lines covered (47.98%)

0.48 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/DataNodeRequestType.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.apache.iotdb.confignode.client;

public enum DataNodeRequestType {

  // Node Maintenance
  DISABLE_DATA_NODE,
  STOP_DATA_NODE,

  FLUSH,
  MERGE,
  FULL_MERGE,
  LOAD_CONFIGURATION,
  SET_SYSTEM_STATUS,
  BROADCAST_LATEST_CONFIG_NODE_GROUP,

  // Region Maintenance
  CREATE_DATA_REGION,
  CREATE_SCHEMA_REGION,
  DELETE_REGION,

  CREATE_NEW_REGION_PEER,
  ADD_REGION_PEER,
  REMOVE_REGION_PEER,
  DELETE_OLD_REGION_PEER,

  UPDATE_REGION_ROUTE_MAP,
  CHANGE_REGION_LEADER,

  // PartitionCache
  INVALIDATE_PARTITION_CACHE,
  INVALIDATE_PERMISSION_CACHE,
  INVALIDATE_SCHEMA_CACHE,
  CLEAR_CACHE,

  // Function
  CREATE_FUNCTION,
  DROP_FUNCTION,

  // Trigger
  CREATE_TRIGGER_INSTANCE,
  DROP_TRIGGER_INSTANCE,
  ACTIVE_TRIGGER_INSTANCE,
  INACTIVE_TRIGGER_INSTANCE,
  UPDATE_TRIGGER_LOCATION,

  // Pipe Plugin
  CREATE_PIPE_PLUGIN,
  DROP_PIPE_PLUGIN,

  // Pipe Task
  PIPE_PUSH_ALL_META,
  PIPE_PUSH_SINGLE_META,
  PIPE_HEARTBEAT,

  // CQ
  EXECUTE_CQ,

  // TEMPLATE
  UPDATE_TEMPLATE,

  // Schema
  SET_TTL,

  CONSTRUCT_SCHEMA_BLACK_LIST,
  ROLLBACK_SCHEMA_BLACK_LIST,
  FETCH_SCHEMA_BLACK_LIST,
  INVALIDATE_MATCHED_SCHEMA_CACHE,
  DELETE_DATA_FOR_DELETE_SCHEMA,
  DELETE_TIMESERIES,

  CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
  ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
  DEACTIVATE_TEMPLATE,
  COUNT_PATHS_USING_TEMPLATE,
  CHECK_TIMESERIES_EXISTENCE,

  CONSTRUCT_VIEW_SCHEMA_BLACK_LIST,
  ROLLBACK_VIEW_SCHEMA_BLACK_LIST,
  DELETE_VIEW,

  ALTER_VIEW,

  // TODO Need to migrate to Node Maintenance
  KILL_QUERY_INSTANCE,

  // ML Model
  DELETE_MODEL_METRICS,

  // Quota
  SET_SPACE_QUOTA,
  SET_THROTTLE_QUOTA,
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one
3	* or more contributor license agreements. See the NOTICE file
4	* distributed with this work for additional information
5	* regarding copyright ownership. The ASF licenses this file
6	* to you under the Apache License, Version 2.0 (the
7	* "License"); you may not use this file except in compliance
8	* with the License. You may obtain a copy of the License at
9	*
10	* http://www.apache.org/licenses/LICENSE-2.0
11	*
12	* Unless required by applicable law or agreed to in writing,
13	* software distributed under the License is distributed on an
14	* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15	* KIND, either express or implied. See the License for the
16	* specific language governing permissions and limitations
17	* under the License.
18	*/
19
20	package org.apache.iotdb.confignode.client;
21
22	public enum DataNodeRequestType {	×
23
24	// Node Maintenance
25	DISABLE_DATA_NODE,	×
26	STOP_DATA_NODE,	×
27
28	FLUSH,	×
29	MERGE,	×
30	FULL_MERGE,	×
31	LOAD_CONFIGURATION,	×
32	SET_SYSTEM_STATUS,	×
33	BROADCAST_LATEST_CONFIG_NODE_GROUP,	×
34
35	// Region Maintenance
36	CREATE_DATA_REGION,	×
37	CREATE_SCHEMA_REGION,	×
38	DELETE_REGION,	×
39
40	CREATE_NEW_REGION_PEER,	×
41	ADD_REGION_PEER,	×
42	REMOVE_REGION_PEER,	×
43	DELETE_OLD_REGION_PEER,	×
44
45	UPDATE_REGION_ROUTE_MAP,	×
46	CHANGE_REGION_LEADER,	×
47
48	// PartitionCache
49	INVALIDATE_PARTITION_CACHE,	×
50	INVALIDATE_PERMISSION_CACHE,	×
51	INVALIDATE_SCHEMA_CACHE,	×
52	CLEAR_CACHE,	×
53
54	// Function
55	CREATE_FUNCTION,	×
56	DROP_FUNCTION,	×
57
58	// Trigger
59	CREATE_TRIGGER_INSTANCE,	×
60	DROP_TRIGGER_INSTANCE,	×
61	ACTIVE_TRIGGER_INSTANCE,	×
62	INACTIVE_TRIGGER_INSTANCE,	×
63	UPDATE_TRIGGER_LOCATION,	×
64
65	// Pipe Plugin
66	CREATE_PIPE_PLUGIN,	×
67	DROP_PIPE_PLUGIN,	×
68
69	// Pipe Task
70	PIPE_PUSH_ALL_META,	×
71	PIPE_PUSH_SINGLE_META,	×
72	PIPE_HEARTBEAT,	×
73
74	// CQ
75	EXECUTE_CQ,	×
76
77	// TEMPLATE
78	UPDATE_TEMPLATE,	×
79
80	// Schema
81	SET_TTL,	×
82
83	CONSTRUCT_SCHEMA_BLACK_LIST,	×
84	ROLLBACK_SCHEMA_BLACK_LIST,	×
85	FETCH_SCHEMA_BLACK_LIST,	×
86	INVALIDATE_MATCHED_SCHEMA_CACHE,	×
87	DELETE_DATA_FOR_DELETE_SCHEMA,	×
88	DELETE_TIMESERIES,	×
89
90	CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE,	×
91	ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE,	×
92	DEACTIVATE_TEMPLATE,	×
93	COUNT_PATHS_USING_TEMPLATE,	×
94	CHECK_TIMESERIES_EXISTENCE,	×
95
96	CONSTRUCT_VIEW_SCHEMA_BLACK_LIST,	×
97	ROLLBACK_VIEW_SCHEMA_BLACK_LIST,	×
98	DELETE_VIEW,	×
99
100	ALTER_VIEW,	×
101
102	// TODO Need to migrate to Node Maintenance
103	KILL_QUERY_INSTANCE,	×
104
105	// ML Model
106	DELETE_MODEL_METRICS,	×
107
108	// Quota
109	SET_SPACE_QUOTA,	×
110	SET_THROTTLE_QUOTA,	×
111	}

apache / iotdb / #9871

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous