You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ra...@apache.org on 2016/09/27 02:12:59 UTC
[2/2] incubator-eagle git commit: [FIX] update joiner from storm to
google library
[FIX] update joiner from storm to google library
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/ad6a5349
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/ad6a5349
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/ad6a5349
Branch: refs/heads/master
Commit: ad6a53490fcf3cf725c1cf4b842b7db0ca40716d
Parents: 2fcb221
Author: Xiancheng Li <xi...@ebay.com>
Authored: Tue Sep 27 09:52:30 2016 +0800
Committer: Ralph, Su <su...@gmail.com>
Committed: Mon Sep 26 19:12:39 2016 -0700
----------------------------------------------------------------------
.../evaluator/nodata/NoDataPolicyTimeBatchHandler.java | 12 +++++++++---
.../eagle/alert/engine/publisher/impl/EventUniq.java | 3 ++-
2 files changed, 11 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/ad6a5349/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/evaluator/nodata/NoDataPolicyTimeBatchHandler.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/evaluator/nodata/NoDataPolicyTimeBatchHandler.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/evaluator/nodata/NoDataPolicyTimeBatchHandler.java
index e2c70a4..b1e32bd 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/evaluator/nodata/NoDataPolicyTimeBatchHandler.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/evaluator/nodata/NoDataPolicyTimeBatchHandler.java
@@ -16,6 +16,14 @@
*/
package org.apache.eagle.alert.engine.evaluator.nodata;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.commons.collections.CollectionUtils;
import org.apache.eagle.alert.engine.Collector;
import org.apache.eagle.alert.engine.coordinator.PolicyDefinition;
import org.apache.eagle.alert.engine.coordinator.StreamDefinition;
@@ -24,13 +32,11 @@ import org.apache.eagle.alert.engine.evaluator.PolicyStreamHandler;
import org.apache.eagle.alert.engine.model.AlertStreamEvent;
import org.apache.eagle.alert.engine.model.StreamEvent;
import org.apache.eagle.alert.utils.TimePeriodUtils;
-import org.apache.commons.collections.CollectionUtils;
-import org.apache.storm.guava.base.Joiner;
import org.joda.time.Period;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.*;
+import com.google.common.base.Joiner;
public class NoDataPolicyTimeBatchHandler implements PolicyStreamHandler {
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/ad6a5349/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/EventUniq.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/EventUniq.java b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/EventUniq.java
index 2a71411..511abcd 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/EventUniq.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/EventUniq.java
@@ -21,7 +21,8 @@
package org.apache.eagle.alert.engine.publisher.impl;
import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.apache.storm.guava.base.Joiner;
+
+import com.google.common.base.Joiner;
import java.util.HashMap;