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

Update Settings: Allow to dynamically set index.gc_deletes setting, closes #1251.

This commit is contained in:
Shay Banon 2011-08-17 02:58:55 +03:00
parent 20ff04f715
commit 451c87f486
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -102,7 +102,7 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine {
private final AtomicBoolean optimizeMutex = new AtomicBoolean(); private final AtomicBoolean optimizeMutex = new AtomicBoolean();
private final long gcDeletesInMillis; private long gcDeletesInMillis;
private final ThreadPool threadPool; private final ThreadPool threadPool;
@ -1231,13 +1231,20 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine {
IndexMetaData.addDynamicSettings( IndexMetaData.addDynamicSettings(
"index.term_index_interval", "index.term_index_interval",
"index.term_index_divisor", "index.term_index_divisor",
"index.index_concurrency" "index.index_concurrency",
"index.gc_deletes"
); );
} }
class ApplySettings implements IndexSettingsService.Listener { class ApplySettings implements IndexSettingsService.Listener {
@Override public void onRefreshSettings(Settings settings) { @Override public void onRefreshSettings(Settings settings) {
long gcDeletesInMillis = indexSettings.getAsTime("index.gc_deletes", TimeValue.timeValueMillis(RobinEngine.this.gcDeletesInMillis)).millis();
if (gcDeletesInMillis != RobinEngine.this.gcDeletesInMillis) {
logger.info("updating index.gc_deletes from [{}] to [{}]", TimeValue.timeValueMillis(RobinEngine.this.gcDeletesInMillis), TimeValue.timeValueMillis(gcDeletesInMillis));
RobinEngine.this.gcDeletesInMillis = gcDeletesInMillis;
}
int termIndexInterval = settings.getAsInt("index.term_index_interval", RobinEngine.this.termIndexInterval); int termIndexInterval = settings.getAsInt("index.term_index_interval", RobinEngine.this.termIndexInterval);
int termIndexDivisor = settings.getAsInt("index.term_index_divisor", RobinEngine.this.termIndexDivisor); // IndexReader#DEFAULT_TERMS_INDEX_DIVISOR int termIndexDivisor = settings.getAsInt("index.term_index_divisor", RobinEngine.this.termIndexDivisor); // IndexReader#DEFAULT_TERMS_INDEX_DIVISOR
int indexConcurrency = settings.getAsInt("index.index_concurrency", RobinEngine.this.indexConcurrency); int indexConcurrency = settings.getAsInt("index.index_concurrency", RobinEngine.this.indexConcurrency);