From 8884b575c1ae648c14eddb90ca805fa3029b541c Mon Sep 17 00:00:00 2001 From: kimchy Date: Sun, 30 Jan 2011 16:30:17 +0200 Subject: [PATCH] more doc --- .../java/org/elasticsearch/index/cache/bloom/BloomCache.java | 3 ++- .../elasticsearch/index/shard/service/InternalIndexShard.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/cache/bloom/BloomCache.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/cache/bloom/BloomCache.java index 19af4b0d34e..323c823f21b 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/cache/bloom/BloomCache.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/cache/bloom/BloomCache.java @@ -30,7 +30,8 @@ import org.elasticsearch.index.IndexComponent; public interface BloomCache extends IndexComponent, CloseableComponent { /** - * *Async* loads a bloom filter for the field name. + * *Async* loads a bloom filter for the field name. Note, this one only supports + * for fields that have a single term per doc. */ BloomFilter filter(IndexReader reader, String fieldName, boolean asyncLoad); diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java index 03375fea8ab..17eb7a9026b 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java @@ -579,7 +579,8 @@ public class InternalIndexShard extends AbstractIndexShardComponent implements I } } // since we can do async merging, it will not be called explicitly when indexing (adding / deleting docs), and only when flushing - // so, make sure we periodically call it + // so, make sure we periodically call it, this need to be a small enough value so mergine will actually + // happen and reduce the number of segments TimeValue optimizeInterval = indexSettings.getAsTime("index.merge.async_interval", TimeValue.timeValueSeconds(1)); if (optimizeInterval.millis() > 0) { optimizeScheduleFuture = threadPool.scheduleWithFixedDelay(new EngineOptimizer(), optimizeInterval);