honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

allow to set term index divisor

This commit is contained in:
kimchy 2010-12-16 21:56:59 +02:00
parent 698f67a31a
commit 005c6d9124
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java
View File

@ -67,6 +67,8 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
private final int termIndexInterval;
private final int termIndexDivisor;
private final TimeValue refreshInterval;
private final ReadWriteLock rwl = new ReentrantReadWriteLock();
@ -111,6 +113,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
this.indexingBufferSize = componentSettings.getAsBytesSize("index_buffer_size", new ByteSizeValue(64, ByteSizeUnit.MB)); // not really important, as it is set by the IndexingMemory manager
this.termIndexInterval = indexSettings.getAsInt("index.term_index_interval", IndexWriter.DEFAULT_TERM_INDEX_INTERVAL);
this.termIndexDivisor = indexSettings.getAsInt("index.term_index_divisor", 1); // IndexReader#DEFAULT_TERMS_INDEX_DIVISOR
this.compoundFormat = indexSettings.getAsBoolean("index.compound_format", indexSettings.getAsBoolean("index.merge.policy.use_compound_file", store == null ? false : store.suggestUseCompoundFile()));
this.refreshInterval = componentSettings.getAsTime("refresh_interval", indexSettings.getAsTime("index.refresh_interval", timeValueSeconds(1)));
@ -615,6 +618,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
indexWriter.setSimilarity(similarityService.defaultIndexSimilarity());
indexWriter.setRAMBufferSizeMB(indexingBufferSize.mbFrac());
indexWriter.setTermIndexInterval(termIndexInterval);
indexWriter.setReaderTermsIndexDivisor(termIndexDivisor);
indexWriter.setUseCompoundFile(compoundFormat);
} catch (IOException e) {
safeClose(indexWriter);