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

cache size locally

This commit is contained in:
nishantmonu51 2014-09-09 16:02:50 +05:30
parent 178f002f05
commit e7a5a01f7b
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -783,6 +783,8 @@ public class IncrementalIndex implements Iterable<Row>, Closeable
private final Map<String, Integer> falseIds;
private final Map<Integer, String> falseIdsReverse;
private volatile String[] sortedVals = null;
// size on MapDB.HTreeMap is slow so maintain a count here
private volatile int size=0;
public DimDim(String dimName)
{
@ -807,7 +809,7 @@ public class IncrementalIndex implements Iterable<Row>, Closeable
public int size()
{
return falseIds.size();
return size;
}
public Set<String> keySet()
@ -817,7 +819,7 @@ public class IncrementalIndex implements Iterable<Row>, Closeable
public synchronized void add(String value)
{
final int id = falseIds.size();
final int id = size++;
falseIds.put(value, id);
falseIdsReverse.put(id, value);
}
@ -837,7 +839,7 @@ public class IncrementalIndex implements Iterable<Row>, Closeable
public void sort()
{
if (sortedVals == null) {
sortedVals = new String[falseIds.size()];
sortedVals = new String[size];
int index = 0;
for (String value : falseIds.keySet()) {