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/fluo.git
The following commit(s) were added to refs/heads/master by this push: new c128be9 Identify nofification scan as type in execution hint #1055 (#1072) c128be9 is described below commit c128be9479f675f62992f99f53e892bd0e011c5a Author: Keith Turner <ktur...@apache.org> AuthorDate: Thu Feb 21 11:24:20 2019 -0500 Identify nofification scan as type in execution hint #1055 (#1072) --- .../main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java index 1a47f2a..e10b29b 100644 --- a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java +++ b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java @@ -57,6 +57,9 @@ public class ScanTask implements Runnable { private long minSleepTime; private long maxSleepTime; + private static final Map<String, String> SCAN_EXEC_HINTS = + Collections.singletonMap("scan_type", "fluo-ntfy"); + ScanTask(NotificationFinder finder, NotificationProcessor proccessor, PartitionManager partitionManager, Environment env, AtomicBoolean stopped, long minSleepTime, long maxSleepTime) { @@ -191,6 +194,8 @@ public class ScanTask implements Runnable { NotificationHashFilter.setModulusParams(iterCfg, pi.getMyGroupSize(), pi.getMyIdInGroup()); scanner.addScanIterator(iterCfg); + scanner.setExecutionHints(SCAN_EXEC_HINTS); + ScanCounts counts = new ScanCounts(); for (Entry<Key, Value> entry : scanner) {