You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2016/11/23 12:16:51 UTC
apex-malhar git commit: APEXMALHAR-2353 Made timeExpression as
@NotNull
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 <bh...@apache.org>
Authored: Wed Nov 23 13:55:50 2016 +0530
Committer: bhupeshchawda <bh...@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