apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chin...@apache.org
Subject apex-malhar git commit: APEXMALHAR-2353 Made timeExpression as @NotNull
Date Wed, 23 Nov 2016 12:16:51 GMT
Repository: apex-malhar
Updated Branches:
  refs/heads/master 645d9d1fc -> f617d5e35


APEXMALHAR-2353 Made timeExpression as @NotNull


Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/f617d5e3
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/f617d5e3
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/f617d5e3

Branch: refs/heads/master
Commit: f617d5e35b08412bcee8fdf0a40e0bc4d317329a
Parents: 645d9d1
Author: bhupeshchawda <bhupesh@apache.org>
Authored: Wed Nov 23 13:55:50 2016 +0530
Committer: bhupeshchawda <bhupesh@apache.org>
Committed: Wed Nov 23 13:55:50 2016 +0530

----------------------------------------------------------------------
 .../apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java   | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/f617d5e3/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
b/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
index 172a957..3f888cc 100644
--- a/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
+++ b/library/src/main/java/org/apache/apex/malhar/lib/dedup/TimeBasedDedupOperator.java
@@ -82,6 +82,7 @@ public class TimeBasedDedupOperator extends AbstractDeduper<Object>
implements A
   @NotNull
   private String keyExpression;
 
+  @NotNull
   private String timeExpression;
 
   @NotNull
@@ -132,10 +133,7 @@ public class TimeBasedDedupOperator extends AbstractDeduper<Object>
implements A
   @Override
   protected long getTime(Object tuple)
   {
-    if (timeGetter != null) {
-      return timeGetter.get(tuple);
-    }
-    return System.currentTimeMillis();
+    return timeGetter.get(tuple);
   }
 
   @Override


Mime
View raw message