public static ProcedureType getProcedureType()

in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureFactory.java [409:545]
137 lines of code
67 McCabe index (conditional complexity)

  public static ProcedureType getProcedureType(final Procedure<?> procedure) {
    if (procedure instanceof DeleteDatabaseProcedure) {
      return ProcedureType.DELETE_DATABASE_PROCEDURE;
    } else if (procedure instanceof AddConfigNodeProcedure) {
      return ProcedureType.ADD_CONFIG_NODE_PROCEDURE;
    } else if (procedure instanceof RemoveConfigNodeProcedure) {
      return ProcedureType.REMOVE_CONFIG_NODE_PROCEDURE;
    } else if (procedure instanceof RemoveDataNodesProcedure) {
      return ProcedureType.REMOVE_DATA_NODE_PROCEDURE;
    } else if (procedure instanceof RemoveAINodeProcedure) {
      return ProcedureType.REMOVE_AI_NODE_PROCEDURE;
    } else if (procedure instanceof RegionMigrateProcedure) {
      return ProcedureType.REGION_MIGRATE_PROCEDURE;
    } else if (procedure instanceof AddRegionPeerProcedure) {
      return ProcedureType.ADD_REGION_PEER_PROCEDURE;
    } else if (procedure instanceof RemoveRegionPeerProcedure) {
      return ProcedureType.REMOVE_REGION_PEER_PROCEDURE;
    } else if (procedure instanceof CreateRegionGroupsProcedure) {
      return ProcedureType.CREATE_REGION_GROUPS;
    } else if (procedure instanceof DeleteTimeSeriesProcedure) {
      return ProcedureType.DELETE_TIMESERIES_PROCEDURE;
    } else if (procedure instanceof ReconstructRegionProcedure) {
      return ProcedureType.RECONSTRUCT_REGION_PROCEDURE;
    } else if (procedure instanceof NotifyRegionMigrationProcedure) {
      return ProcedureType.NOTIFY_REGION_MIGRATION_PROCEDURE;
    } else if (procedure instanceof CreateTriggerProcedure) {
      return ProcedureType.CREATE_TRIGGER_PROCEDURE;
    } else if (procedure instanceof DropTriggerProcedure) {
      return ProcedureType.DROP_TRIGGER_PROCEDURE;
    } else if (procedure instanceof CreatePipeProcedure) {
      return ProcedureType.CREATE_PIPE_PROCEDURE;
    } else if (procedure instanceof StartPipeProcedure) {
      return ProcedureType.START_PIPE_PROCEDURE;
    } else if (procedure instanceof StopPipeProcedure) {
      return ProcedureType.STOP_PIPE_PROCEDURE;
    } else if (procedure instanceof DropPipeProcedure) {
      return ProcedureType.DROP_PIPE_PROCEDURE;
    } else if (procedure instanceof CreateCQProcedure) {
      return ProcedureType.CREATE_CQ_PROCEDURE;
    } else if (procedure instanceof SetTemplateProcedure) {
      return ProcedureType.SET_TEMPLATE_PROCEDURE;
    } else if (procedure instanceof DeactivateTemplateProcedure) {
      return ProcedureType.DEACTIVATE_TEMPLATE_PROCEDURE;
    } else if (procedure instanceof UnsetTemplateProcedure) {
      return ProcedureType.UNSET_TEMPLATE_PROCEDURE;
    } else if (procedure instanceof CreateTableViewProcedure) {
      return ProcedureType.CREATE_TABLE_VIEW_PROCEDURE;
    } else if (procedure instanceof CreateTableProcedure) {
      return ProcedureType.CREATE_TABLE_PROCEDURE;
    } else if (procedure instanceof AddViewColumnProcedure) {
      return ProcedureType.ADD_VIEW_COLUMN_PROCEDURE;
    } else if (procedure instanceof AddTableColumnProcedure) {
      return ProcedureType.ADD_TABLE_COLUMN_PROCEDURE;
    } else if (procedure instanceof SetViewPropertiesProcedure) {
      return ProcedureType.SET_VIEW_PROPERTIES_PROCEDURE;
    } else if (procedure instanceof SetTablePropertiesProcedure) {
      return ProcedureType.SET_TABLE_PROPERTIES_PROCEDURE;
    } else if (procedure instanceof RenameViewColumnProcedure) {
      return ProcedureType.RENAME_VIEW_COLUMN_PROCEDURE;
    } else if (procedure instanceof RenameTableColumnProcedure) {
      return ProcedureType.RENAME_TABLE_COLUMN_PROCEDURE;
    } else if (procedure instanceof DropViewColumnProcedure) {
      return ProcedureType.DROP_VIEW_COLUMN_PROCEDURE;
    } else if (procedure instanceof DropTableColumnProcedure) {
      return ProcedureType.DROP_TABLE_COLUMN_PROCEDURE;
    } else if (procedure instanceof DropViewProcedure) {
      return ProcedureType.DROP_VIEW_PROCEDURE;
    } else if (procedure instanceof DropTableProcedure) {
      return ProcedureType.DROP_TABLE_PROCEDURE;
    } else if (procedure instanceof DeleteDevicesProcedure) {
      return ProcedureType.DELETE_DEVICES_PROCEDURE;
    } else if (procedure instanceof RenameViewProcedure) {
      return ProcedureType.RENAME_VIEW_PROCEDURE;
    } else if (procedure instanceof RenameTableProcedure) {
      return ProcedureType.RENAME_TABLE_PROCEDURE;
    } else if (procedure instanceof CreatePipePluginProcedure) {
      return ProcedureType.CREATE_PIPE_PLUGIN_PROCEDURE;
    } else if (procedure instanceof DropPipePluginProcedure) {
      return ProcedureType.DROP_PIPE_PLUGIN_PROCEDURE;
    } else if (procedure instanceof CreateModelProcedure) {
      return ProcedureType.CREATE_MODEL_PROCEDURE;
    } else if (procedure instanceof DropModelProcedure) {
      return ProcedureType.DROP_MODEL_PROCEDURE;
    } else if (procedure instanceof CreatePipeProcedureV2) {
      return ProcedureType.CREATE_PIPE_PROCEDURE_V2;
    } else if (procedure instanceof StartPipeProcedureV2) {
      return ProcedureType.START_PIPE_PROCEDURE_V2;
    } else if (procedure instanceof StopPipeProcedureV2) {
      return ProcedureType.STOP_PIPE_PROCEDURE_V2;
    } else if (procedure instanceof DropPipeProcedureV2) {
      return ProcedureType.DROP_PIPE_PROCEDURE_V2;
    } else if (procedure instanceof AlterPipeProcedureV2) {
      return ProcedureType.ALTER_PIPE_PROCEDURE_V2;
    } else if (procedure instanceof PipeHandleLeaderChangeProcedure) {
      return ProcedureType.PIPE_HANDLE_LEADER_CHANGE_PROCEDURE;
    } else if (procedure instanceof PipeMetaSyncProcedure) {
      return ProcedureType.PIPE_META_SYNC_PROCEDURE;
    } else if (procedure instanceof PipeHandleMetaChangeProcedure) {
      return ProcedureType.PIPE_HANDLE_META_CHANGE_PROCEDURE;
    } else if (procedure instanceof CreateTopicProcedure) {
      return ProcedureType.CREATE_TOPIC_PROCEDURE;
    } else if (procedure instanceof DropTopicProcedure) {
      return ProcedureType.DROP_TOPIC_PROCEDURE;
    } else if (procedure instanceof AlterTopicProcedure) {
      return ProcedureType.ALTER_TOPIC_PROCEDURE;
    } else if (procedure instanceof TopicMetaSyncProcedure) {
      return ProcedureType.TOPIC_META_SYNC_PROCEDURE;
    } else if (procedure instanceof CreateSubscriptionProcedure) {
      return ProcedureType.CREATE_SUBSCRIPTION_PROCEDURE;
    } else if (procedure instanceof DropSubscriptionProcedure) {
      return ProcedureType.DROP_SUBSCRIPTION_PROCEDURE;
    } else if (procedure instanceof CreateConsumerProcedure) {
      return ProcedureType.CREATE_CONSUMER_PROCEDURE;
    } else if (procedure instanceof DropConsumerProcedure) {
      return ProcedureType.DROP_CONSUMER_PROCEDURE;
    } else if (procedure instanceof AlterConsumerGroupProcedure) {
      return ProcedureType.ALTER_CONSUMER_GROUP_PROCEDURE;
    } else if (procedure instanceof ConsumerGroupMetaSyncProcedure) {
      return ProcedureType.CONSUMER_GROUP_META_SYNC_PROCEDURE;
    } else if (procedure instanceof DeleteLogicalViewProcedure) {
      return ProcedureType.DELETE_LOGICAL_VIEW_PROCEDURE;
    } else if (procedure instanceof AlterLogicalViewProcedure) {
      return ProcedureType.ALTER_LOGICAL_VIEW_PROCEDURE;
    } else if (procedure instanceof AuthOperationProcedure) {
      return ProcedureType.AUTH_OPERATE_PROCEDURE;
    } else if (procedure instanceof SetTTLProcedure) {
      return ProcedureType.SET_TTL_PROCEDURE;
    } else if (procedure instanceof CreateManyDatabasesProcedure) {
      return ProcedureType.CREATE_MANY_DATABASES_PROCEDURE;
    } else if (procedure instanceof NeverFinishProcedure) {
      return ProcedureType.NEVER_FINISH_PROCEDURE;
    } else if (procedure instanceof AddNeverFinishSubProcedureProcedure) {
      return ProcedureType.ADD_NEVER_FINISH_SUB_PROCEDURE_PROCEDURE;
    }
    throw new UnsupportedOperationException(
        "Procedure type " + procedure.getClass() + " is not supported");
  }