indexData = new ArrayList<>();
BufferedReader indexFileReader = null;
try {
- indexFileReader =
- new BufferedReader(new FileReader(new File(STORAGE_BASE_PATH, DATA_FILE_INDEX_FILE_NAME)));
+ indexFileReader = new BufferedReader(new FileReader(new File(STORAGE_BASE_PATH, DATA_FILE_INDEX_FILE_NAME)));
String indexDataStr = null;
while ((indexDataStr = indexFileReader.readLine()) != null) {
indexData.add(Long.parseLong(indexDataStr));
diff --git a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/block/index/L1Cache.java b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/block/index/L1Cache.java
index f8f9a3e65518eabb4e1cf32832ede7cda5a7d8dd..4f2281e736c483df913b397c238dda1722a2d2ed 100644
--- a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/block/index/L1Cache.java
+++ b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/block/index/L1Cache.java
@@ -1,7 +1,7 @@
package com.a.eye.skywalking.storage.block.index;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
+import com.a.eye.skywalking.logging.api.ILog;
+import com.a.eye.skywalking.logging.api.LogManager;
import java.util.List;
import java.util.TreeSet;
@@ -11,13 +11,13 @@ import java.util.concurrent.locks.ReentrantReadWriteLock;
/**
* 块索引的一级缓存
- *
+ *
* Created by xin on 2016/11/2.
*/
public class L1Cache {
private static final int MAX_DATA_KEEP_SIZE = 30;
- private static Logger logger = LogManager.getLogger(L1Cache.class);
+ private static ILog logger = LogManager.getLogger(L1Cache.class);
private TreeSet cacheData = new TreeSet();
private final ReadWriteLock updateLock = new ReentrantReadWriteLock();
diff --git a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/IndexDataCapacityMonitor.java b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/IndexDataCapacityMonitor.java
index 608ee39afe6421758b5e35699409f74576e2d457..066c096199f0f51c4c6c84e42550bd62ab6af4d4 100644
--- a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/IndexDataCapacityMonitor.java
+++ b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/IndexDataCapacityMonitor.java
@@ -1,10 +1,9 @@
package com.a.eye.skywalking.storage.data;
+import com.a.eye.skywalking.logging.api.ILog;
+import com.a.eye.skywalking.logging.api.LogManager;
import com.a.eye.skywalking.storage.block.index.BlockIndexEngine;
import com.a.eye.skywalking.storage.data.index.IndexDBConnector;
-import org.apache.jute.Index;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
import java.sql.SQLException;
import java.util.concurrent.atomic.AtomicLong;
@@ -16,7 +15,7 @@ import static com.a.eye.skywalking.storage.config.Config.DataIndex.MAX_CAPACITY_
*/
public class IndexDataCapacityMonitor extends Thread {
- private static Logger logger = LogManager.getLogger(IndexDataCapacityMonitor.class);
+ private static ILog logger = LogManager.getLogger(IndexDataCapacityMonitor.class);
private static Detector detector;
public static void addIndexData(long timestamp, int size) {