code format; change LOGGER to logger; add Priority constant value fix_sonar 31/head
authorxiangdong huang <sainthxd@gmail.com>
Mon, 28 Jan 2019 15:48:54 +0000 (23:48 +0800)
committerxiangdong huang <sainthxd@gmail.com>
Mon, 28 Jan 2019 15:48:54 +0000 (23:48 +0800)
iotdb/src/main/java/org/apache/iotdb/db/postback/receiver/ServerServiceImpl.java
iotdb/src/main/java/org/apache/iotdb/db/postback/utils/CreateDataSender1.java
iotdb/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/ConcatPathOptimizer.java
iotdb/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/RemoveNotOptimizer.java
iotdb/src/main/java/org/apache/iotdb/db/query/control/FileReaderManager.java
iotdb/src/main/java/org/apache/iotdb/db/query/control/QueryTokenManager.java
iotdb/src/main/java/org/apache/iotdb/db/query/executor/EngineExecutorWithTimeGenerator.java
iotdb/src/main/java/org/apache/iotdb/db/query/executor/EngineExecutorWithoutTimeGenerator.java
iotdb/src/main/java/org/apache/iotdb/db/query/factory/SeriesReaderFactory.java
iotdb/src/main/java/org/apache/iotdb/db/query/reader/merge/PriorityMergeReader.java

index 9bb66ad..1324abd 100644 (file)
@@ -27,7 +27,6 @@ import java.io.IOException;
 import java.math.BigInteger;
 import java.nio.ByteBuffer;
 import java.nio.channels.FileChannel;
-import java.nio.file.Files;
 import java.security.MessageDigest;
 import java.sql.Connection;
 import java.sql.DriverManager;
@@ -36,6 +35,7 @@ import java.sql.Statement;
 import java.util.*;
 
 import org.apache.iotdb.db.conf.IoTDBConfig;
+import org.apache.iotdb.db.conf.IoTDBConstant;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.conf.directories.Directories;
 import org.apache.iotdb.db.engine.filenode.FileNodeManager;
@@ -64,7 +64,7 @@ import org.slf4j.LoggerFactory;
  */
 public class ServerServiceImpl implements ServerService.Iface {
 
-  private static final Logger LOGGER = LoggerFactory.getLogger(ServerServiceImpl.class);
+  private static final Logger logger = LoggerFactory.getLogger(ServerServiceImpl.class);
   private static final FileNodeManager fileNodeManager = FileNodeManager.getInstance();
   private static final String JDBC_DRIVER_NAME = "org.apache.iotdb.jdbc.IoTDBDriver";
   private static final String POSTBACK = "postback";
@@ -91,7 +91,7 @@ public class ServerServiceImpl implements ServerService.Iface {
    */
   @Override
   public void init(String storageGroup) {
-    LOGGER.info(String.format(
+    logger.info(String.format(
         "IoTDB post back receiver: postback process starts to receive data of storage group {}."),
         storageGroup);
     fileNum.set(0);
@@ -159,17 +159,17 @@ public class ServerServiceImpl implements ServerService.Iface {
         try {
           file.getParentFile().mkdirs();
           if (!file.createNewFile()) {
-            LOGGER.error("IoTDB post back receiver: cannot create file {}", file.getAbsoluteFile());
+            logger.error("IoTDB post back receiver: cannot create file {}", file.getAbsoluteFile());
           }
         } catch (IOException e) {
-          LOGGER.error("IoTDB post back receiver: cannot make file", e);
+          logger.error("IoTDB post back receiver: cannot make file", e);
         }
       }
       try (FileOutputStream fos = new FileOutputStream(file, true)) {// append new data
         channel = fos.getChannel();
         channel.write(dataToReceive);
       } catch (IOException e) {
-        LOGGER.error("IoTDB post back receiver: cannot write data to file", e);
+        logger.error("IoTDB post back receiver: cannot write data to file", e);
 
       }
     } else { // all data in the same file has received successfully
@@ -184,14 +184,14 @@ public class ServerServiceImpl implements ServerService.Iface {
         md5OfReceiver = (new BigInteger(1, md.digest())).toString(16);
         if (md5OfSender.equals(md5OfReceiver)) {
           fileNum.set(fileNum.get() + 1);
-          LOGGER.info(String
+          logger.info(String
               .format("IoTDB post back receiver : Receiver has received %d files from sender!",
                   fileNum.get()));
         } else {
           new File(filePath).delete();
         }
       } catch (Exception e) {
-        LOGGER.error("IoTDB post back receiver: cannot generate md5", e);
+        logger.error("IoTDB post back receiver: cannot generate md5", e);
       }
     }
     return md5OfReceiver;
@@ -210,7 +210,7 @@ public class ServerServiceImpl implements ServerService.Iface {
     if (status == 0) {
       Statement statement = null;
       try (Connection connection = DriverManager.getConnection("jdbc:iotdb://localhost:" +
-          config.rpcPort + "/", "root", "root")) {
+          config.rpcPort + "/", IoTDBConstant.ADMIN_NAME, IoTDBConstant.ADMIN_PW)) {
         Class.forName(JDBC_DRIVER_NAME);
         statement = connection.createStatement();
 
@@ -238,23 +238,23 @@ public class ServerServiceImpl implements ServerService.Iface {
             }
           }
         } catch (FileNotFoundException e) {
-          LOGGER.error("IoTDB post back receiver: cannot read the file {}.",
+          logger.error("IoTDB post back receiver: cannot read the file {}.",
               schemaFromSenderPath.get(), e);
         } catch (IOException e) {
-          LOGGER.error("IoTDB post back receiver: cannot insert schema to IoTDB.", e);
+          logger.error("IoTDB post back receiver: cannot insert schema to IoTDB.", e);
         }
 
         statement.executeBatch();
         statement.clearBatch();
       } catch (SQLException | ClassNotFoundException e) {
-        LOGGER.error("IoTDB post back receiver: jdbc can not connect to IoTDB.", e);
+        logger.error("IoTDB post back receiver: jdbc can not connect to IoTDB.", e);
       } finally {
         try {
           if (statement != null) {
             statement.close();
           }
         } catch (SQLException e) {
-          LOGGER.error("IoTDB post back receiver : can not close JDBC connection.", e);
+          logger.error("IoTDB post back receiver : can not close JDBC connection.", e);
         }
       }
     } else {
@@ -263,11 +263,11 @@ public class ServerServiceImpl implements ServerService.Iface {
         try {
           file.getParentFile().mkdirs();
           if (!file.createNewFile()) {
-            LOGGER.error("IoTDB post back receiver: cannot create file {}",
+            logger.error("IoTDB post back receiver: cannot create file {}",
                 file.getAbsoluteFile());
           }
         } catch (IOException e) {
-          LOGGER.error("IoTDB post back receiver: cannot make schema file.", e);
+          logger.error("IoTDB post back receiver: cannot make schema file.", e);
         }
       }
       try {
@@ -277,7 +277,7 @@ public class ServerServiceImpl implements ServerService.Iface {
         channel.close();
         fos.close();
       } catch (Exception e) {
-        LOGGER.error("IoTDB post back receiver: cannot write data to file.",
+        logger.error("IoTDB post back receiver: cannot write data to file.",
             e);
       }
     }
@@ -320,7 +320,7 @@ public class ServerServiceImpl implements ServerService.Iface {
     fileNodeStartTime.remove();
     fileNodeEndTime.remove();
     schemaFromSenderPath.remove();
-    LOGGER.info("IoTDB post back receiver: the postBack has finished!");
+    logger.info("IoTDB post back receiver: the postBack has finished!");
   }
 
   /**
@@ -350,7 +350,7 @@ public class ServerServiceImpl implements ServerService.Iface {
             endTimeMap.put(key, device.getEndTime());
           }
         } catch (Exception e) {
-          LOGGER.error("IoTDB post back receiver: unable to read tsfile {}",
+          logger.error("IoTDB post back receiver: unable to read tsfile {}",
               fileTF.getAbsolutePath(), e);
         } finally {
           try {
@@ -358,7 +358,7 @@ public class ServerServiceImpl implements ServerService.Iface {
               reader.close();
             }
           } catch (IOException e) {
-            LOGGER.error("IoTDB receiver : Cannot close file stream {}",
+            logger.error("IoTDB receiver : Cannot close file stream {}",
                 fileTF.getAbsolutePath(), e);
           }
         }
@@ -366,7 +366,7 @@ public class ServerServiceImpl implements ServerService.Iface {
         fileNodeEndTime.get().put(fileTF.getAbsolutePath(), endTimeMap);
         filesPath.add(fileTF.getAbsolutePath());
         num++;
-        LOGGER.info(String
+        logger.info(String
             .format("IoTDB receiver : Getting FileNode Info has complete : %d/%d", num,
                 fileNum.get()));
       }
@@ -448,23 +448,23 @@ public class ServerServiceImpl implements ServerService.Iface {
       statement.executeBatch();
       statement.clearBatch();
     } catch (IOException e) {
-      LOGGER.error("IoTDB receiver can not parse tsfile into SQL", e);
+      logger.error("IoTDB receiver can not parse tsfile into SQL", e);
     } catch (SQLException | ClassNotFoundException e) {
-      LOGGER.error("IoTDB post back receiver: jdbc cannot connect to IoTDB", e);
+      logger.error("IoTDB post back receiver: jdbc cannot connect to IoTDB", e);
     } finally {
       try {
         if (reader != null) {
           reader.close();
         }
       } catch (IOException e) {
-        LOGGER.error("IoTDB receiver : Cannot close file stream {}", filePath, e);
+        logger.error("IoTDB receiver : Cannot close file stream {}", filePath, e);
       }
       try {
         if (statement != null) {
           statement.close();
         }
       } catch (SQLException e) {
-        LOGGER.error("IoTDB receiver : Can not close JDBC connection", e);
+        logger.error("IoTDB receiver : Can not close JDBC connection", e);
       }
     }
   }
@@ -598,23 +598,23 @@ public class ServerServiceImpl implements ServerService.Iface {
       statement.executeBatch();
       statement.clearBatch();
     } catch (SQLException e) {
-      LOGGER.error("IoTDB post back receiver: sql cannot execute successfully in IoTDB", e);
+      logger.error("IoTDB post back receiver: sql cannot execute successfully in IoTDB", e);
     } catch (ClassNotFoundException e) {
-      LOGGER.error("IoTDB post back receiver: jdbc cannot connect to IoTDB", e);
+      logger.error("IoTDB post back receiver: jdbc cannot connect to IoTDB", e);
     } catch (IOException e) {
-      LOGGER.error("IoTDB receiver can not parse tsfile into SQL", e);
+      logger.error("IoTDB receiver can not parse tsfile into SQL", e);
     } finally {
       try {
         reader.close();
       } catch (IOException e) {
-        LOGGER.error("IoTDB receiver : Cannot close file stream {}", filePath, e);
+        logger.error("IoTDB receiver : Cannot close file stream {}", filePath, e);
       }
       try {
         if (statement != null) {
           statement.close();
         }
       } catch (SQLException e) {
-        LOGGER.error("IoTDB receiver : Can not close JDBC connection", e);
+        logger.error("IoTDB receiver : Can not close JDBC connection", e);
       }
     }
   }
@@ -681,11 +681,11 @@ public class ServerServiceImpl implements ServerService.Iface {
             }
           }
         } catch (FileNodeManagerException e) {
-          LOGGER.error("IoTDB receiver : Can not load external file ", e);
+          logger.error("IoTDB receiver : Can not load external file ", e);
         }
 
         num++;
-        LOGGER.info(String
+        logger.info(String
             .format("IoTDB receiver : Merging files has completed : %d/%d", num, fileNum.get()));
       }
     }
index a4f25e6..e5e9664 100644 (file)
@@ -58,7 +58,7 @@ public class CreateDataSender1 {
   private static final int MAX_FLOAT = 30;
   private static final int STRING_LENGTH = 5;
   private static final int BATCH_SQL = 10000;
-  private static final Logger LOGGER = LoggerFactory.getLogger(CreateDataSender1.class);
+  private static final Logger logger = LoggerFactory.getLogger(CreateDataSender1.class);
 
   /**
    * generate time series map from file.
@@ -117,7 +117,7 @@ public class CreateDataSender1 {
       statement.executeBatch();
       statement.clearBatch();
     } catch (Exception e) {
-      LOGGER.error("", e);
+      logger.error("", e);
     }
   }
 
@@ -137,7 +137,7 @@ public class CreateDataSender1 {
         statement.execute(sql);
       }
     } catch (Exception e) {
-      LOGGER.error("", e);
+      logger.error("", e);
     }
   }
 
@@ -243,15 +243,15 @@ public class CreateDataSender1 {
       statement = connection.createStatement();
 
       setStorageGroup(statement, storageGroupList);
-      LOGGER.debug("Finish set storage group.");
+      logger.debug("Finish set storage group.");
       createTimeseries(statement, timeseriesMap);
-      LOGGER.debug("Finish create timeseries.");
+      logger.debug("Finish create timeseries.");
       while (true) {
         randomInsertData(statement, timeseriesMap);
       }
 
     } catch (Exception e) {
-      LOGGER.error("", e);
+      logger.error("", e);
     } finally {
       if (statement != null) {
         statement.close();
index f483077..0693991 100644 (file)
@@ -61,7 +61,7 @@ public class ConcatPathOptimizer implements ILogicalOptimizer {
     SFWOperator sfwOperator = (SFWOperator) operator;
     FromOperator from = sfwOperator.getFromOperator();
     List<Path> prefixPaths;
-    if (from == null){
+    if (from == null) {
       LOG.warn("given SFWOperator doesn't have prefix paths, cannot concat seriesPath");
       return operator;
     } else {
@@ -73,12 +73,12 @@ public class ConcatPathOptimizer implements ILogicalOptimizer {
     }
     SelectOperator select = sfwOperator.getSelectOperator();
     List<Path> initialSuffixPaths;
-    if (select == null){
+    if (select == null) {
       LOG.warn(WARNING_NO_SUFFIX_PATHS);
       return operator;
     } else {
       initialSuffixPaths = select.getSuffixPaths();
-      if (initialSuffixPaths.isEmpty()){
+      if (initialSuffixPaths.isEmpty()) {
         LOG.warn(WARNING_NO_SUFFIX_PATHS);
         return operator;
       }
@@ -105,28 +105,30 @@ public class ConcatPathOptimizer implements ILogicalOptimizer {
     return sfwOperator;
   }
 
-  private List<Path> judgeSelectOperator(SelectOperator selectOperator) throws LogicalOptimizeException {
+  private List<Path> judgeSelectOperator(SelectOperator selectOperator)
+      throws LogicalOptimizeException {
     List<Path> suffixPaths;
-    if (selectOperator == null){
+    if (selectOperator == null) {
       throw new LogicalOptimizeException(WARNING_NO_SUFFIX_PATHS);
     } else {
       suffixPaths = selectOperator.getSuffixPaths();
-      if (suffixPaths.isEmpty()){
+      if (suffixPaths.isEmpty()) {
         throw new LogicalOptimizeException(WARNING_NO_SUFFIX_PATHS);
       }
     }
     return suffixPaths;
   }
 
-  private void checkAggrOfSelectOperator(SelectOperator selectOperator) throws LogicalOptimizeException {
+  private void checkAggrOfSelectOperator(SelectOperator selectOperator)
+      throws LogicalOptimizeException {
     if (!selectOperator.getAggregations().isEmpty()
-            && selectOperator.getSuffixPaths().size() != selectOperator.getAggregations().size()) {
+        && selectOperator.getSuffixPaths().size() != selectOperator.getAggregations().size()) {
       throw new LogicalOptimizeException(
-              "Common queries and aggregated queries are not allowed to appear at the same time");
+          "Common queries and aggregated queries are not allowed to appear at the same time");
     }
   }
 
-  private void extendListSafely(List<String> source, int index, List<String> target){
+  private void extendListSafely(List<String> source, int index, List<String> target) {
     if (source != null && !source.isEmpty()) {
       target.add(source.get(index));
     }
@@ -164,10 +166,10 @@ public class ConcatPathOptimizer implements ILogicalOptimizer {
     removeStarsInPath(allPaths, afterConcatAggregations, selectOperator);
   }
 
-  private boolean isWithStar(List<Path> suffixPaths, List<Path> prefixPaths, List<Path> fakePaths){
+  private boolean isWithStar(List<Path> suffixPaths, List<Path> prefixPaths, List<Path> fakePaths) {
     boolean isWithStar = false;
     for (Iterator<Path> iterSuffix = suffixPaths.iterator();
-         iterSuffix.hasNext() && !isWithStar; ) {
+        iterSuffix.hasNext() && !isWithStar; ) {
       // NOTE the traversal order should keep consistent with that of the `transformedPaths`
       Path suffixPath = iterSuffix.next();
       if (suffixPath.getFullPath().contains("*")) {
index a7ae618..18646c9 100644 (file)
@@ -33,7 +33,7 @@ import org.slf4j.LoggerFactory;
 
 public class RemoveNotOptimizer implements IFilterOptimizer {
 
-  private static final Logger LOG = LoggerFactory.getLogger(RemoveNotOptimizer.class);
+  private static final Logger logger = LoggerFactory.getLogger(RemoveNotOptimizer.class);
 
   /**
    * get DNF(disjunctive normal form) for this filter operator tree. Before getDNF, this op tree
@@ -81,7 +81,7 @@ public class RemoveNotOptimizer implements IFilterOptimizer {
       try {
         ((BasicFunctionOperator) filter).setReversedTokenIntType();
       } catch (LogicalOperatorException e) {
-        LOG.error("meet error while converting BasicFunction.", e);
+        logger.error("meet error while converting BasicFunction.", e);
         throw new LogicalOperatorException(
             "convert BasicFuntion to reserved meet failed: previous token:"
                 + tokenInt + "tokenName:" + SQLConstant.tokenNames.get(tokenInt));
index 86230e3..6e3c8bd 100644 (file)
@@ -47,8 +47,8 @@ public class FileReaderManager implements IService {
   private static final int MAX_CACHED_FILE_SIZE = 30000;
 
   /**
-   * the key of fileReaderMap is the file path and the value of fileReaderMap is
-   * the corresponding reader.
+   * the key of fileReaderMap is the file path and the value of fileReaderMap is the corresponding
+   * reader.
    */
   private ConcurrentHashMap<String, TsFileSequenceReader> fileReaderMap;
 
@@ -100,6 +100,7 @@ public class FileReaderManager implements IService {
   /**
    * Get the reader of the file(tsfile or unseq tsfile) indicated by filePath. If the reader already
    * exists, just get it from fileReaderMap. Otherwise a new reader will be created.
+   *
    * @param filePath the path of the file, of which the reader is desired.
    * @param isUnClosed whether the corresponding file still receives insertions or not.
    * @return the reader of the file specified by filePath.
@@ -152,8 +153,8 @@ public class FileReaderManager implements IService {
   }
 
   /**
-   * Only for <code>EnvironmentUtils.cleanEnv</code> method. To make sure that unit tests
-   * and integration tests will not conflict with each other.
+   * Only for <code>EnvironmentUtils.cleanEnv</code> method. To make sure that unit tests and
+   * integration tests will not conflict with each other.
    */
   public synchronized void closeAndRemoveAllOpenedReaders() throws IOException {
     for (Map.Entry<String, TsFileSequenceReader> entry : fileReaderMap.entrySet()) {
@@ -196,8 +197,10 @@ public class FileReaderManager implements IService {
   }
 
   private static class FileReaderManagerHelper {
+
     private static final FileReaderManager INSTANCE = new FileReaderManager();
 
-    private FileReaderManagerHelper(){ }
+    private FileReaderManagerHelper() {
+    }
   }
 }
\ No newline at end of file
index d727ba3..e304675 100644 (file)
@@ -171,6 +171,7 @@ public class QueryTokenManager {
 \r
     private static final QueryTokenManager INSTANCE = new QueryTokenManager();\r
 \r
-    private QueryTokenManagerHelper(){}\r
+    private QueryTokenManagerHelper() {\r
+    }\r
   }\r
 }\r
index 813bbd6..86d36dc 100644 (file)
@@ -69,9 +69,9 @@ public class EngineExecutorWithTimeGenerator {
     EngineTimeGenerator timestampGenerator;
     List<EngineReaderByTimeStamp> readersOfSelectedSeries;
     try {
-       timestampGenerator = new EngineTimeGenerator(jobId, queryExpression.getExpression());
-       readersOfSelectedSeries = getReadersOfSelectedPaths(queryExpression.getSelectedSeries());
-    } catch (IOException ex){
+      timestampGenerator = new EngineTimeGenerator(jobId, queryExpression.getExpression());
+      readersOfSelectedSeries = getReadersOfSelectedPaths(queryExpression.getSelectedSeries());
+    } catch (IOException ex) {
       throw new FileNodeManagerException(ex);
     }
 
index 2c8b315..5742fcc 100644 (file)
@@ -84,7 +84,7 @@ public class EngineExecutorWithoutTimeGenerator {
       try {
         tsFilesReader = new SequenceDataReader(queryDataSource.getSeqDataSource(),
             timeFilter);
-        priorityReader.addReaderWithPriority(tsFilesReader, 1);
+        priorityReader.addReaderWithPriority(tsFilesReader, PriorityMergeReader.LOW_PRIORITY);
       } catch (IOException e) {
         throw new FileNodeManagerException(e);
       }
@@ -94,7 +94,7 @@ public class EngineExecutorWithoutTimeGenerator {
       try {
         unSeqMergeReader = SeriesReaderFactory.getInstance()
             .createUnSeqMergeReader(queryDataSource.getOverflowSeriesDataSource(), timeFilter);
-        priorityReader.addReaderWithPriority(unSeqMergeReader, 2);
+        priorityReader.addReaderWithPriority(unSeqMergeReader, PriorityMergeReader.HIGH_PRIORITY);
       } catch (IOException e) {
         throw new FileNodeManagerException(e);
       }
index 4f1fe42..8062172 100644 (file)
@@ -171,6 +171,7 @@ public class SeriesReaderFactory {
 
     private static final SeriesReaderFactory INSTANCE = new SeriesReaderFactory();
 
-    private SeriesReaderFactoryHelper(){}
+    private SeriesReaderFactoryHelper() {
+    }
   }
 }
\ No newline at end of file
index a10c72e..e100e50 100644 (file)
@@ -35,6 +35,9 @@ import org.apache.iotdb.tsfile.read.common.BatchData;
  */
 public class PriorityMergeReader implements IReader {
 
+  public static final int LOW_PRIORITY = 1;
+  public static final int HIGH_PRIORITY = 2;
+
   private List<IReader> readerList = new ArrayList<>();
   private List<Integer> priorityList = new ArrayList<>();
   private PriorityQueue<Element> heap = new PriorityQueue<>();