Update to guice 4.0

common/src/main/java/io/druid/guice/DruidSecondaryModule.java

@@ -72,14 +72,14 @@ public void configure(Binder binder)
   }
 
   @Provides @LazySingleton @Json
-  public ObjectMapper getJsonMapper(final Injector injector)
+  public final ObjectMapper getJsonMapper(final Injector injector)
   {
     setupJackson(injector, jsonMapper);
     return jsonMapper;
   }
 
   @Provides @LazySingleton @Smile
-  public ObjectMapper getSmileMapper(Injector injector)
+  public final ObjectMapper getSmileMapper(Injector injector)
   {
     setupJackson(injector, smileMapper);
     return smileMapper;

common/src/main/java/io/druid/guice/JacksonConfigManagerModule.java

@@ -40,7 +40,7 @@ public void configure(Binder binder)
   }
 
   @Provides @ManageLifecycle
-  public ConfigManager getConfigManager(
+  public final ConfigManager getConfigManager(
       final MetadataStorageConnector dbConnector,
       final Supplier<MetadataStorageTablesConfig> dbTables,
       final Supplier<ConfigManagerConfig> config,

extensions/azure-extensions/src/main/java/io/druid/storage/azure/AzureStorageDruidModule.java

@@ -98,7 +98,7 @@ public void configure(Binder binder)
 
   @Provides
   @LazySingleton
-  public CloudBlobClient getCloudBlobClient(final AzureAccountConfig config)
+  public final CloudBlobClient getCloudBlobClient(final AzureAccountConfig config)
       throws URISyntaxException, InvalidKeyException
   {
     CloudStorageAccount account = CloudStorageAccount.parse(
@@ -115,7 +115,7 @@ public CloudBlobClient getCloudBlobClient(final AzureAccountConfig config)
 
   @Provides
   @LazySingleton
-  public AzureStorage getAzureStorageContainer(
+  public final AzureStorage getAzureStorageContainer(
       final CloudBlobClient cloudBlobClient
   )
   {

extensions/kafka-extraction-namespace/src/main/java/io/druid/server/namespace/KafkaExtractionNamespaceModule.java

@@ -71,7 +71,15 @@ public void setupModule(SetupContext setupContext)
   @Provides
   @Named("renameKafkaProperties")
   @LazySingleton
-  public Properties getProperties(
+  public final Properties getProperties(
+      @Json ObjectMapper mapper,
+      Properties systemProperties
+  ){
+    return getPropertiesInner(mapper, systemProperties);
+  }
+
+  // Protected for use in unit tests
+  protected Properties getPropertiesInner(
       @Json ObjectMapper mapper,
       Properties systemProperties
   )
@@ -98,7 +106,7 @@ public Properties getProperties(
 
   @Provides
   @LazySingleton
-  public KafkaExtractionNamespaceFactory factoryFactory(
+  public final KafkaExtractionNamespaceFactory factoryFactory(
       KafkaExtractionManager kafkaManager
   )
   {

extensions/kafka-extraction-namespace/src/test/java/io/druid/query/extraction/namespace/TestKafkaExtractionCluster.java

@@ -31,9 +31,6 @@
 import com.google.inject.Module;
 import com.google.inject.Provider;
 import com.google.inject.TypeLiteral;
-import com.google.inject.multibindings.MapBinder;
-import com.google.inject.multibindings.Multibinder;
-import com.google.inject.name.Named;
 import com.google.inject.name.Names;
 import com.metamx.common.ISE;
 import com.metamx.common.StringUtils;
@@ -58,10 +55,6 @@
 import org.I0Itec.zkclient.ZkClient;
 import org.apache.commons.io.FileUtils;
 import org.apache.curator.test.TestingServer;
-import org.apache.log4j.BasicConfigurator;
-import org.apache.log4j.ConsoleAppender;
-import org.apache.log4j.Level;
-import org.apache.log4j.PatternLayout;
 import org.apache.zookeeper.CreateMode;
 import org.joda.time.DateTime;
 import org.junit.AfterClass;
@@ -97,16 +90,18 @@ public class TestKafkaExtractionCluster
   private static Injector injector;
 
 
-
   public static class KafkaFactoryProvider implements Provider<ExtractionNamespaceFunctionFactory<?>>
   {
     private final KafkaExtractionManager kafkaExtractionManager;
+
     @Inject
     public KafkaFactoryProvider(
         KafkaExtractionManager kafkaExtractionManager
-    ){
+    )
+    {
       this.kafkaExtractionManager = kafkaExtractionManager;
     }
+
     @Override
     public ExtractionNamespaceFunctionFactory<?> get()
     {
@@ -222,6 +217,10 @@ public void sleep(long ms)
     }
 
     System.setProperty("druid.extensions.searchCurrentClassloader", "false");
+    final Properties consumerProperties = new Properties(kafkaProperties);
+    consumerProperties.put("zookeeper.connect", zkTestServer.getConnectString() + "/kafka");
+    consumerProperties.put("zookeeper.session.timeout.ms", "10000");
+    consumerProperties.put("zookeeper.sync.time.ms", "200");
 
     injector = Initialization.makeInjectorWithModules(
         GuiceInjectors.makeStartupInjectorWithModules(
@@ -239,15 +238,11 @@ public void configure(Binder binder)
             new KafkaExtractionNamespaceModule()
             {
               @Override
-              public Properties getProperties(
+              protected Properties getPropertiesInner(
                   @Json ObjectMapper mapper,
                   Properties systemProperties
               )
               {
-                final Properties consumerProperties = new Properties(kafkaProperties);
-                consumerProperties.put("zookeeper.connect", zkTestServer.getConnectString() + "/kafka");
-                consumerProperties.put("zookeeper.session.timeout.ms", "10000");
-                consumerProperties.put("zookeeper.sync.time.ms", "200");
                 return consumerProperties;
               }
             }
@@ -287,7 +282,8 @@ public static void closeStatic() throws IOException
       if (zkClient.exists("/kafka")) {
         try {
           zkClient.deleteRecursive("/kafka");
-        }catch(org.I0Itec.zkclient.exception.ZkException ex){
+        }
+        catch (org.I0Itec.zkclient.exception.ZkException ex) {
           log.warn(ex, "error deleting /kafka zk node");
         }
       }
@@ -296,12 +292,13 @@ public static void closeStatic() throws IOException
     if (null != zkTestServer) {
       zkTestServer.stop();
     }
-    if(tmpDir.exists()){
+    if (tmpDir.exists()) {
       FileUtils.deleteDirectory(tmpDir);
     }
   }
 
-  private static final Properties makeProducerProperties(){
+  private static final Properties makeProducerProperties()
+  {
     final Properties kafkaProducerProperties = new Properties();
     kafkaProducerProperties.putAll(kafkaProperties);
     kafkaProducerProperties.put(
@@ -327,7 +324,16 @@ public void testSimpleRename() throws InterruptedException
     final Producer<byte[], byte[]> producer = new Producer<byte[], byte[]>(new ProducerConfig(kafkaProducerProperties));
     try {
       checkServer();
-      final ConcurrentMap<String, Function<String, String>> fnFn = injector.getInstance(Key.get(new TypeLiteral<ConcurrentMap<String, Function<String, String>>>(){}, Names.named("namespaceExtractionFunctionCache")));
+      final ConcurrentMap<String, Function<String, String>> fnFn = injector.getInstance(
+          Key.get(
+              new TypeLiteral<ConcurrentMap<String, Function<String, String>>>()
+              {
+              },
+              Names.named(
+                  "namespaceExtractionFunctionCache"
+              )
+          )
+      );
       KafkaExtractionNamespace extractionNamespace = new KafkaExtractionNamespace(topicName, namespace);
 
       Assert.assertEquals(null, fnFn.get(extractionNamespace.getNamespace()).apply("foo"));

extensions/namespace-lookup/src/main/java/io/druid/server/namespace/NamespacedExtractionModule.java

@@ -164,22 +164,22 @@ public void configure(Binder binder)
   @Provides
   @Named("namespaceVersionMap")
   @LazySingleton
-  public ConcurrentMap<String, String> getVersionMap()
+  public final ConcurrentMap<String, String> getVersionMap()
   {
     return new ConcurrentHashMap<>();
   }
 
   @Provides
   @Named("namespaceExtractionFunctionCache")
-  public ConcurrentMap<String, Function<String, String>> getFnCache()
+  public final ConcurrentMap<String, Function<String, String>> getFnCache()
   {
     return fnCache;
   }
 
   @Provides
   @Named("dimExtractionNamespace")
   @LazySingleton
-  public Function<String, Function<String, String>> getFunctionMaker(
+  public final Function<String, Function<String, String>> getFunctionMaker(
       @Named("namespaceExtractionFunctionCache")
       final ConcurrentMap<String, Function<String, String>> fnCache
   )

extensions/s3-extensions/src/main/java/io/druid/storage/s3/S3StorageDruidModule.java

@@ -95,14 +95,14 @@ public void configure(Binder binder)
 
   @Provides
   @LazySingleton
-  public AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
+  public final AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
   {
     return AWSCredentialsUtils.defaultAWSCredentialsProviderChain(config);
   }
 
   @Provides
   @LazySingleton
-  public RestS3Service getRestS3Service(AWSCredentialsProvider provider)
+  public final RestS3Service getRestS3Service(AWSCredentialsProvider provider)
   {
     if(provider.getCredentials() instanceof com.amazonaws.auth.AWSSessionCredentials) {
       return new RestS3Service(new AWSSessionCredentialsAdapter(provider));

integration-tests/src/main/java/io/druid/testing/guice/DruidTestModule.java

@@ -44,7 +44,7 @@ public void configure(Binder binder)
 
   @Provides
   @LazySingleton
-  public ServiceEmitter getServiceEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
+  public final ServiceEmitter getServiceEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
   {
     return new ServiceEmitter("", "", new LoggingEmitter(config.get(), jsonMapper));
   }

pom.xml

@@ -69,11 +69,12 @@
         <apache.curator.version>2.8.0</apache.curator.version>
         <jetty.version>9.2.5.v20141112</jetty.version>
         <jersey.version>1.19</jersey.version>
-        <druid.api.version>0.3.9</druid.api.version>
+        <druid.api.version>0.3.10</druid.api.version>
         <jackson.version>2.4.4</jackson.version>
         <log4j.version>2.2</log4j.version>
         <slf4j.version>1.7.10</slf4j.version>
         <hadoop.compile.version>2.3.0</hadoop.compile.version>
+        <guice.version>4.0</guice.version>
     </properties>
 
     <modules>
@@ -235,17 +236,17 @@
             <dependency>
                 <groupId>com.google.inject</groupId>
                 <artifactId>guice</artifactId>
-                <version>4.0-beta</version>
+                <version>${guice.version}</version>
             </dependency>
             <dependency>
                 <groupId>com.google.inject.extensions</groupId>
                 <artifactId>guice-servlet</artifactId>
-                <version>4.0-beta</version>
+                <version>${guice.version}</version>
             </dependency>
             <dependency>
                 <groupId>com.google.inject.extensions</groupId>
                 <artifactId>guice-multibindings</artifactId>
-                <version>4.0-beta</version>
+                <version>${guice.version}</version>
             </dependency>
             <dependency>
                 <groupId>com.ibm.icu</groupId>

processing/src/main/java/io/druid/guice/ConfigModule.java

@@ -39,7 +39,7 @@ public void configure(Binder binder)
   }
 
   @Provides @LazySingleton
-  public ConfigurationObjectFactory makeFactory(Properties props)
+  public final ConfigurationObjectFactory makeFactory(Properties props)
   {
     return Config.createFactory(props);
   }

processing/src/main/java/io/druid/jackson/JacksonModule.java

@@ -39,13 +39,13 @@ public void configure(Binder binder)
   }
 
   @Provides @LazySingleton @Json
-  public ObjectMapper jsonMapper()
+  public final ObjectMapper jsonMapper()
   {
     return new DefaultObjectMapper();
   }
 
   @Provides @LazySingleton @Smile
-  public ObjectMapper smileMapper()
+  public final ObjectMapper smileMapper()
   {
     final SmileFactory smileFactory = new SmileFactory();
     smileFactory.configure(SmileGenerator.Feature.ENCODE_BINARY_AS_7BIT, false);

processing/src/test/java/io/druid/guice/MetadataStorageTablesConfigTest.java

@@ -52,7 +52,7 @@ public void configure(Binder binder)
 
           @Provides
           @LazySingleton
-          public ObjectMapper jsonMapper()
+          public final ObjectMapper jsonMapper()
           {
             return new DefaultObjectMapper();
           }

server/src/main/java/io/druid/curator/CuratorModule.java

@@ -45,7 +45,7 @@ public void configure(Binder binder)
   }
 
   @Provides @LazySingleton
-  public CuratorFramework makeCurator(CuratorConfig config, Lifecycle lifecycle) throws IOException
+  public final CuratorFramework makeCurator(CuratorConfig config, Lifecycle lifecycle) throws IOException
   {
     final CuratorFramework framework =
         CuratorFrameworkFactory.builder()

server/src/main/java/io/druid/curator/discovery/DiscoveryModule.java

@@ -145,7 +145,7 @@ public void configure(Binder binder)
   @Provides
   @LazySingleton
   @Named(NAME)
-  public CuratorServiceAnnouncer getServiceAnnouncer(
+  public final CuratorServiceAnnouncer getServiceAnnouncer(
       final CuratorServiceAnnouncer announcer,
       final Injector injector,
       final Set<KeyHolder<DruidNode>> nodesToAnnounce,
@@ -190,7 +190,7 @@ public void stop()
 
   @Provides
   @LazySingleton
-  public ServiceDiscovery<Void> getServiceDiscovery(
+  public final ServiceDiscovery<Void> getServiceDiscovery(
       CuratorFramework curator,
       CuratorDiscoveryConfig config,
       Lifecycle lifecycle
@@ -233,7 +233,7 @@ public void stop()
 
   @Provides
   @LazySingleton
-  public ServerDiscoveryFactory getServerDiscoveryFactory(
+  public final ServerDiscoveryFactory getServerDiscoveryFactory(
       ServiceDiscovery<Void> serviceDiscovery
   )
   {

server/src/main/java/io/druid/guice/AWSModule.java

@@ -38,14 +38,14 @@ public void configure(Binder binder)
 
   @Provides
   @LazySingleton
-  public AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
+  public final AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
   {
     return AWSCredentialsUtils.defaultAWSCredentialsProviderChain(config);
   }
 
   @Provides
   @LazySingleton
-  public AmazonEC2 getEc2Client(AWSCredentialsProvider credentials)
+  public final AmazonEC2 getEc2Client(AWSCredentialsProvider credentials)
   {
     return new AmazonEC2Client(credentials);
   }

server/src/main/java/io/druid/guice/AnnouncerModule.java

@@ -45,7 +45,7 @@ public void configure(Binder binder)
 
   @Provides
   @ManageLifecycle
-  public Announcer getAnnouncer(CuratorFramework curator)
+  public final Announcer getAnnouncer(CuratorFramework curator)
   {
     return new Announcer(curator, Execs.singleThreaded("Announcer-%s"));
   }

server/src/main/java/io/druid/guice/DruidProcessingModule.java

@@ -60,7 +60,7 @@ public void configure(Binder binder)
   @Provides
   @BackgroundCaching
   @LazySingleton
-  public ExecutorService getBackgroundExecutorService(
+  public final ExecutorService getBackgroundExecutorService(
       CacheConfig cacheConfig
   )
   {
@@ -81,7 +81,7 @@ public ExecutorService getBackgroundExecutorService(
   @Provides
   @Processing
   @ManageLifecycle
-  public ExecutorService getProcessingExecutorService(
+  public final ExecutorService getProcessingExecutorService(
       ExecutorServiceConfig config,
       ServiceEmitter emitter,
       Lifecycle lifecycle
@@ -100,7 +100,7 @@ public ExecutorService getProcessingExecutorService(
   @Provides
   @LazySingleton
   @Global
-  public StupidPool<ByteBuffer> getIntermediateResultsPool(DruidProcessingConfig config)
+  public final StupidPool<ByteBuffer> getIntermediateResultsPool(DruidProcessingConfig config)
   {
     try {
       long maxDirectMemory = VMUtils.getMaxDirectMemory();