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) {