Merge pull request #1628 from druid-io/revert-1608-guice40

Revert "Update to guice 4.0"

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

@@ -72,14 +72,14 @@ public class DruidSecondaryModule implements Module
   }
 
   @Provides @LazySingleton @Json
-  public final ObjectMapper getJsonMapper(final Injector injector)
+  public ObjectMapper getJsonMapper(final Injector injector)
   {
     setupJackson(injector, jsonMapper);
     return jsonMapper;
   }
 
   @Provides @LazySingleton @Smile
-  public final ObjectMapper getSmileMapper(Injector injector)
+  public ObjectMapper getSmileMapper(Injector injector)
   {
     setupJackson(injector, smileMapper);
     return smileMapper;

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

@@ -40,7 +40,7 @@ public class JacksonConfigManagerModule implements Module
   }
 
   @Provides @ManageLifecycle
-  public final ConfigManager getConfigManager(
+  public 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 class AzureStorageDruidModule implements DruidModule
 
   @Provides
   @LazySingleton
-  public final CloudBlobClient getCloudBlobClient(final AzureAccountConfig config)
+  public CloudBlobClient getCloudBlobClient(final AzureAccountConfig config)
       throws URISyntaxException, InvalidKeyException
   {
     CloudStorageAccount account = CloudStorageAccount.parse(
@@ -115,7 +115,7 @@ public class AzureStorageDruidModule implements DruidModule
 
   @Provides
   @LazySingleton
-  public final AzureStorage getAzureStorageContainer(
+  public AzureStorage getAzureStorageContainer(
       final CloudBlobClient cloudBlobClient
   )
   {

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

@@ -71,15 +71,7 @@ public class KafkaExtractionNamespaceModule implements DruidModule
   @Provides
   @Named("renameKafkaProperties")
   @LazySingleton
-  public final Properties getProperties(
+  public 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
   )
@@ -106,7 +98,7 @@ public class KafkaExtractionNamespaceModule implements DruidModule
 
   @Provides
   @LazySingleton
-  public final KafkaExtractionNamespaceFactory factoryFactory(
+  public KafkaExtractionNamespaceFactory factoryFactory(
       KafkaExtractionManager kafkaManager
   )
   {

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

@@ -31,6 +31,9 @@ import com.google.inject.Key;
 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;
@@ -55,6 +58,10 @@ import kafka.utils.ZKStringSerializer$;
 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;
@@ -90,18 +97,16 @@ 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()
     {
@@ -217,10 +222,6 @@ public class TestKafkaExtractionCluster
     }
 
     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(
@@ -238,11 +239,15 @@ public class TestKafkaExtractionCluster
             new KafkaExtractionNamespaceModule()
             {
               @Override
-              protected Properties getPropertiesInner(
+              public Properties getProperties(
                   @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;
               }
             }
@@ -282,8 +287,7 @@ public class TestKafkaExtractionCluster
       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");
         }
       }
@@ -292,13 +296,12 @@ public class TestKafkaExtractionCluster
     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(
@@ -324,16 +327,7 @@ public class TestKafkaExtractionCluster
     final Producer<byte[], byte[]> producer = new Producer<byte[], byte[]>(new ProducerConfig(kafkaProducerProperties));
     try {
       checkServer();
-      final ConcurrentMap<String, Function<String, String>> fnFn = injector.getInstance(
+      final ConcurrentMap<String, Function<String, String>> fnFn = injector.getInstance(Key.get(new TypeLiteral<ConcurrentMap<String, Function<String, String>>>(){}, Names.named("namespaceExtractionFunctionCache")));
-          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,14 +164,14 @@ public class NamespacedExtractionModule implements DruidModule
   @Provides
   @Named("namespaceVersionMap")
   @LazySingleton
-  public final ConcurrentMap<String, String> getVersionMap()
+  public ConcurrentMap<String, String> getVersionMap()
   {
     return new ConcurrentHashMap<>();
   }
 
   @Provides
   @Named("namespaceExtractionFunctionCache")
-  public final ConcurrentMap<String, Function<String, String>> getFnCache()
+  public ConcurrentMap<String, Function<String, String>> getFnCache()
   {
     return fnCache;
   }
@@ -179,7 +179,7 @@ public class NamespacedExtractionModule implements DruidModule
   @Provides
   @Named("dimExtractionNamespace")
   @LazySingleton
-  public final Function<String, Function<String, String>> getFunctionMaker(
+  public 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 class S3StorageDruidModule implements DruidModule
 
   @Provides
   @LazySingleton
-  public final AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
+  public AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
   {
     return AWSCredentialsUtils.defaultAWSCredentialsProviderChain(config);
   }
 
   @Provides
   @LazySingleton
-  public final RestS3Service getRestS3Service(AWSCredentialsProvider provider)
+  public 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 class DruidTestModule implements Module
 
   @Provides
   @LazySingleton
-  public final ServiceEmitter getServiceEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
+  public ServiceEmitter getServiceEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
   {
     return new ServiceEmitter("", "", new LoggingEmitter(config.get(), jsonMapper));
   }

pom.xml

@@ -69,12 +69,11 @@
         <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.10</druid.api.version>
+        <druid.api.version>0.3.9</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>
@@ -236,17 +235,17 @@
             <dependency>
                 <groupId>com.google.inject</groupId>
                 <artifactId>guice</artifactId>
-                <version>${guice.version}</version>
+                <version>4.0-beta</version>
             </dependency>
             <dependency>
                 <groupId>com.google.inject.extensions</groupId>
                 <artifactId>guice-servlet</artifactId>
-                <version>${guice.version}</version>
+                <version>4.0-beta</version>
             </dependency>
             <dependency>
                 <groupId>com.google.inject.extensions</groupId>
                 <artifactId>guice-multibindings</artifactId>
-                <version>${guice.version}</version>
+                <version>4.0-beta</version>
             </dependency>
             <dependency>
                 <groupId>com.ibm.icu</groupId>

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

@@ -39,7 +39,7 @@ public class ConfigModule implements Module
   }
 
   @Provides @LazySingleton
-  public final ConfigurationObjectFactory makeFactory(Properties props)
+  public ConfigurationObjectFactory makeFactory(Properties props)
   {
     return Config.createFactory(props);
   }

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

@@ -39,13 +39,13 @@ public class JacksonModule implements Module
   }
 
   @Provides @LazySingleton @Json
-  public final ObjectMapper jsonMapper()
+  public ObjectMapper jsonMapper()
   {
     return new DefaultObjectMapper();
   }
 
   @Provides @LazySingleton @Smile
-  public final ObjectMapper smileMapper()
+  public 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 class MetadataStorageTablesConfigTest
 
           @Provides
           @LazySingleton
-          public final ObjectMapper jsonMapper()
+          public ObjectMapper jsonMapper()
           {
             return new DefaultObjectMapper();
           }

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

@@ -45,7 +45,7 @@ public class CuratorModule implements Module
   }
 
   @Provides @LazySingleton
-  public final CuratorFramework makeCurator(CuratorConfig config, Lifecycle lifecycle) throws IOException
+  public 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 class DiscoveryModule implements Module
   @Provides
   @LazySingleton
   @Named(NAME)
-  public final CuratorServiceAnnouncer getServiceAnnouncer(
+  public CuratorServiceAnnouncer getServiceAnnouncer(
       final CuratorServiceAnnouncer announcer,
       final Injector injector,
       final Set<KeyHolder<DruidNode>> nodesToAnnounce,
@@ -190,7 +190,7 @@ public class DiscoveryModule implements Module
 
   @Provides
   @LazySingleton
-  public final ServiceDiscovery<Void> getServiceDiscovery(
+  public ServiceDiscovery<Void> getServiceDiscovery(
       CuratorFramework curator,
       CuratorDiscoveryConfig config,
       Lifecycle lifecycle
@@ -233,7 +233,7 @@ public class DiscoveryModule implements Module
 
   @Provides
   @LazySingleton
-  public final ServerDiscoveryFactory getServerDiscoveryFactory(
+  public ServerDiscoveryFactory getServerDiscoveryFactory(
       ServiceDiscovery<Void> serviceDiscovery
   )
   {

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

@@ -38,14 +38,14 @@ public class AWSModule implements Module
 
   @Provides
   @LazySingleton
-  public final AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
+  public AWSCredentialsProvider getAWSCredentialsProvider(final AWSCredentialsConfig config)
   {
     return AWSCredentialsUtils.defaultAWSCredentialsProviderChain(config);
   }
 
   @Provides
   @LazySingleton
-  public final AmazonEC2 getEc2Client(AWSCredentialsProvider credentials)
+  public AmazonEC2 getEc2Client(AWSCredentialsProvider credentials)
   {
     return new AmazonEC2Client(credentials);
   }

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

@@ -45,7 +45,7 @@ public class AnnouncerModule implements Module
 
   @Provides
   @ManageLifecycle
-  public final Announcer getAnnouncer(CuratorFramework curator)
+  public 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 class DruidProcessingModule implements Module
   @Provides
   @BackgroundCaching
   @LazySingleton
-  public final ExecutorService getBackgroundExecutorService(
+  public ExecutorService getBackgroundExecutorService(
       CacheConfig cacheConfig
   )
   {
@@ -81,7 +81,7 @@ public class DruidProcessingModule implements Module
   @Provides
   @Processing
   @ManageLifecycle
-  public final ExecutorService getProcessingExecutorService(
+  public ExecutorService getProcessingExecutorService(
       ExecutorServiceConfig config,
       ServiceEmitter emitter,
       Lifecycle lifecycle
@@ -100,7 +100,7 @@ public class DruidProcessingModule implements Module
   @Provides
   @LazySingleton
   @Global
-  public final StupidPool<ByteBuffer> getIntermediateResultsPool(DruidProcessingConfig config)
+  public StupidPool<ByteBuffer> getIntermediateResultsPool(DruidProcessingConfig config)
   {
     try {
       long maxDirectMemory = VMUtils.getMaxDirectMemory();

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

@@ -38,7 +38,7 @@ public class IndexingServiceDiscoveryModule implements Module
   @Provides
   @IndexingService
   @ManageLifecycle
-  public final ServerDiscoverySelector getServiceProvider(
+  public ServerDiscoverySelector getServiceProvider(
       IndexingServiceSelectorConfig config,
       ServerDiscoveryFactory serverDiscoveryFactory
   )

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

@@ -48,7 +48,7 @@ public class ServerModule implements DruidModule
   }
 
   @Provides @LazySingleton
-  public final ScheduledExecutorFactory getScheduledExecutorFactory(Lifecycle lifecycle)
+  public ScheduledExecutorFactory getScheduledExecutorFactory(Lifecycle lifecycle)
   {
     return ScheduledExecutors.createFactory(lifecycle);
   }

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

@@ -57,7 +57,7 @@ public class StorageNodeModule implements Module
 
   @Provides
   @LazySingleton
-  public final DruidServerMetadata getMetadata(@Self DruidNode node, @Nullable NodeTypeConfig nodeType, DruidServerConfig config)
+  public DruidServerMetadata getMetadata(@Self DruidNode node, @Nullable NodeTypeConfig nodeType, DruidServerConfig config)
   {
     if (nodeType == null) {
       throw new ProvisionException("Must override the binding for NodeTypeConfig if you want a DruidServerMetadata.");

server/src/main/java/io/druid/server/initialization/EmitterModule.java

@@ -74,7 +74,7 @@ public class EmitterModule implements Module
 
   @Provides
   @ManageLifecycle
-  public final ServiceEmitter getServiceEmitter(@Self Supplier<DruidNode> configSupplier, Emitter emitter)
+  public ServiceEmitter getServiceEmitter(@Self Supplier<DruidNode> configSupplier, Emitter emitter)
   {
     final DruidNode config = configSupplier.get();
     final ServiceEmitter retVal = new ServiceEmitter(config.getServiceName(), config.getHostAndPort(), emitter);

server/src/main/java/io/druid/server/initialization/HttpEmitterModule.java

@@ -60,7 +60,7 @@ public class HttpEmitterModule implements Module
   @Provides
   @ManageLifecycle
   @Named("http")
-  public final Emitter getEmitter(
+  public Emitter getEmitter(
       Supplier<HttpEmitterConfig> config,
       @Nullable SSLContext sslContext,
       Lifecycle lifecycle,

server/src/main/java/io/druid/server/initialization/LogEmitterModule.java

@@ -42,7 +42,7 @@ public class LogEmitterModule implements Module
   }
 
   @Provides @ManageLifecycle @Named(EMITTER_TYPE)
-  public final Emitter makeEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
+  public Emitter makeEmitter(Supplier<LoggingEmitterConfig> config, ObjectMapper jsonMapper)
   {
     return new LoggingEmitter(config.get(), jsonMapper);
   }

server/src/main/java/io/druid/server/initialization/NoopEmitterModule.java

@@ -39,7 +39,7 @@ public class NoopEmitterModule implements Module
   @Provides
   @ManageLifecycle
   @Named(EMITTER_TYPE)
-  public final Emitter makeEmitter()
+  public Emitter makeEmitter()
   {
     return new NoopEmitter();
   }

server/src/main/java/io/druid/server/initialization/jetty/JettyServerModule.java

@@ -106,7 +106,7 @@ public class JettyServerModule extends JerseyServletModule
 
   @Provides
   @LazySingleton
-  public final Server getServer(Injector injector, Lifecycle lifecycle, @Self DruidNode node, ServerConfig config)
+  public Server getServer(Injector injector, Lifecycle lifecycle, @Self DruidNode node, ServerConfig config)
   {
     JettyServerInitializer initializer = injector.getInstance(JettyServerInitializer.class);
 
@@ -145,7 +145,7 @@ public class JettyServerModule extends JerseyServletModule
 
   @Provides
   @Singleton
-  public final JacksonJsonProvider getJacksonJsonProvider(@Json ObjectMapper objectMapper)
+  public JacksonJsonProvider getJacksonJsonProvider(@Json ObjectMapper objectMapper)
   {
     final JacksonJsonProvider provider = new JacksonJsonProvider();
     provider.setMapper(objectMapper);

server/src/main/java/io/druid/server/metrics/MetricsModule.java

@@ -67,7 +67,7 @@ public class MetricsModule implements Module
 
   @Provides
   @ManageLifecycle
-  public final MonitorScheduler getMonitorScheduler(
+  public MonitorScheduler getMonitorScheduler(
       Supplier<DruidMonitorSchedulerConfig> config,
       MonitorsConfig monitorsConfig,
       Set<Class<? extends Monitor>> monitorSet,

services/src/main/java/io/druid/cli/CliBridge.java

@@ -118,7 +118,7 @@ public class CliBridge extends ServerRunnable
           @Provides
           @LazySingleton
           @Bridge
-          public final CuratorFramework getBridgeCurator(final BridgeCuratorConfig bridgeCuratorConfig, Lifecycle lifecycle)
+          public CuratorFramework getBridgeCurator(final BridgeCuratorConfig bridgeCuratorConfig, Lifecycle lifecycle)
           {
             final CuratorFramework framework =
                 CuratorFrameworkFactory.builder()
@@ -156,7 +156,7 @@ public class CliBridge extends ServerRunnable
 
           @Provides
           @ManageLifecycle
-          public final ServerDiscoverySelector getServerDiscoverySelector(
+          public ServerDiscoverySelector getServerDiscoverySelector(
               DruidClusterBridgeConfig config,
               ServerDiscoveryFactory factory
 
@@ -168,7 +168,7 @@ public class CliBridge extends ServerRunnable
           @Provides
           @ManageLifecycle
           @Bridge
-          public final Announcer getBridgeAnnouncer(
+          public Announcer getBridgeAnnouncer(
               @Bridge CuratorFramework curator
           )
           {
@@ -178,7 +178,7 @@ public class CliBridge extends ServerRunnable
           @Provides
           @ManageLifecycleLast
           @Bridge
-          public final AbstractDataSegmentAnnouncer getBridgeDataSegmentAnnouncer(
+          public AbstractDataSegmentAnnouncer getBridgeDataSegmentAnnouncer(
               DruidServerMetadata metadata,
               BatchDataSegmentAnnouncerConfig config,
               ZkPathsConfig zkPathsConfig,

services/src/main/java/io/druid/cli/CliCoordinator.java

@@ -138,7 +138,7 @@ public class CliCoordinator extends ServerRunnable
 
           @Provides
           @LazySingleton
-          public final LoadQueueTaskMaster getLoadQueueTaskMaster(
+          public LoadQueueTaskMaster getLoadQueueTaskMaster(
               CuratorFramework curator,
               ObjectMapper jsonMapper,
               ScheduledExecutorFactory factory,

services/src/main/java/io/druid/cli/CliMiddleManager.java

@@ -99,7 +99,7 @@ public class CliMiddleManager extends ServerRunnable
 
           @Provides
           @LazySingleton
-          public final Worker getWorker(@Self DruidNode node, WorkerConfig config)
+          public Worker getWorker(@Self DruidNode node, WorkerConfig config)
           {
             return new Worker(
                 node.getHostAndPort(),

services/src/main/java/io/druid/cli/CliRouter.java

@@ -93,7 +93,7 @@ public class CliRouter extends ServerRunnable
 
           @Provides
           @ManageLifecycle
-          public final ServerDiscoverySelector getCoordinatorServerDiscoverySelector(
+          public ServerDiscoverySelector getCoordinatorServerDiscoverySelector(
               TieredBrokerConfig config,
               ServerDiscoveryFactory factory