From 06b8be19f8f0dcccf099342b1e0f0ed2f63b2d74 Mon Sep 17 00:00:00 2001 From: Arvid Heise Date: Mon, 21 Aug 2017 16:00:03 +0200 Subject: [PATCH] Adding bug to be caught by sonar --- src/main/java/com/bakdata/ignite/hbase/HBaseCacheStore.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/bakdata/ignite/hbase/HBaseCacheStore.java b/src/main/java/com/bakdata/ignite/hbase/HBaseCacheStore.java index 860f69e..024063f 100644 --- a/src/main/java/com/bakdata/ignite/hbase/HBaseCacheStore.java +++ b/src/main/java/com/bakdata/ignite/hbase/HBaseCacheStore.java @@ -15,6 +15,7 @@ import java.util.stream.Collectors; import java.util.stream.Stream; import java.util.stream.StreamSupport; +import javax.annotation.Nonnull; import javax.cache.Cache.Entry; import javax.cache.CacheException; import javax.cache.integration.CacheLoaderException; @@ -123,7 +124,7 @@ public Map loadAll(Iterable keys) throws CacheLoaderException */ @Override public void loadCache(IgniteBiInClosure clo, Object... args) throws CacheLoaderException { - Scan scan = createScan(args); + Scan scan = null;//createScan(args); Map values = scan(scan); values.forEach(clo::apply); } @@ -254,7 +255,7 @@ private Scan createScan(Object[] args) { return scan; } - private Map scan(Scan scan) { + private Map scan(@Nonnull Scan scan) { try (ResultScanner scanner = table().getScanner(scan)) { return resultsToMap(scanner); } catch (IOException | IllegalStateException e) {