From e7da31e42d8d7b96cbce5ecaeac0d43b723ffe98 Mon Sep 17 00:00:00 2001 From: Dhruv Parthasarathy Date: Mon, 8 Jul 2013 13:41:19 -0700 Subject: [PATCH] seems to be working --- .../webStream/WebFirehoseFactory.java | 21 ++++++++----------- 1 file changed, 9 insertions(+), 12 deletions(-) diff --git a/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java b/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java index 239e23b4acd..b2f65bb467e 100644 --- a/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java +++ b/examples/src/main/java/druid/examples/webStream/WebFirehoseFactory.java @@ -35,13 +35,11 @@ import org.joda.time.DateTime; import java.io.IOException; import java.util.ArrayList; -import java.util.List; import java.util.Map; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; -import java.util.concurrent.TimeUnit; @JsonTypeName("webstream") public class WebFirehoseFactory implements FirehoseFactory @@ -51,15 +49,14 @@ public class WebFirehoseFactory implements FirehoseFactory private final String url; private final String timeDimension; private final String newTimeDimension; - private final Map renamedDimensions; + private final Map renamedDimensions; private final String timeFormat; - private final long waitTime = 15L; @JsonCreator public WebFirehoseFactory( @JsonProperty("url") String url, - @JsonProperty("renamedDimensions") Map renamedDimensions, + @JsonProperty("renamedDimensions") Map renamedDimensions, @JsonProperty("timeDimension") String timeDimension, @JsonProperty("timeFormat") String timeFormat ) @@ -67,16 +64,16 @@ public class WebFirehoseFactory implements FirehoseFactory this.url = url; this.renamedDimensions = renamedDimensions; this.timeDimension = timeDimension; - if (renamedDimensions!=null){ - newTimeDimension=renamedDimensions.get(timeDimension); + if (renamedDimensions != null) { + newTimeDimension = renamedDimensions.get(timeDimension); } - else{ - newTimeDimension=timeDimension; + else { + newTimeDimension = timeDimension; } - if (timeFormat==null){ - this.timeFormat="auto"; + if (timeFormat == null) { + this.timeFormat = "auto"; } - else{ + else { this.timeFormat = timeFormat; } }