From 867dedfe1bd1f51fca89766dad63b2a15ff1025f Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Mon, 22 Jul 2013 22:40:18 -0700 Subject: [PATCH] Remove unused class --- .../IntervalRejectionPolicyFactory.java | 42 ------------------- 1 file changed, 42 deletions(-) delete mode 100644 realtime/src/main/java/com/metamx/druid/realtime/plumber/IntervalRejectionPolicyFactory.java diff --git a/realtime/src/main/java/com/metamx/druid/realtime/plumber/IntervalRejectionPolicyFactory.java b/realtime/src/main/java/com/metamx/druid/realtime/plumber/IntervalRejectionPolicyFactory.java deleted file mode 100644 index c13a03dafb1..00000000000 --- a/realtime/src/main/java/com/metamx/druid/realtime/plumber/IntervalRejectionPolicyFactory.java +++ /dev/null @@ -1,42 +0,0 @@ -package com.metamx.druid.realtime.plumber; - -import org.joda.time.DateTime; -import org.joda.time.Interval; -import org.joda.time.Period; - -/** - */ -public class IntervalRejectionPolicyFactory implements RejectionPolicyFactory -{ - private final Interval interval; - - public IntervalRejectionPolicyFactory(Interval interval) - { - this.interval = interval; - } - - @Override - public RejectionPolicy create(Period windowPeriod) - { - return new RejectionPolicy() - { - @Override - public DateTime getCurrMaxTime() - { - return new DateTime(); - } - - @Override - public boolean accept(long timestamp) - { - return interval.contains(timestamp); - } - - @Override - public String toString() - { - return String.format("interval-%s", interval); - } - }; - } -}