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

fix for concurrent modifications in druid server

This commit is contained in:
Fangjin Yang 2013-03-22 17:05:39 -07:00
parent cc08d6029f
commit 5eaaabce7f
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client/src/main/java/com/metamx/druid/client/DruidServer.java
View File

@ -24,8 +24,6 @@ import com.fasterxml.jackson.annotation.JsonProperty;
import com.google.common.collect.ImmutableMap;
import com.metamx.common.logger.Logger;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@ -41,7 +39,7 @@ public class DruidServer implements Comparable
private final String name;
private final ConcurrentMap<String, DruidDataSource> dataSources;
private final Map<String, DataSegment> segments;
private final ConcurrentMap<String, DataSegment> segments;
private final String host;
private final long maxSize;
@ -80,7 +78,7 @@ public class DruidServer implements Comparable
this.tier = tier;
this.dataSources = new ConcurrentHashMap<String, DruidDataSource>();
this.segments = new HashMap<String, DataSegment>();
this.segments = new ConcurrentHashMap<String, DataSegment>();
}
public String getName()
@ -132,7 +130,7 @@ public class DruidServer implements Comparable
@JsonProperty
public Map<String, DataSegment> getSegments()
{
return segments;
return ImmutableMap.copyOf(segments);
}
public DataSegment getSegment(String segmentName)