com.google.common.collect.Maps



Project amplab/tachyon in file ...d/core.src.main.java.tachyon.master.Operation.java (2014-07-06)
@@ -19,7 +19,6 @@ import java.util.Map;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.google.common.base.Objects;
-import com.google.common.collect.Maps;
 
 /**
  * Each entry in the EditLog is represented as a single Operation, which is serialized as JSON.
@@ -29,7 +28,6 @@ class Operation extends JsonObject {
   // NB: These type names are used in the serialized JSON. They should be concise but readable.
   public OperationType type;
   public long transId;
-  public Map<String, Object> parameters = Maps.newHashMap();
 
   public Operation(OperationType type, long transId) {
     this.type = type;
Project druid-io/druid in file ...ry.datasourcemetadata.DataSourceMetadataQuery.java (2015-02-03)
@@ -22,7 +22,6 @@ package io.druid.query.datasourcemetadata;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
 import io.druid.common.utils.JodaUtils;
 import io.druid.query.BaseQuery;
 import io.druid.query.DataSource;
@@ -45,9 +44,6 @@ public class DataSourceMetadataQuery extends BaseQuery<Result<DataSourceMetadata
       JodaUtils.MIN_INSTANT, JodaUtils.MAX_INSTANT
   );
 
-  public static String MAX_INGESTED_EVENT_TIME = "maxIngestedEventTime";
-
-
   @JsonCreator
   public DataSourceMetadataQuery(
       @JsonProperty("dataSource") DataSource dataSource,
Project metamx/druid in file ...ry.datasourcemetadata.DataSourceMetadataQuery.java (2015-02-03)
@@ -22,7 +22,6 @@ package io.druid.query.datasourcemetadata;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
 import io.druid.common.utils.JodaUtils;
 import io.druid.query.BaseQuery;
 import io.druid.query.DataSource;
@@ -45,9 +44,6 @@ public class DataSourceMetadataQuery extends BaseQuery<Result<DataSourceMetadata
       JodaUtils.MIN_INSTANT, JodaUtils.MAX_INSTANT
   );
 
-  public static String MAX_INGESTED_EVENT_TIME = "maxIngestedEventTime";
-
-
   @JsonCreator
   public DataSourceMetadataQuery(
       @JsonProperty("dataSource") DataSource dataSource,
Project Graylog2/graylog2-server in file ....src.main.java.org.graylog2.indexer.Deflector.java (2014-09-23)
@@ -18,7 +18,6 @@ package org.graylog2.indexer;
 
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
 import org.elasticsearch.action.admin.indices.stats.IndexStats;
 import org.elasticsearch.indices.InvalidAliasNameException;
 import org.graylog2.Configuration;
@@ -65,7 +64,7 @@ public class Deflector { // extends Ablenkblech
                      final RebuildIndexRangesJob.Factory rebuildIndexRangesJobFactory,
                      final OptimizeIndexJob.Factory optimizeIndexJobFactory,
                      final Indices indices) {
-        indexPrefix = configuration.getElasticSearchIndexPrefix() + SEPARATOR;
+        indexPrefix = configuration.getElasticSearchIndexPrefix();
 
         this.systemJobManager = systemJobManager;
         this.activityWriter = activityWriter;
Project druid-io/druid in file ...mx.druid.realtime.firehose.IrcFirehoseFactory.java (2013-08-14)
@@ -3,7 +3,6 @@ package com.metamx.druid.realtime.firehose;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
 import com.ircclouds.irc.api.Callback;
 import com.ircclouds.irc.api.IRCApi;
 import com.ircclouds.irc.api.IRCApiImpl;
@@ -90,7 +89,7 @@ public class IrcFirehoseFactory implements FirehoseFactory
       public void onChannelMessage(ChannelPrivMsg aMsg)
       {
         try {
-          queue.put(Pair.of(new DateTime(), aMsg));
+          queue.put(Pair.of(DateTime.now(), aMsg));
         } catch(InterruptedException e) {
           throw new RuntimeException("interrupted adding message to queue", e);
         }