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 <[email protected]> Authored: Wed Nov 23 13:55:50 2016 +0530 Committer: bhupeshchawda <[email protected]> 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
