This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch DeadLockTryFix in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit fbe0074bf847e97b467acb7a392bacedf0017e74 Author: JackieTien97 <[email protected]> AuthorDate: Fri Jun 4 15:20:01 2021 +0800 format code --- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 100 +++++++++++---------- 1 file changed, 51 insertions(+), 49 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java index 1fe07df..b07750f 100644 --- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java @@ -18,55 +18,6 @@ */ package org.apache.iotdb.db.qp.executor; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CANCELLED; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CHILD_NODES; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CHILD_PATHS; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_COLUMN; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_COUNT; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CREATED_TIME; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_DEVICES; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_DONE; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_CLASS; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_NAME; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_TYPE; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_ITEM; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_LOCK_INFO; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_PRIVILEGE; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_PROGRESS; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_ROLE; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_STORAGE_GROUP; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TASK_NAME; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_ATTRIBUTES; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_CLASS; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_EVENT; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_NAME; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_PATH; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_STATUS; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TTL; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_USER; -import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_VALUE; -import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_BUILTIN_UDAF; -import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_BUILTIN_UDTF; -import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_EXTERNAL_UDAF; -import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_EXTERNAL_UDTF; -import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_NATIVE; -import static org.apache.iotdb.db.conf.IoTDBConstant.QUERY_ID; -import static org.apache.iotdb.db.conf.IoTDBConstant.STATEMENT; -import static org.apache.iotdb.tsfile.common.constant.TsFileConstant.TSFILE_SUFFIX; - -import java.io.File; -import java.io.IOException; -import java.lang.reflect.InvocationTargetException; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collection; -import java.util.Collections; -import java.util.HashMap; -import java.util.HashSet; -import java.util.List; -import java.util.Map; -import java.util.Map.Entry; -import java.util.Set; import org.apache.iotdb.db.auth.AuthException; import org.apache.iotdb.db.auth.AuthorityChecker; import org.apache.iotdb.db.auth.authorizer.BasicAuthorizer; @@ -188,9 +139,60 @@ import org.apache.iotdb.tsfile.utils.Binary; import org.apache.iotdb.tsfile.utils.Pair; import org.apache.iotdb.tsfile.write.schema.MeasurementSchema; import org.apache.iotdb.tsfile.write.writer.RestorableTsFileIOWriter; + import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.File; +import java.io.IOException; +import java.lang.reflect.InvocationTargetException; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Map.Entry; +import java.util.Set; + +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CANCELLED; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CHILD_NODES; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CHILD_PATHS; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_COLUMN; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_COUNT; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_CREATED_TIME; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_DEVICES; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_DONE; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_CLASS; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_NAME; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_FUNCTION_TYPE; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_ITEM; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_LOCK_INFO; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_PRIVILEGE; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_PROGRESS; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_ROLE; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_STORAGE_GROUP; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TASK_NAME; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_ATTRIBUTES; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_CLASS; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_EVENT; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_NAME; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_PATH; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TRIGGER_STATUS; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_TTL; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_USER; +import static org.apache.iotdb.db.conf.IoTDBConstant.COLUMN_VALUE; +import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_BUILTIN_UDAF; +import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_BUILTIN_UDTF; +import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_EXTERNAL_UDAF; +import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_EXTERNAL_UDTF; +import static org.apache.iotdb.db.conf.IoTDBConstant.FUNCTION_TYPE_NATIVE; +import static org.apache.iotdb.db.conf.IoTDBConstant.QUERY_ID; +import static org.apache.iotdb.db.conf.IoTDBConstant.STATEMENT; +import static org.apache.iotdb.tsfile.common.constant.TsFileConstant.TSFILE_SUFFIX; + @SuppressWarnings("java:S1135") // ignore todos public class PlanExecutor implements IPlanExecutor {
