You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2020/01/02 20:37:02 UTC
[accumulo] 02/02: Use lambdas in WAL existence cache (#1462)
This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit 01b8f29e4fbe42c85ddd260c59e2c196ec65c222
Author: Keith Turner <kt...@apache.org>
AuthorDate: Thu Jan 2 15:33:53 2020 -0500
Use lambdas in WAL existence cache (#1462)
---
.../apache/accumulo/master/recovery/RecoveryManager.java | 16 ++--------------
1 file changed, 2 insertions(+), 14 deletions(-)
diff --git a/server/master/src/main/java/org/apache/accumulo/master/recovery/RecoveryManager.java b/server/master/src/main/java/org/apache/accumulo/master/recovery/RecoveryManager.java
index f380778..30c597b 100644
--- a/server/master/src/main/java/org/apache/accumulo/master/recovery/RecoveryManager.java
+++ b/server/master/src/main/java/org/apache/accumulo/master/recovery/RecoveryManager.java
@@ -28,7 +28,6 @@ import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
@@ -56,7 +55,6 @@ import org.slf4j.LoggerFactory;
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
-import com.google.common.cache.Weigher;
public class RecoveryManager {
@@ -74,12 +72,7 @@ public class RecoveryManager {
this.master = master;
existenceCache =
CacheBuilder.newBuilder().expireAfterWrite(timeToCacheExistsInMillis, TimeUnit.MILLISECONDS)
- .maximumWeight(10_000_000).weigher(new Weigher<Path,Boolean>() {
- @Override
- public int weigh(Path path, Boolean exist) {
- return path.toString().length();
- }
- }).build();
+ .maximumWeight(10_000_000).weigher((path, exist) -> path.toString().length()).build();
executor = Executors.newScheduledThreadPool(4, new NamingThreadFactory("Walog sort starter "));
zooCache = new ZooCache(master.getContext().getZooReaderWriter(), null);
@@ -150,12 +143,7 @@ public class RecoveryManager {
private boolean exists(final Path path) throws IOException {
try {
- return existenceCache.get(path, new Callable<Boolean>() {
- @Override
- public Boolean call() throws Exception {
- return master.getFileSystem().exists(path);
- }
- });
+ return existenceCache.get(path, () -> master.getFileSystem().exists(path));
} catch (ExecutionException e) {
throw new IOException(e);
}