From f9b3ebb2f0c57a70aedda5847300dbfb5340349b Mon Sep 17 00:00:00 2001 From: Charles Allen Date: Wed, 1 Jul 2015 10:09:24 -0700 Subject: [PATCH] Add uri scheme to S3StorageDruidModule for pullers --- .../src/main/java/io/druid/storage/s3/S3StorageDruidModule.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/extensions/s3-extensions/src/main/java/io/druid/storage/s3/S3StorageDruidModule.java b/extensions/s3-extensions/src/main/java/io/druid/storage/s3/S3StorageDruidModule.java index bab2114ff6d3..e3ae50fb7559 100644 --- a/extensions/s3-extensions/src/main/java/io/druid/storage/s3/S3StorageDruidModule.java +++ b/extensions/s3-extensions/src/main/java/io/druid/storage/s3/S3StorageDruidModule.java @@ -39,6 +39,7 @@ public class S3StorageDruidModule implements DruidModule { public static final String SCHEME = "s3_zip"; + public static final String URI_SCHEME = "s3"; @Override public List getJacksonModules() { @@ -72,6 +73,7 @@ public void configure(Binder binder) JsonConfigProvider.bind(binder, "druid.s3", AWSCredentialsConfig.class); Binders.dataSegmentPullerBinder(binder).addBinding(SCHEME).to(S3DataSegmentPuller.class).in(LazySingleton.class); + Binders.dataSegmentPullerBinder(binder).addBinding(URI_SCHEME).to(S3DataSegmentPuller.class).in(LazySingleton.class); Binders.dataSegmentKillerBinder(binder).addBinding(SCHEME).to(S3DataSegmentKiller.class).in(LazySingleton.class); Binders.dataSegmentMoverBinder(binder).addBinding(SCHEME).to(S3DataSegmentMover.class).in(LazySingleton.class); Binders.dataSegmentArchiverBinder(binder).addBinding(SCHEME).to(S3DataSegmentArchiver.class).in(LazySingleton.class);