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

Thread Pool: Add a specific thread pool for bulk indexing operations, closes #1668.

This commit is contained in:
Shay Banon 2012-02-05 20:12:41 +02:00
parent 437eda6b5b
commit e8a0ccc20c
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/elasticsearch/action/bulk/TransportShardBulkAction.java
View File

@ -72,7 +72,7 @@ public class TransportShardBulkAction extends TransportShardReplicationOperation
@Override @Override
protected String executor() { protected String executor() {
return ThreadPool.Names.INDEX; return ThreadPool.Names.BULK;
} }
@Override @Override

2
src/main/java/org/elasticsearch/threadpool/ThreadPool.java
View File

@ -58,6 +58,7 @@ public class ThreadPool extends AbstractComponent {
public static final String SAME = "same"; public static final String SAME = "same";
public static final String CACHED = "cached"; public static final String CACHED = "cached";
public static final String INDEX = "index"; public static final String INDEX = "index";
public static final String BULK = "bulk";
public static final String SEARCH = "search"; public static final String SEARCH = "search";
public static final String PERCOLATE = "percolate"; public static final String PERCOLATE = "percolate";
public static final String MANAGEMENT = "management"; public static final String MANAGEMENT = "management";
@ -85,6 +86,7 @@ public class ThreadPool extends AbstractComponent {
Map<String, ExecutorHolder> executors = Maps.newHashMap(); Map<String, ExecutorHolder> executors = Maps.newHashMap();
executors.put(Names.CACHED, build(Names.CACHED, "cached", groupSettings.get(Names.CACHED), settingsBuilder().put("keep_alive", "30s").build())); executors.put(Names.CACHED, build(Names.CACHED, "cached", groupSettings.get(Names.CACHED), settingsBuilder().put("keep_alive", "30s").build()));
executors.put(Names.INDEX, build(Names.INDEX, "cached", groupSettings.get(Names.INDEX), ImmutableSettings.Builder.EMPTY_SETTINGS)); executors.put(Names.INDEX, build(Names.INDEX, "cached", groupSettings.get(Names.INDEX), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.BULK, build(Names.BULK, "cached", groupSettings.get(Names.BULK), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.SEARCH, build(Names.SEARCH, "cached", groupSettings.get(Names.SEARCH), ImmutableSettings.Builder.EMPTY_SETTINGS)); executors.put(Names.SEARCH, build(Names.SEARCH, "cached", groupSettings.get(Names.SEARCH), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.PERCOLATE, build(Names.PERCOLATE, "cached", groupSettings.get(Names.PERCOLATE), ImmutableSettings.Builder.EMPTY_SETTINGS)); executors.put(Names.PERCOLATE, build(Names.PERCOLATE, "cached", groupSettings.get(Names.PERCOLATE), ImmutableSettings.Builder.EMPTY_SETTINGS));
executors.put(Names.MANAGEMENT, build(Names.MANAGEMENT, "scaling", groupSettings.get(Names.MANAGEMENT), settingsBuilder().put("keep_alive", "5m").put("size", 20).build())); executors.put(Names.MANAGEMENT, build(Names.MANAGEMENT, "scaling", groupSettings.get(Names.MANAGEMENT), settingsBuilder().put("keep_alive", "5m").put("size", 20).build()));