Identify nofification scan as type in execution hint apache#1055

keith-turner · Feb 19, 2019 · 1f30731 · 1f30731
1 parent 282b94e
commit 1f30731
Showing 1 changed file with 5 additions and 0 deletions.
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
@@ -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 @@ private ScanCounts scan(Session session, PartitionInfo pi, Range range)
       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) {