Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

1) Don't need a ServiceEmitter in ZkCoordinator anymore.

This commit is contained in:
cheddar 2013-04-25 10:40:17 -05:00
parent 38b5d94ffc
commit 1eb2dfe17e
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/main/java/com/metamx/druid/coordination/ZkCoordinator.java
View File

@ -28,7 +28,6 @@ import com.metamx.druid.client.DataSegment;
import com.metamx.druid.initialization.ZkPathsConfig; import com.metamx.druid.initialization.ZkPathsConfig;
import com.metamx.druid.loading.SegmentLoadingException; import com.metamx.druid.loading.SegmentLoadingException;
import com.metamx.emitter.EmittingLogger; import com.metamx.emitter.EmittingLogger;
import com.metamx.emitter.service.ServiceEmitter;
import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.cache.ChildData; import org.apache.curator.framework.recipes.cache.ChildData;
import org.apache.curator.framework.recipes.cache.PathChildrenCache; import org.apache.curator.framework.recipes.cache.PathChildrenCache;
@ -53,7 +52,6 @@ public class ZkCoordinator implements DataSegmentChangeHandler
private final DataSegmentAnnouncer announcer; private final DataSegmentAnnouncer announcer;
private final CuratorFramework curator; private final CuratorFramework curator;
private final ServerManager serverManager; private final ServerManager serverManager;
private final ServiceEmitter emitter;
private final String loadQueueLocation; private final String loadQueueLocation;
private final String servedSegmentsLocation; private final String servedSegmentsLocation;
@ -68,8 +66,7 @@ public class ZkCoordinator implements DataSegmentChangeHandler
DruidServerMetadata me, DruidServerMetadata me,
DataSegmentAnnouncer announcer, DataSegmentAnnouncer announcer,
CuratorFramework curator, CuratorFramework curator,
ServerManager serverManager, ServerManager serverManager
ServiceEmitter emitter
) )
{ {
this.jsonMapper = jsonMapper; this.jsonMapper = jsonMapper;
@ -78,7 +75,6 @@ public class ZkCoordinator implements DataSegmentChangeHandler
this.announcer = announcer; this.announcer = announcer;
this.curator = curator; this.curator = curator;
this.serverManager = serverManager; this.serverManager = serverManager;
this.emitter = emitter;
this.loadQueueLocation = ZKPaths.makePath(zkPaths.getLoadQueuePath(), me.getName()); this.loadQueueLocation = ZKPaths.makePath(zkPaths.getLoadQueuePath(), me.getName());
this.servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName()); this.servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName());