add some fixes

This commit is contained in:
fjy 2013-08-22 10:56:50 -07:00
parent 6a8c160740
commit 261ef7ce56
3 changed files with 9 additions and 2 deletions

View File

@ -19,6 +19,7 @@ import com.metamx.druid.guice.RealtimeManagerConfig;
import com.metamx.druid.initialization.DruidModule; import com.metamx.druid.initialization.DruidModule;
import com.metamx.druid.loading.DataSegmentPusher; import com.metamx.druid.loading.DataSegmentPusher;
import com.metamx.druid.realtime.FireDepartment; import com.metamx.druid.realtime.FireDepartment;
import com.metamx.druid.realtime.RealtimeManager;
import com.metamx.druid.realtime.SegmentPublisher; import com.metamx.druid.realtime.SegmentPublisher;
import druid.examples.flights.FlightsFirehoseFactory; import druid.examples.flights.FlightsFirehoseFactory;
import druid.examples.rand.RandomFirehoseFactory; import druid.examples.rand.RandomFirehoseFactory;
@ -51,7 +52,8 @@ public class RealtimeExampleModule implements DruidModule
new TypeLiteral<List<FireDepartment>>() new TypeLiteral<List<FireDepartment>>()
{ {
} }
).toProvider(FireDepartmentsProvider.class).in(ManageLifecycle.class); ).toProvider(FireDepartmentsProvider.class);
binder.bind(RealtimeManager.class).in(ManageLifecycle.class);
} }
@Override @Override

View File

@ -47,7 +47,7 @@ public class RealtimeModule implements Module
new TypeLiteral<List<FireDepartment>>() new TypeLiteral<List<FireDepartment>>()
{ {
} }
).toProvider(FireDepartmentsProvider.class).in(ManageLifecycle.class); ).toProvider(FireDepartmentsProvider.class);
binder.bind(RealtimeManager.class).in(ManageLifecycle.class); binder.bind(RealtimeManager.class).in(ManageLifecycle.class);
} }
} }

View File

@ -42,6 +42,11 @@
<artifactId>druid-server</artifactId> <artifactId>druid-server</artifactId>
<version>${project.parent.version}</version> <version>${project.parent.version}</version>
</dependency> </dependency>
<dependency>
<groupId>com.metamx.druid</groupId>
<artifactId>druid-examples</artifactId>
<version>${project.parent.version}</version>
</dependency>
<dependency> <dependency>
<groupId>io.airlift</groupId> <groupId>io.airlift</groupId>
<artifactId>airline</artifactId> <artifactId>airline</artifactId>