Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-25 20:48:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

append a random UUID to map name

Browse Source 
avoid collision with dimension name
This commit is contained in:
nishantmonu51 2014-09-09 23:20:19 +05:30
parent e7a5a01f7b
commit 2b3ad4d742
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
processing/src/main/java/io/druid/segment/incremental/IncrementalIndex.java
View File

@ -69,6 +69,7 @@ import java.util.LinkedHashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.UUID;
import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentNavigableMap;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
@ -314,7 +315,7 @@ public class IncrementalIndex implements Iterable<Row>, Closeable
this.bufferHolder = bufferPool.take(); this.bufferHolder = bufferPool.take();
this.dimValues = new DimensionHolder(); this.dimValues = new DimensionHolder();
db = DBMaker.newMemoryDirectDB().transactionDisable().cacheWeakRefEnable().make(); db = DBMaker.newMemoryDirectDB().transactionDisable().cacheWeakRefEnable().make();
this.facts = db.createTreeMap("facts").make(); this.facts = db.createTreeMap("__facts" + UUID.randomUUID()).make();
} }
public IncrementalIndex( public IncrementalIndex(