in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java [120:466]
protected void initActionMapBuilder() {
actionMapBuilder.put(
CnToDnAsyncRequestType.SET_TTL,
(req, client, handler) ->
client.setTTL((TSetTTLReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CREATE_DATA_REGION,
(req, client, handler) ->
client.createDataRegion(
(TCreateDataRegionReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_REGION,
(req, client, handler) ->
client.deleteRegion((TConsensusGroupId) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CREATE_SCHEMA_REGION,
(req, client, handler) ->
client.createSchemaRegion(
(TCreateSchemaRegionReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CREATE_FUNCTION,
(req, client, handler) ->
client.createFunction(
(TCreateFunctionInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DROP_FUNCTION,
(req, client, handler) ->
client.dropFunction(
(TDropFunctionInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CREATE_TRIGGER_INSTANCE,
(req, client, handler) ->
client.createTriggerInstance(
(TCreateTriggerInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DROP_TRIGGER_INSTANCE,
(req, client, handler) ->
client.dropTriggerInstance(
(TDropTriggerInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ACTIVE_TRIGGER_INSTANCE,
(req, client, handler) ->
client.activeTriggerInstance(
(TActiveTriggerInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INACTIVE_TRIGGER_INSTANCE,
(req, client, handler) ->
client.inactiveTriggerInstance(
(TInactiveTriggerInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.UPDATE_TRIGGER_LOCATION,
(req, client, handler) ->
client.updateTriggerLocation(
(TUpdateTriggerLocationReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CREATE_PIPE_PLUGIN,
(req, client, handler) ->
client.createPipePlugin(
(TCreatePipePluginInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DROP_PIPE_PLUGIN,
(req, client, handler) ->
client.dropPipePlugin(
(TDropPipePluginInstanceReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.PIPE_PUSH_ALL_META,
(req, client, handler) ->
client.pushPipeMeta((TPushPipeMetaReq) req, (PipePushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.PIPE_PUSH_SINGLE_META,
(req, client, handler) ->
client.pushSinglePipeMeta(
(TPushSinglePipeMetaReq) req, (PipePushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.PIPE_PUSH_MULTI_META,
(req, client, handler) ->
client.pushMultiPipeMeta(
(TPushMultiPipeMetaReq) req, (PipePushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.TOPIC_PUSH_ALL_META,
(req, client, handler) ->
client.pushTopicMeta((TPushTopicMetaReq) req, (TopicPushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.TOPIC_PUSH_SINGLE_META,
(req, client, handler) ->
client.pushSingleTopicMeta(
(TPushSingleTopicMetaReq) req, (TopicPushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.TOPIC_PUSH_MULTI_META,
(req, client, handler) ->
client.pushMultiTopicMeta(
(TPushMultiTopicMetaReq) req, (TopicPushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSUMER_GROUP_PUSH_ALL_META,
(req, client, handler) ->
client.pushConsumerGroupMeta(
(TPushConsumerGroupMetaReq) req, (ConsumerGroupPushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSUMER_GROUP_PUSH_SINGLE_META,
(req, client, handler) ->
client.pushSingleConsumerGroupMeta(
(TPushSingleConsumerGroupMetaReq) req, (ConsumerGroupPushMetaRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.PIPE_HEARTBEAT,
(req, client, handler) ->
client.pipeHeartbeat((TPipeHeartbeatReq) req, (PipeHeartbeatRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.MERGE,
(req, client, handler) -> client.merge((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.FULL_MERGE,
(req, client, handler) -> client.merge((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.FLUSH,
(req, client, handler) ->
client.flush((TFlushReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CLEAR_CACHE,
(req, client, handler) ->
client.clearCache((Set<Integer>) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.START_REPAIR_DATA,
(req, client, handler) -> client.startRepairData((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.STOP_REPAIR_DATA,
(req, client, handler) -> client.stopRepairData((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.LOAD_CONFIGURATION,
(req, client, handler) -> client.loadConfiguration((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SET_SYSTEM_STATUS,
(req, client, handler) ->
client.setSystemStatus((String) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SET_CONFIGURATION,
(req, client, handler) ->
client.setConfiguration(
(TSetConfigurationReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.UPDATE_REGION_ROUTE_MAP,
(req, client, handler) ->
client.updateRegionCache((TRegionRouteReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.NOTIFY_REGION_MIGRATION,
(req, client, handler) ->
client.notifyRegionMigration(
(TNotifyRegionMigrationReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CHANGE_REGION_LEADER,
(req, client, handler) ->
client.changeRegionLeader(
(TRegionLeaderChangeReq) req, (TransferLeaderRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSTRUCT_SCHEMA_BLACK_LIST,
(req, client, handler) ->
client.constructSchemaBlackList(
(TConstructSchemaBlackListReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ROLLBACK_SCHEMA_BLACK_LIST,
(req, client, handler) ->
client.rollbackSchemaBlackList(
(TRollbackSchemaBlackListReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.FETCH_SCHEMA_BLACK_LIST,
(req, client, handler) ->
client.fetchSchemaBlackList(
(TFetchSchemaBlackListReq) req, (FetchSchemaBlackListRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_SCHEMA_CACHE,
(req, client, handler) ->
client.invalidateSchemaCache(
(TInvalidateCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_MATCHED_SCHEMA_CACHE,
(req, client, handler) ->
client.invalidateMatchedSchemaCache(
(TInvalidateMatchedSchemaCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_LAST_CACHE,
(req, client, handler) ->
client.invalidateLastCache((String) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_DATA_FOR_DELETE_SCHEMA,
(req, client, handler) ->
client.deleteDataForDeleteSchema(
(TDeleteDataForDeleteSchemaReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_TIMESERIES,
(req, client, handler) ->
client.deleteTimeSeries((TDeleteTimeSeriesReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
(req, client, handler) ->
client.constructSchemaBlackListWithTemplate(
(TConstructSchemaBlackListWithTemplateReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
(req, client, handler) ->
client.rollbackSchemaBlackListWithTemplate(
(TRollbackSchemaBlackListWithTemplateReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DEACTIVATE_TEMPLATE,
(req, client, handler) ->
client.deactivateTemplate(
(TDeactivateTemplateReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.UPDATE_TEMPLATE,
(req, client, handler) ->
client.updateTemplate((TUpdateTemplateReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.COUNT_PATHS_USING_TEMPLATE,
(req, client, handler) ->
client.countPathsUsingTemplate(
(TCountPathsUsingTemplateReq) req, (CountPathsUsingTemplateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CHECK_SCHEMA_REGION_USING_TEMPLATE,
(req, client, handler) ->
client.checkSchemaRegionUsingTemplate(
(TCheckSchemaRegionUsingTemplateReq) req,
(CheckSchemaRegionUsingTemplateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CHECK_TIMESERIES_EXISTENCE,
(req, client, handler) ->
client.checkTimeSeriesExistence(
(TCheckTimeSeriesExistenceReq) req, (CheckTimeSeriesExistenceRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSTRUCT_VIEW_SCHEMA_BLACK_LIST,
(req, client, handler) ->
client.constructViewSchemaBlackList(
(TConstructViewSchemaBlackListReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ROLLBACK_VIEW_SCHEMA_BLACK_LIST,
(req, client, handler) ->
client.rollbackViewSchemaBlackList(
(TRollbackViewSchemaBlackListReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_VIEW,
(req, client, handler) ->
client.deleteViewSchema((TDeleteViewSchemaReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ALTER_VIEW,
(req, client, handler) ->
client.alterView((TAlterViewReq) req, (SchemaUpdateRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.KILL_QUERY_INSTANCE,
(req, client, handler) ->
client.killQueryInstance((String) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SET_SPACE_QUOTA,
(req, client, handler) ->
client.setSpaceQuota((TSetSpaceQuotaReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SET_THROTTLE_QUOTA,
(req, client, handler) ->
client.setThrottleQuota(
(TSetThrottleQuotaReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.RESET_PEER_LIST,
(req, client, handler) ->
client.resetPeerList((TResetPeerListReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SUBMIT_TEST_CONNECTION_TASK,
(req, client, handler) ->
client.submitTestConnectionTask(
(TNodeLocations) req, (SubmitTestConnectionTaskRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.SUBMIT_TEST_DN_INTERNAL_CONNECTION_TASK,
(req, client, handler) ->
client.submitInternalTestConnectionTask(
(TNodeLocations) req, (SubmitTestConnectionTaskRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.TEST_CONNECTION,
(req, client, handler) ->
client.testConnectionEmptyRPC((DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.UPDATE_TABLE,
(req, client, handler) ->
client.updateTable((TUpdateTableReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_TABLE_CACHE,
(req, client, handler) ->
client.invalidateTableCache(
(TInvalidateTableCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_DATA_FOR_DROP_TABLE,
(req, client, handler) ->
client.deleteDataForDropTable(
(TDeleteDataOrDevicesForDropTableReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_DEVICES_FOR_DROP_TABLE,
(req, client, handler) ->
client.deleteDevicesForDropTable(
(TDeleteDataOrDevicesForDropTableReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_COLUMN_CACHE,
(req, client, handler) ->
client.invalidateColumnCache(
(TInvalidateColumnCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_COLUMN_DATA,
(req, client, handler) ->
client.deleteColumnData(
(TDeleteColumnDataReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CONSTRUCT_TABLE_DEVICE_BLACK_LIST,
(req, client, handler) ->
client.constructTableDeviceBlackList(
(TTableDeviceDeletionWithPatternAndFilterReq) req,
(DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.ROLLBACK_TABLE_DEVICE_BLACK_LIST,
(req, client, handler) ->
client.rollbackTableDeviceBlackList(
(TTableDeviceDeletionWithPatternOrModReq) req,
(DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.INVALIDATE_MATCHED_TABLE_DEVICE_CACHE,
(req, client, handler) ->
client.invalidateMatchedTableDeviceCache(
(TTableDeviceInvalidateCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_DATA_FOR_TABLE_DEVICE,
(req, client, handler) ->
client.deleteDataForTableDevice(
(TTableDeviceDeletionWithPatternOrModReq) req,
(DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DELETE_TABLE_DEVICE_IN_BLACK_LIST,
(req, client, handler) ->
client.deleteTableDeviceInBlackList(
(TTableDeviceDeletionWithPatternOrModReq) req,
(DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.DETECT_TREE_DEVICE_VIEW_FIELD_TYPE,
(req, client, handler) ->
client.detectTreeDeviceViewFieldType(
(TDeviceViewReq) req, (TreeDeviceViewFieldDetectionHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.CLEAN_DATA_NODE_CACHE,
(req, client, handler) ->
client.cleanDataNodeCache(
(TCleanDataNodeCacheReq) req, (DataNodeTSStatusRPCHandler) handler));
actionMapBuilder.put(
CnToDnAsyncRequestType.STOP_AND_CLEAR_DATA_NODE,
(req, client, handler) ->
client.stopAndClearDataNode((DataNodeTSStatusRPCHandler) handler));
}