You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluo.apache.org by kt...@apache.org on 2019/02/21 16:24:25 UTC
[fluo] branch master updated: Identify nofification scan as type in
execution hint #1055 (#1072)
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 <kt...@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) {