[fluo] branch master updated: Identify nofification scan as type in execution hint #1055 (#1072)

[kturner]

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