From 1e359135790a7db020df75502134cefce2a19391 Mon Sep 17 00:00:00 2001 From: Eric Tschetter Date: Tue, 27 Nov 2012 11:12:28 -0600 Subject: [PATCH] 1) add a log line on plumber creation to make it easier to know what rejection policy is being used. --- .../druid/realtime/RealtimePlumberSchool.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/realtime/src/main/java/com/metamx/druid/realtime/RealtimePlumberSchool.java b/realtime/src/main/java/com/metamx/druid/realtime/RealtimePlumberSchool.java index c119b2c12e0..1be9ea6ca93 100644 --- a/realtime/src/main/java/com/metamx/druid/realtime/RealtimePlumberSchool.java +++ b/realtime/src/main/java/com/metamx/druid/realtime/RealtimePlumberSchool.java @@ -242,6 +242,7 @@ public class RealtimePlumberSchool implements PlumberSchool final long truncatedNow = segmentGranularity.truncate(new DateTime()).getMillis(); final long windowMillis = windowPeriod.toStandardDuration().getMillis(); final RejectionPolicy rejectionPolicy = rejectionPolicyFactory.create(windowPeriod); + log.info("Creating plumber using rejectionPolicy[%s]", rejectionPolicy); log.info( "Expect to run at [%s]", @@ -553,7 +554,7 @@ public class RealtimePlumberSchool implements PlumberSchool public class ServerTimeRejectionPolicyFactory implements RejectionPolicyFactory { @Override - public RejectionPolicy create(Period windowPeriod) + public RejectionPolicy create(final Period windowPeriod) { final long windowMillis = windowPeriod.toStandardDuration().getMillis(); @@ -570,6 +571,12 @@ public class RealtimePlumberSchool implements PlumberSchool { return timestamp >= (System.currentTimeMillis() - windowMillis); } + + @Override + public String toString() + { + return String.format("serverTime-%s", windowPeriod); + } }; } } @@ -577,7 +584,7 @@ public class RealtimePlumberSchool implements PlumberSchool public class MessageTimeRejectionPolicyFactory implements RejectionPolicyFactory { @Override - public RejectionPolicy create(Period windowPeriod) + public RejectionPolicy create(final Period windowPeriod) { final long windowMillis = windowPeriod.toStandardDuration().getMillis(); @@ -598,6 +605,12 @@ public class RealtimePlumberSchool implements PlumberSchool return timestamp >= (maxTimestamp - windowMillis); } + + @Override + public String toString() + { + return String.format("messageTime-%s", windowPeriod); + } }; } }