Merge branch 'master' into feature/rank-eval
This commit is contained in:
commit
20c1e25609
|
@ -58,57 +58,57 @@ public class AllocationBenchmark {
|
||||||
// support to constrain the combinations of benchmark parameters and we do not want to rely on OptionsBuilder as each benchmark would
|
// support to constrain the combinations of benchmark parameters and we do not want to rely on OptionsBuilder as each benchmark would
|
||||||
// need its own main method and we cannot execute more than one class with a main method per JAR.
|
// need its own main method and we cannot execute more than one class with a main method per JAR.
|
||||||
@Param({
|
@Param({
|
||||||
// indices, shards, replicas, nodes
|
// indices| shards| replicas| nodes
|
||||||
" 10, 1, 0, 1",
|
" 10| 1| 0| 1",
|
||||||
" 10, 3, 0, 1",
|
" 10| 3| 0| 1",
|
||||||
" 10, 10, 0, 1",
|
" 10| 10| 0| 1",
|
||||||
" 100, 1, 0, 1",
|
" 100| 1| 0| 1",
|
||||||
" 100, 3, 0, 1",
|
" 100| 3| 0| 1",
|
||||||
" 100, 10, 0, 1",
|
" 100| 10| 0| 1",
|
||||||
|
|
||||||
" 10, 1, 0, 10",
|
" 10| 1| 0| 10",
|
||||||
" 10, 3, 0, 10",
|
" 10| 3| 0| 10",
|
||||||
" 10, 10, 0, 10",
|
" 10| 10| 0| 10",
|
||||||
" 100, 1, 0, 10",
|
" 100| 1| 0| 10",
|
||||||
" 100, 3, 0, 10",
|
" 100| 3| 0| 10",
|
||||||
" 100, 10, 0, 10",
|
" 100| 10| 0| 10",
|
||||||
|
|
||||||
" 10, 1, 1, 10",
|
" 10| 1| 1| 10",
|
||||||
" 10, 3, 1, 10",
|
" 10| 3| 1| 10",
|
||||||
" 10, 10, 1, 10",
|
" 10| 10| 1| 10",
|
||||||
" 100, 1, 1, 10",
|
" 100| 1| 1| 10",
|
||||||
" 100, 3, 1, 10",
|
" 100| 3| 1| 10",
|
||||||
" 100, 10, 1, 10",
|
" 100| 10| 1| 10",
|
||||||
|
|
||||||
" 10, 1, 2, 10",
|
" 10| 1| 2| 10",
|
||||||
" 10, 3, 2, 10",
|
" 10| 3| 2| 10",
|
||||||
" 10, 10, 2, 10",
|
" 10| 10| 2| 10",
|
||||||
" 100, 1, 2, 10",
|
" 100| 1| 2| 10",
|
||||||
" 100, 3, 2, 10",
|
" 100| 3| 2| 10",
|
||||||
" 100, 10, 2, 10",
|
" 100| 10| 2| 10",
|
||||||
|
|
||||||
" 10, 1, 0, 50",
|
" 10| 1| 0| 50",
|
||||||
" 10, 3, 0, 50",
|
" 10| 3| 0| 50",
|
||||||
" 10, 10, 0, 50",
|
" 10| 10| 0| 50",
|
||||||
" 100, 1, 0, 50",
|
" 100| 1| 0| 50",
|
||||||
" 100, 3, 0, 50",
|
" 100| 3| 0| 50",
|
||||||
" 100, 10, 0, 50",
|
" 100| 10| 0| 50",
|
||||||
|
|
||||||
" 10, 1, 1, 50",
|
" 10| 1| 1| 50",
|
||||||
" 10, 3, 1, 50",
|
" 10| 3| 1| 50",
|
||||||
" 10, 10, 1, 50",
|
" 10| 10| 1| 50",
|
||||||
" 100, 1, 1, 50",
|
" 100| 1| 1| 50",
|
||||||
" 100, 3, 1, 50",
|
" 100| 3| 1| 50",
|
||||||
" 100, 10, 1, 50",
|
" 100| 10| 1| 50",
|
||||||
|
|
||||||
" 10, 1, 2, 50",
|
" 10| 1| 2| 50",
|
||||||
" 10, 3, 2, 50",
|
" 10| 3| 2| 50",
|
||||||
" 10, 10, 2, 50",
|
" 10| 10| 2| 50",
|
||||||
" 100, 1, 2, 50",
|
" 100| 1| 2| 50",
|
||||||
" 100, 3, 2, 50",
|
" 100| 3| 2| 50",
|
||||||
" 100, 10, 2, 50"
|
" 100| 10| 2| 50"
|
||||||
})
|
})
|
||||||
public String indicesShardsReplicasNodes = "10,1,0,1";
|
public String indicesShardsReplicasNodes = "10|1|0|1";
|
||||||
|
|
||||||
public int numTags = 2;
|
public int numTags = 2;
|
||||||
|
|
||||||
|
@ -117,7 +117,7 @@ public class AllocationBenchmark {
|
||||||
|
|
||||||
@Setup
|
@Setup
|
||||||
public void setUp() throws Exception {
|
public void setUp() throws Exception {
|
||||||
final String[] params = indicesShardsReplicasNodes.split(",");
|
final String[] params = indicesShardsReplicasNodes.split("\\|");
|
||||||
|
|
||||||
int numIndices = toInt(params[0]);
|
int numIndices = toInt(params[0]);
|
||||||
int numShards = toInt(params[1]);
|
int numShards = toInt(params[1]);
|
||||||
|
|
|
@ -393,7 +393,7 @@ class BuildPlugin implements Plugin<Project> {
|
||||||
}
|
}
|
||||||
|
|
||||||
options.encoding = 'UTF-8'
|
options.encoding = 'UTF-8'
|
||||||
//options.incremental = true
|
options.incremental = true
|
||||||
|
|
||||||
if (project.javaVersion == JavaVersion.VERSION_1_9) {
|
if (project.javaVersion == JavaVersion.VERSION_1_9) {
|
||||||
// hack until gradle supports java 9's new "--release" arg
|
// hack until gradle supports java 9's new "--release" arg
|
||||||
|
|
|
@ -38,7 +38,6 @@
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]ClusterUpdateSettingsAction.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]ClusterUpdateSettingsAction.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]ClusterUpdateSettingsRequestBuilder.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]ClusterUpdateSettingsRequestBuilder.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]SettingsUpdater.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]SettingsUpdater.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]settings[/\\]TransportClusterUpdateSettingsAction.java" checks="LineLength" />
|
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]ClusterSearchShardsAction.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]ClusterSearchShardsAction.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]ClusterSearchShardsRequestBuilder.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]ClusterSearchShardsRequestBuilder.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]TransportClusterSearchShardsAction.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]admin[/\\]cluster[/\\]shards[/\\]TransportClusterSearchShardsAction.java" checks="LineLength" />
|
||||||
|
@ -146,7 +145,6 @@
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]GetRequest.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]GetRequest.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]MultiGetRequest.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]MultiGetRequest.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]TransportGetAction.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]TransportGetAction.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]TransportMultiGetAction.java" checks="LineLength" />
|
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]TransportShardMultiGetAction.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]get[/\\]TransportShardMultiGetAction.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]index[/\\]IndexRequest.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]index[/\\]IndexRequest.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]index[/\\]IndexRequestBuilder.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]main[/\\]java[/\\]org[/\\]elasticsearch[/\\]action[/\\]index[/\\]IndexRequestBuilder.java" checks="LineLength" />
|
||||||
|
@ -881,7 +879,6 @@
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]store[/\\]IndicesStoreIntegrationIT.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]store[/\\]IndicesStoreIntegrationIT.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]store[/\\]IndicesStoreTests.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]store[/\\]IndicesStoreTests.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]template[/\\]SimpleIndexTemplateIT.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]indices[/\\]template[/\\]SimpleIndexTemplateIT.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]mget[/\\]SimpleMgetIT.java" checks="LineLength" />
|
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]monitor[/\\]jvm[/\\]JvmGcMonitorServiceSettingsTests.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]monitor[/\\]jvm[/\\]JvmGcMonitorServiceSettingsTests.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]plugins[/\\]PluginInfoTests.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]plugins[/\\]PluginInfoTests.java" checks="LineLength" />
|
||||||
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]plugins[/\\]PluginsServiceTests.java" checks="LineLength" />
|
<suppress files="core[/\\]src[/\\]test[/\\]java[/\\]org[/\\]elasticsearch[/\\]plugins[/\\]PluginsServiceTests.java" checks="LineLength" />
|
||||||
|
|
|
@ -24,9 +24,6 @@ import org.apache.lucene.search.Query;
|
||||||
import org.elasticsearch.index.query.ExistsQueryBuilder;
|
import org.elasticsearch.index.query.ExistsQueryBuilder;
|
||||||
import org.elasticsearch.index.query.QueryShardContext;
|
import org.elasticsearch.index.query.QueryShardContext;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ExistsFieldQueryExtension implements FieldQueryExtension {
|
public class ExistsFieldQueryExtension implements FieldQueryExtension {
|
||||||
|
|
||||||
public static final String NAME = "_exists_";
|
public static final String NAME = "_exists_";
|
||||||
|
|
|
@ -22,9 +22,6 @@ package org.apache.lucene.queryparser.classic;
|
||||||
import org.apache.lucene.search.Query;
|
import org.apache.lucene.search.Query;
|
||||||
import org.elasticsearch.index.query.QueryShardContext;
|
import org.elasticsearch.index.query.QueryShardContext;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public interface FieldQueryExtension {
|
public interface FieldQueryExtension {
|
||||||
|
|
||||||
Query query(QueryShardContext context, String queryText);
|
Query query(QueryShardContext context, String queryText);
|
||||||
|
|
|
@ -28,6 +28,7 @@ import org.apache.lucene.search.ConstantScoreQuery;
|
||||||
import org.apache.lucene.search.MultiPhraseQuery;
|
import org.apache.lucene.search.MultiPhraseQuery;
|
||||||
import org.apache.lucene.search.PhraseQuery;
|
import org.apache.lucene.search.PhraseQuery;
|
||||||
import org.apache.lucene.search.Query;
|
import org.apache.lucene.search.Query;
|
||||||
|
import org.apache.lucene.search.SynonymQuery;
|
||||||
import org.apache.lucene.search.TermQuery;
|
import org.apache.lucene.search.TermQuery;
|
||||||
import org.apache.lucene.search.join.ToParentBlockJoinQuery;
|
import org.apache.lucene.search.join.ToParentBlockJoinQuery;
|
||||||
import org.apache.lucene.search.spans.SpanTermQuery;
|
import org.apache.lucene.search.spans.SpanTermQuery;
|
||||||
|
@ -38,9 +39,6 @@ import org.elasticsearch.common.lucene.search.function.FunctionScoreQuery;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
// LUCENE MONITOR
|
// LUCENE MONITOR
|
||||||
// TODO: remove me!
|
// TODO: remove me!
|
||||||
public class CustomFieldQuery extends FieldQuery {
|
public class CustomFieldQuery extends FieldQuery {
|
||||||
|
@ -88,6 +86,13 @@ public class CustomFieldQuery extends FieldQuery {
|
||||||
flatten(boostingQuery.getMatch(), reader, flatQueries, boost);
|
flatten(boostingQuery.getMatch(), reader, flatQueries, boost);
|
||||||
//flatten negative query with negative boost
|
//flatten negative query with negative boost
|
||||||
flatten(boostingQuery.getContext(), reader, flatQueries, boostingQuery.getBoost());
|
flatten(boostingQuery.getContext(), reader, flatQueries, boostingQuery.getBoost());
|
||||||
|
} else if (sourceQuery instanceof SynonymQuery) {
|
||||||
|
// SynonymQuery should be handled by the parent class directly.
|
||||||
|
// This statement should be removed when https://issues.apache.org/jira/browse/LUCENE-7484 is merged.
|
||||||
|
SynonymQuery synQuery = (SynonymQuery) sourceQuery;
|
||||||
|
for (Term term : synQuery.getTerms()) {
|
||||||
|
flatten(new TermQuery(term), reader, flatQueries, boost);
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
super.flatten(sourceQuery, reader, flatQueries, boost);
|
super.flatten(sourceQuery, reader, flatQueries, boost);
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,8 +22,6 @@ import org.apache.lucene.store.RateLimiter.SimpleRateLimiter;
|
||||||
import org.elasticsearch.common.Nullable;
|
import org.elasticsearch.common.Nullable;
|
||||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class StoreRateLimiting {
|
public class StoreRateLimiting {
|
||||||
|
|
||||||
public interface Provider {
|
public interface Provider {
|
||||||
|
|
|
@ -20,8 +20,6 @@ package org.apache.lucene.store;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public final class StoreUtils {
|
public final class StoreUtils {
|
||||||
|
|
||||||
private StoreUtils() {
|
private StoreUtils() {
|
||||||
|
|
|
@ -24,9 +24,6 @@ import org.elasticsearch.rest.RestStatus;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ElasticsearchParseException extends ElasticsearchException {
|
public class ElasticsearchParseException extends ElasticsearchException {
|
||||||
|
|
||||||
public ElasticsearchParseException(String msg, Object... args) {
|
public ElasticsearchParseException(String msg, Object... args) {
|
||||||
|
|
|
@ -19,9 +19,6 @@
|
||||||
|
|
||||||
package org.elasticsearch;
|
package org.elasticsearch;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public interface ElasticsearchWrapperException {
|
public interface ElasticsearchWrapperException {
|
||||||
|
|
||||||
Throwable getCause();
|
Throwable getCause();
|
||||||
|
|
|
@ -29,8 +29,6 @@ import org.elasticsearch.monitor.jvm.JvmInfo;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class Version {
|
public class Version {
|
||||||
/*
|
/*
|
||||||
* The logic for ID is: XXYYZZAA, where XX is major version, YY is minor version, ZZ is revision, and AA is alpha/beta/rc indicator AA
|
* The logic for ID is: XXYYZZAA, where XX is major version, YY is minor version, ZZ is revision, and AA is alpha/beta/rc indicator AA
|
||||||
|
@ -91,6 +89,8 @@ public class Version {
|
||||||
public static final Version V_5_0_0_beta1 = new Version(V_5_0_0_beta1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
public static final Version V_5_0_0_beta1 = new Version(V_5_0_0_beta1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
||||||
public static final int V_5_0_0_rc1_ID = 5000051;
|
public static final int V_5_0_0_rc1_ID = 5000051;
|
||||||
public static final Version V_5_0_0_rc1 = new Version(V_5_0_0_rc1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
public static final Version V_5_0_0_rc1 = new Version(V_5_0_0_rc1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
||||||
|
public static final int V_5_0_0_rc2_ID = 5000052;
|
||||||
|
public static final Version V_5_0_0_rc2 = new Version(V_5_0_0_rc2_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
||||||
public static final int V_6_0_0_alpha1_ID = 6000001;
|
public static final int V_6_0_0_alpha1_ID = 6000001;
|
||||||
public static final Version V_6_0_0_alpha1 = new Version(V_6_0_0_alpha1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
public static final Version V_6_0_0_alpha1 = new Version(V_6_0_0_alpha1_ID, org.apache.lucene.util.Version.LUCENE_6_2_0);
|
||||||
public static final Version CURRENT = V_6_0_0_alpha1;
|
public static final Version CURRENT = V_6_0_0_alpha1;
|
||||||
|
@ -108,6 +108,8 @@ public class Version {
|
||||||
switch (id) {
|
switch (id) {
|
||||||
case V_6_0_0_alpha1_ID:
|
case V_6_0_0_alpha1_ID:
|
||||||
return V_6_0_0_alpha1;
|
return V_6_0_0_alpha1;
|
||||||
|
case V_5_0_0_rc2_ID:
|
||||||
|
return V_5_0_0_rc2;
|
||||||
case V_5_0_0_rc1_ID:
|
case V_5_0_0_rc1_ID:
|
||||||
return V_5_0_0_rc1;
|
return V_5_0_0_rc1;
|
||||||
case V_5_0_0_beta1_ID:
|
case V_5_0_0_beta1_ID:
|
||||||
|
|
|
@ -25,9 +25,6 @@ import org.elasticsearch.transport.TransportRequest;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public abstract class ActionRequest<Request extends ActionRequest<Request>> extends TransportRequest {
|
public abstract class ActionRequest<Request extends ActionRequest<Request>> extends TransportRequest {
|
||||||
|
|
||||||
public ActionRequest() {
|
public ActionRequest() {
|
||||||
|
|
|
@ -26,9 +26,6 @@ import org.elasticsearch.threadpool.ThreadPool;
|
||||||
|
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public abstract class ActionRequestBuilder<Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> {
|
public abstract class ActionRequestBuilder<Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> {
|
||||||
|
|
||||||
protected final Action<Request, Response, RequestBuilder> action;
|
protected final Action<Request, Response, RequestBuilder> action;
|
||||||
|
|
|
@ -25,9 +25,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class FailedNodeException extends ElasticsearchException {
|
public class FailedNodeException extends ElasticsearchException {
|
||||||
|
|
||||||
private final String nodeId;
|
private final String nodeId;
|
||||||
|
|
|
@ -26,9 +26,6 @@ import org.elasticsearch.rest.RestStatus;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NoShardAvailableActionException extends ElasticsearchException {
|
public class NoShardAvailableActionException extends ElasticsearchException {
|
||||||
|
|
||||||
public NoShardAvailableActionException(ShardId shardId) {
|
public NoShardAvailableActionException(ShardId shardId) {
|
||||||
|
|
|
@ -23,9 +23,6 @@ import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NoSuchNodeException extends FailedNodeException {
|
public class NoSuchNodeException extends FailedNodeException {
|
||||||
|
|
||||||
public NoSuchNodeException(String nodeId) {
|
public NoSuchNodeException(String nodeId) {
|
||||||
|
|
|
@ -24,9 +24,6 @@ import org.elasticsearch.common.io.stream.StreamInput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class PrimaryMissingActionException extends ElasticsearchException {
|
public class PrimaryMissingActionException extends ElasticsearchException {
|
||||||
|
|
||||||
public PrimaryMissingActionException(String message) {
|
public PrimaryMissingActionException(String message) {
|
||||||
|
|
|
@ -27,9 +27,6 @@ import org.elasticsearch.rest.RestStatus;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class RoutingMissingException extends ElasticsearchException {
|
public class RoutingMissingException extends ElasticsearchException {
|
||||||
|
|
||||||
private final String type;
|
private final String type;
|
||||||
|
|
|
@ -20,9 +20,6 @@
|
||||||
package org.elasticsearch.action;
|
package org.elasticsearch.action;
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public enum ThreadingModel {
|
public enum ThreadingModel {
|
||||||
NONE((byte) 0),
|
NONE((byte) 0),
|
||||||
OPERATION((byte) 1),
|
OPERATION((byte) 1),
|
||||||
|
|
|
@ -25,8 +25,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TimestampParsingException extends ElasticsearchException {
|
public class TimestampParsingException extends ElasticsearchException {
|
||||||
|
|
||||||
private final String timestamp;
|
private final String timestamp;
|
||||||
|
|
|
@ -27,9 +27,6 @@ import org.elasticsearch.rest.RestStatus;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class UnavailableShardsException extends ElasticsearchException {
|
public class UnavailableShardsException extends ElasticsearchException {
|
||||||
|
|
||||||
public UnavailableShardsException(@Nullable ShardId shardId, String message, Object... args) {
|
public UnavailableShardsException(@Nullable ShardId shardId, String message, Object... args) {
|
||||||
|
|
|
@ -19,9 +19,6 @@
|
||||||
|
|
||||||
package org.elasticsearch.action;
|
package org.elasticsearch.action;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ValidateActions {
|
public class ValidateActions {
|
||||||
|
|
||||||
public static ActionRequestValidationException addValidationError(String error, ActionRequestValidationException validationException) {
|
public static ActionRequestValidationException addValidationError(String error, ActionRequestValidationException validationException) {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.health;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterHealthAction extends Action<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
|
public class ClusterHealthAction extends Action<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterHealthAction INSTANCE = new ClusterHealthAction();
|
public static final ClusterHealthAction INSTANCE = new ClusterHealthAction();
|
||||||
|
|
|
@ -34,9 +34,6 @@ import org.elasticsearch.common.unit.TimeValue;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterHealthRequest extends MasterNodeReadRequest<ClusterHealthRequest> implements IndicesRequest.Replaceable {
|
public class ClusterHealthRequest extends MasterNodeReadRequest<ClusterHealthRequest> implements IndicesRequest.Replaceable {
|
||||||
|
|
||||||
private String[] indices;
|
private String[] indices;
|
||||||
|
|
|
@ -26,9 +26,6 @@ import org.elasticsearch.cluster.health.ClusterHealthStatus;
|
||||||
import org.elasticsearch.common.Priority;
|
import org.elasticsearch.common.Priority;
|
||||||
import org.elasticsearch.common.unit.TimeValue;
|
import org.elasticsearch.common.unit.TimeValue;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterHealthRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
|
public class ClusterHealthRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterHealthRequest, ClusterHealthResponse, ClusterHealthRequestBuilder> {
|
||||||
|
|
||||||
public ClusterHealthRequestBuilder(ElasticsearchClient client, ClusterHealthAction action) {
|
public ClusterHealthRequestBuilder(ElasticsearchClient client, ClusterHealthAction action) {
|
||||||
|
|
|
@ -36,9 +36,6 @@ import java.io.IOException;
|
||||||
import java.util.Locale;
|
import java.util.Locale;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterHealthResponse extends ActionResponse implements StatusToXContent {
|
public class ClusterHealthResponse extends ActionResponse implements StatusToXContent {
|
||||||
private String clusterName;
|
private String clusterName;
|
||||||
private int numberOfPendingTasks = 0;
|
private int numberOfPendingTasks = 0;
|
||||||
|
|
|
@ -44,9 +44,6 @@ import org.elasticsearch.tasks.Task;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportClusterHealthAction extends TransportMasterNodeReadAction<ClusterHealthRequest, ClusterHealthResponse> {
|
public class TransportClusterHealthAction extends TransportMasterNodeReadAction<ClusterHealthRequest, ClusterHealthResponse> {
|
||||||
|
|
||||||
private final GatewayAllocator gatewayAllocator;
|
private final GatewayAllocator gatewayAllocator;
|
||||||
|
|
|
@ -26,8 +26,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodeHotThreads extends BaseNodeResponse {
|
public class NodeHotThreads extends BaseNodeResponse {
|
||||||
|
|
||||||
private String hotThreads;
|
private String hotThreads;
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.node.hotthreads;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesHotThreadsAction extends Action<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
|
public class NodesHotThreadsAction extends Action<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
|
||||||
|
|
||||||
public static final NodesHotThreadsAction INSTANCE = new NodesHotThreadsAction();
|
public static final NodesHotThreadsAction INSTANCE = new NodesHotThreadsAction();
|
||||||
|
|
|
@ -27,8 +27,6 @@ import org.elasticsearch.common.unit.TimeValue;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesHotThreadsRequest extends BaseNodesRequest<NodesHotThreadsRequest> {
|
public class NodesHotThreadsRequest extends BaseNodesRequest<NodesHotThreadsRequest> {
|
||||||
|
|
||||||
int threads = 3;
|
int threads = 3;
|
||||||
|
|
|
@ -23,8 +23,6 @@ import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
import org.elasticsearch.common.unit.TimeValue;
|
import org.elasticsearch.common.unit.TimeValue;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesHotThreadsRequestBuilder extends NodesOperationRequestBuilder<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
|
public class NodesHotThreadsRequestBuilder extends NodesOperationRequestBuilder<NodesHotThreadsRequest, NodesHotThreadsResponse, NodesHotThreadsRequestBuilder> {
|
||||||
|
|
||||||
public NodesHotThreadsRequestBuilder(ElasticsearchClient client, NodesHotThreadsAction action) {
|
public NodesHotThreadsRequestBuilder(ElasticsearchClient client, NodesHotThreadsAction action) {
|
||||||
|
|
|
@ -28,8 +28,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesHotThreadsResponse extends BaseNodesResponse<NodeHotThreads> {
|
public class NodesHotThreadsResponse extends BaseNodesResponse<NodeHotThreads> {
|
||||||
|
|
||||||
NodesHotThreadsResponse() {
|
NodesHotThreadsResponse() {
|
||||||
|
|
|
@ -38,9 +38,6 @@ import org.elasticsearch.transport.TransportService;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportNodesHotThreadsAction extends TransportNodesAction<NodesHotThreadsRequest,
|
public class TransportNodesHotThreadsAction extends TransportNodesAction<NodesHotThreadsRequest,
|
||||||
NodesHotThreadsResponse,
|
NodesHotThreadsResponse,
|
||||||
TransportNodesHotThreadsAction.NodeRequest,
|
TransportNodesHotThreadsAction.NodeRequest,
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.node.info;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesInfoAction extends Action<NodesInfoRequest, NodesInfoResponse, NodesInfoRequestBuilder> {
|
public class NodesInfoAction extends Action<NodesInfoRequest, NodesInfoResponse, NodesInfoRequestBuilder> {
|
||||||
|
|
||||||
public static final NodesInfoAction INSTANCE = new NodesInfoAction();
|
public static final NodesInfoAction INSTANCE = new NodesInfoAction();
|
||||||
|
|
|
@ -22,9 +22,6 @@ package org.elasticsearch.action.admin.cluster.node.info;
|
||||||
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NodesInfoRequestBuilder extends NodesOperationRequestBuilder<NodesInfoRequest, NodesInfoResponse, NodesInfoRequestBuilder> {
|
public class NodesInfoRequestBuilder extends NodesOperationRequestBuilder<NodesInfoRequest, NodesInfoResponse, NodesInfoRequestBuilder> {
|
||||||
|
|
||||||
public NodesInfoRequestBuilder(ElasticsearchClient client, NodesInfoAction action) {
|
public NodesInfoRequestBuilder(ElasticsearchClient client, NodesInfoAction action) {
|
||||||
|
|
|
@ -34,9 +34,6 @@ import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NodesInfoResponse extends BaseNodesResponse<NodeInfo> implements ToXContent {
|
public class NodesInfoResponse extends BaseNodesResponse<NodeInfo> implements ToXContent {
|
||||||
|
|
||||||
public NodesInfoResponse() {
|
public NodesInfoResponse() {
|
||||||
|
|
|
@ -36,9 +36,6 @@ import org.elasticsearch.transport.TransportService;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportNodesInfoAction extends TransportNodesAction<NodesInfoRequest,
|
public class TransportNodesInfoAction extends TransportNodesAction<NodesInfoRequest,
|
||||||
NodesInfoResponse,
|
NodesInfoResponse,
|
||||||
TransportNodesInfoAction.NodeInfoRequest,
|
TransportNodesInfoAction.NodeInfoRequest,
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.node.stats;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class NodesStatsAction extends Action<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
|
public class NodesStatsAction extends Action<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
|
||||||
|
|
||||||
public static final NodesStatsAction INSTANCE = new NodesStatsAction();
|
public static final NodesStatsAction INSTANCE = new NodesStatsAction();
|
||||||
|
|
|
@ -23,9 +23,6 @@ import org.elasticsearch.action.admin.indices.stats.CommonStatsFlags;
|
||||||
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NodesStatsRequestBuilder extends NodesOperationRequestBuilder<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
|
public class NodesStatsRequestBuilder extends NodesOperationRequestBuilder<NodesStatsRequest, NodesStatsResponse, NodesStatsRequestBuilder> {
|
||||||
|
|
||||||
public NodesStatsRequestBuilder(ElasticsearchClient client, NodesStatsAction action) {
|
public NodesStatsRequestBuilder(ElasticsearchClient client, NodesStatsAction action) {
|
||||||
|
|
|
@ -31,9 +31,6 @@ import org.elasticsearch.common.xcontent.XContentFactory;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class NodesStatsResponse extends BaseNodesResponse<NodeStats> implements ToXContent {
|
public class NodesStatsResponse extends BaseNodesResponse<NodeStats> implements ToXContent {
|
||||||
|
|
||||||
NodesStatsResponse() {
|
NodesStatsResponse() {
|
||||||
|
|
|
@ -36,9 +36,6 @@ import org.elasticsearch.transport.TransportService;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportNodesStatsAction extends TransportNodesAction<NodesStatsRequest,
|
public class TransportNodesStatsAction extends TransportNodesAction<NodesStatsRequest,
|
||||||
NodesStatsResponse,
|
NodesStatsResponse,
|
||||||
TransportNodesStatsAction.NodeStatsRequest,
|
TransportNodesStatsAction.NodeStatsRequest,
|
||||||
|
|
|
@ -40,9 +40,6 @@ import java.util.function.Consumer;
|
||||||
|
|
||||||
import static org.elasticsearch.common.unit.TimeValue.timeValueSeconds;
|
import static org.elasticsearch.common.unit.TimeValue.timeValueSeconds;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportListTasksAction extends TransportTasksAction<Task, ListTasksRequest, ListTasksResponse, TaskInfo> {
|
public class TransportListTasksAction extends TransportTasksAction<Task, ListTasksRequest, ListTasksResponse, TaskInfo> {
|
||||||
public static long waitForCompletionTimeout(TimeValue timeout) {
|
public static long waitForCompletionTimeout(TimeValue timeout) {
|
||||||
if (timeout == null) {
|
if (timeout == null) {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.reroute;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterRerouteAction extends Action<ClusterRerouteRequest, ClusterRerouteResponse, ClusterRerouteRequestBuilder> {
|
public class ClusterRerouteAction extends Action<ClusterRerouteRequest, ClusterRerouteResponse, ClusterRerouteRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterRerouteAction INSTANCE = new ClusterRerouteAction();
|
public static final ClusterRerouteAction INSTANCE = new ClusterRerouteAction();
|
||||||
|
|
|
@ -39,8 +39,6 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportClusterRerouteAction extends TransportMasterNodeAction<ClusterRerouteRequest, ClusterRerouteResponse> {
|
public class TransportClusterRerouteAction extends TransportMasterNodeAction<ClusterRerouteRequest, ClusterRerouteResponse> {
|
||||||
|
|
||||||
private final AllocationService allocationService;
|
private final AllocationService allocationService;
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.settings;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterUpdateSettingsAction extends Action<ClusterUpdateSettingsRequest, ClusterUpdateSettingsResponse, ClusterUpdateSettingsRequestBuilder> {
|
public class ClusterUpdateSettingsAction extends Action<ClusterUpdateSettingsRequest, ClusterUpdateSettingsResponse, ClusterUpdateSettingsRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterUpdateSettingsAction INSTANCE = new ClusterUpdateSettingsAction();
|
public static final ClusterUpdateSettingsAction INSTANCE = new ClusterUpdateSettingsAction();
|
||||||
|
|
|
@ -42,19 +42,19 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
/**
|
public class TransportClusterUpdateSettingsAction extends
|
||||||
*
|
TransportMasterNodeAction<ClusterUpdateSettingsRequest, ClusterUpdateSettingsResponse> {
|
||||||
*/
|
|
||||||
public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAction<ClusterUpdateSettingsRequest, ClusterUpdateSettingsResponse> {
|
|
||||||
|
|
||||||
private final AllocationService allocationService;
|
private final AllocationService allocationService;
|
||||||
|
|
||||||
private final ClusterSettings clusterSettings;
|
private final ClusterSettings clusterSettings;
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
public TransportClusterUpdateSettingsAction(Settings settings, TransportService transportService, ClusterService clusterService, ThreadPool threadPool,
|
public TransportClusterUpdateSettingsAction(Settings settings, TransportService transportService, ClusterService clusterService,
|
||||||
AllocationService allocationService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, ClusterSettings clusterSettings) {
|
ThreadPool threadPool, AllocationService allocationService, ActionFilters actionFilters,
|
||||||
super(settings, ClusterUpdateSettingsAction.NAME, transportService, clusterService, threadPool, actionFilters, indexNameExpressionResolver, ClusterUpdateSettingsRequest::new);
|
IndexNameExpressionResolver indexNameExpressionResolver, ClusterSettings clusterSettings) {
|
||||||
|
super(settings, ClusterUpdateSettingsAction.NAME, false, transportService, clusterService, threadPool, actionFilters,
|
||||||
|
indexNameExpressionResolver, ClusterUpdateSettingsRequest::new);
|
||||||
this.allocationService = allocationService;
|
this.allocationService = allocationService;
|
||||||
this.clusterSettings = clusterSettings;
|
this.clusterSettings = clusterSettings;
|
||||||
}
|
}
|
||||||
|
@ -67,8 +67,11 @@ public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAct
|
||||||
@Override
|
@Override
|
||||||
protected ClusterBlockException checkBlock(ClusterUpdateSettingsRequest request, ClusterState state) {
|
protected ClusterBlockException checkBlock(ClusterUpdateSettingsRequest request, ClusterState state) {
|
||||||
// allow for dedicated changes to the metadata blocks, so we don't block those to allow to "re-enable" it
|
// allow for dedicated changes to the metadata blocks, so we don't block those to allow to "re-enable" it
|
||||||
if ((request.transientSettings().getAsMap().isEmpty() && request.persistentSettings().getAsMap().size() == 1 && MetaData.SETTING_READ_ONLY_SETTING.exists(request.persistentSettings())) ||
|
if ((request.transientSettings().getAsMap().isEmpty() &&
|
||||||
request.persistentSettings().getAsMap().isEmpty() && request.transientSettings().getAsMap().size() == 1 && MetaData.SETTING_READ_ONLY_SETTING.exists(request.transientSettings())) {
|
request.persistentSettings().getAsMap().size() == 1 &&
|
||||||
|
MetaData.SETTING_READ_ONLY_SETTING.exists(request.persistentSettings())) ||
|
||||||
|
(request.persistentSettings().getAsMap().isEmpty() && request.transientSettings().getAsMap().size() == 1 &&
|
||||||
|
MetaData.SETTING_READ_ONLY_SETTING.exists(request.transientSettings()))) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
return state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_WRITE);
|
return state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_WRITE);
|
||||||
|
@ -81,7 +84,8 @@ public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAct
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void masterOperation(final ClusterUpdateSettingsRequest request, final ClusterState state, final ActionListener<ClusterUpdateSettingsResponse> listener) {
|
protected void masterOperation(final ClusterUpdateSettingsRequest request, final ClusterState state,
|
||||||
|
final ActionListener<ClusterUpdateSettingsResponse> listener) {
|
||||||
final SettingsUpdater updater = new SettingsUpdater(clusterSettings);
|
final SettingsUpdater updater = new SettingsUpdater(clusterSettings);
|
||||||
clusterService.submitStateUpdateTask("cluster_update_settings",
|
clusterService.submitStateUpdateTask("cluster_update_settings",
|
||||||
new AckedClusterStateUpdateTask<ClusterUpdateSettingsResponse>(Priority.IMMEDIATE, request, listener) {
|
new AckedClusterStateUpdateTask<ClusterUpdateSettingsResponse>(Priority.IMMEDIATE, request, listener) {
|
||||||
|
@ -117,7 +121,8 @@ public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAct
|
||||||
// so we should *not* execute the reroute.
|
// so we should *not* execute the reroute.
|
||||||
if (!clusterService.state().nodes().isLocalNodeElectedMaster()) {
|
if (!clusterService.state().nodes().isLocalNodeElectedMaster()) {
|
||||||
logger.debug("Skipping reroute after cluster update settings, because node is no longer master");
|
logger.debug("Skipping reroute after cluster update settings, because node is no longer master");
|
||||||
listener.onResponse(new ClusterUpdateSettingsResponse(updateSettingsAcked, updater.getTransientUpdates(), updater.getPersistentUpdate()));
|
listener.onResponse(new ClusterUpdateSettingsResponse(updateSettingsAcked, updater.getTransientUpdates(),
|
||||||
|
updater.getPersistentUpdate()));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -135,15 +140,18 @@ public class TransportClusterUpdateSettingsAction extends TransportMasterNodeAct
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
//we return when the cluster reroute is acked or it times out but the acknowledged flag depends on whether the update settings was acknowledged
|
// we return when the cluster reroute is acked or it times out but the acknowledged flag depends on whether the
|
||||||
|
// update settings was acknowledged
|
||||||
protected ClusterUpdateSettingsResponse newResponse(boolean acknowledged) {
|
protected ClusterUpdateSettingsResponse newResponse(boolean acknowledged) {
|
||||||
return new ClusterUpdateSettingsResponse(updateSettingsAcked && acknowledged, updater.getTransientUpdates(), updater.getPersistentUpdate());
|
return new ClusterUpdateSettingsResponse(updateSettingsAcked && acknowledged, updater.getTransientUpdates(),
|
||||||
|
updater.getPersistentUpdate());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onNoLongerMaster(String source) {
|
public void onNoLongerMaster(String source) {
|
||||||
logger.debug("failed to preform reroute after cluster settings were updated - current node is no longer a master");
|
logger.debug("failed to preform reroute after cluster settings were updated - current node is no longer a master");
|
||||||
listener.onResponse(new ClusterUpdateSettingsResponse(updateSettingsAcked, updater.getTransientUpdates(), updater.getPersistentUpdate()));
|
listener.onResponse(new ClusterUpdateSettingsResponse(updateSettingsAcked, updater.getTransientUpdates(),
|
||||||
|
updater.getPersistentUpdate()));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.shards;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterSearchShardsAction extends Action<ClusterSearchShardsRequest, ClusterSearchShardsResponse, ClusterSearchShardsRequestBuilder> {
|
public class ClusterSearchShardsAction extends Action<ClusterSearchShardsRequest, ClusterSearchShardsResponse, ClusterSearchShardsRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterSearchShardsAction INSTANCE = new ClusterSearchShardsAction();
|
public static final ClusterSearchShardsAction INSTANCE = new ClusterSearchShardsAction();
|
||||||
|
|
|
@ -30,8 +30,6 @@ import org.elasticsearch.index.shard.ShardId;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterSearchShardsGroup implements Streamable, ToXContent {
|
public class ClusterSearchShardsGroup implements Streamable, ToXContent {
|
||||||
|
|
||||||
private ShardId shardId;
|
private ShardId shardId;
|
||||||
|
|
|
@ -30,8 +30,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterSearchShardsRequest extends MasterNodeReadRequest<ClusterSearchShardsRequest> implements IndicesRequest.Replaceable {
|
public class ClusterSearchShardsRequest extends MasterNodeReadRequest<ClusterSearchShardsRequest> implements IndicesRequest.Replaceable {
|
||||||
private String[] indices;
|
private String[] indices;
|
||||||
@Nullable
|
@Nullable
|
||||||
|
|
|
@ -23,8 +23,6 @@ import org.elasticsearch.action.support.IndicesOptions;
|
||||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterSearchShardsRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterSearchShardsRequest, ClusterSearchShardsResponse, ClusterSearchShardsRequestBuilder> {
|
public class ClusterSearchShardsRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterSearchShardsRequest, ClusterSearchShardsResponse, ClusterSearchShardsRequestBuilder> {
|
||||||
|
|
||||||
public ClusterSearchShardsRequestBuilder(ElasticsearchClient client, ClusterSearchShardsAction action) {
|
public ClusterSearchShardsRequestBuilder(ElasticsearchClient client, ClusterSearchShardsAction action) {
|
||||||
|
|
|
@ -28,8 +28,6 @@ import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterSearchShardsResponse extends ActionResponse implements ToXContent {
|
public class ClusterSearchShardsResponse extends ActionResponse implements ToXContent {
|
||||||
|
|
||||||
private ClusterSearchShardsGroup[] groups;
|
private ClusterSearchShardsGroup[] groups;
|
||||||
|
|
|
@ -42,8 +42,6 @@ import java.util.HashSet;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportClusterSearchShardsAction extends TransportMasterNodeReadAction<ClusterSearchShardsRequest, ClusterSearchShardsResponse> {
|
public class TransportClusterSearchShardsAction extends TransportMasterNodeReadAction<ClusterSearchShardsRequest, ClusterSearchShardsResponse> {
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
|
|
@ -22,19 +22,27 @@ package org.elasticsearch.action.admin.cluster.snapshots.restore;
|
||||||
import org.elasticsearch.action.ActionListener;
|
import org.elasticsearch.action.ActionListener;
|
||||||
import org.elasticsearch.action.support.ActionFilters;
|
import org.elasticsearch.action.support.ActionFilters;
|
||||||
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
import org.elasticsearch.action.support.master.TransportMasterNodeAction;
|
||||||
|
import org.elasticsearch.cluster.ClusterChangedEvent;
|
||||||
import org.elasticsearch.cluster.ClusterState;
|
import org.elasticsearch.cluster.ClusterState;
|
||||||
|
import org.elasticsearch.cluster.ClusterStateListener;
|
||||||
|
import org.elasticsearch.cluster.RestoreInProgress;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockException;
|
import org.elasticsearch.cluster.block.ClusterBlockException;
|
||||||
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
import org.elasticsearch.cluster.block.ClusterBlockLevel;
|
||||||
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
|
||||||
import org.elasticsearch.cluster.service.ClusterService;
|
import org.elasticsearch.cluster.service.ClusterService;
|
||||||
|
import org.elasticsearch.common.collect.ImmutableOpenMap;
|
||||||
import org.elasticsearch.common.inject.Inject;
|
import org.elasticsearch.common.inject.Inject;
|
||||||
import org.elasticsearch.common.settings.Settings;
|
import org.elasticsearch.common.settings.Settings;
|
||||||
|
import org.elasticsearch.index.shard.ShardId;
|
||||||
import org.elasticsearch.snapshots.RestoreInfo;
|
import org.elasticsearch.snapshots.RestoreInfo;
|
||||||
import org.elasticsearch.snapshots.RestoreService;
|
import org.elasticsearch.snapshots.RestoreService;
|
||||||
|
import org.elasticsearch.snapshots.RestoreService.RestoreCompletionResponse;
|
||||||
import org.elasticsearch.snapshots.Snapshot;
|
import org.elasticsearch.snapshots.Snapshot;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
|
import static org.elasticsearch.snapshots.RestoreService.restoreInProgress;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Transport action for restore snapshot operation
|
* Transport action for restore snapshot operation
|
||||||
*/
|
*/
|
||||||
|
@ -78,28 +86,44 @@ public class TransportRestoreSnapshotAction extends TransportMasterNodeAction<Re
|
||||||
request.settings(), request.masterNodeTimeout(), request.includeGlobalState(), request.partial(), request.includeAliases(),
|
request.settings(), request.masterNodeTimeout(), request.includeGlobalState(), request.partial(), request.includeAliases(),
|
||||||
request.indexSettings(), request.ignoreIndexSettings(), "restore_snapshot[" + request.snapshot() + "]");
|
request.indexSettings(), request.ignoreIndexSettings(), "restore_snapshot[" + request.snapshot() + "]");
|
||||||
|
|
||||||
restoreService.restoreSnapshot(restoreRequest, new ActionListener<RestoreInfo>() {
|
restoreService.restoreSnapshot(restoreRequest, new ActionListener<RestoreCompletionResponse>() {
|
||||||
@Override
|
@Override
|
||||||
public void onResponse(RestoreInfo restoreInfo) {
|
public void onResponse(RestoreCompletionResponse restoreCompletionResponse) {
|
||||||
if (restoreInfo == null && request.waitForCompletion()) {
|
if (restoreCompletionResponse.getRestoreInfo() == null && request.waitForCompletion()) {
|
||||||
restoreService.addListener(new ActionListener<RestoreService.RestoreCompletionResponse>() {
|
final Snapshot snapshot = restoreCompletionResponse.getSnapshot();
|
||||||
|
|
||||||
|
ClusterStateListener clusterStateListener = new ClusterStateListener() {
|
||||||
@Override
|
@Override
|
||||||
public void onResponse(RestoreService.RestoreCompletionResponse restoreCompletionResponse) {
|
public void clusterChanged(ClusterChangedEvent changedEvent) {
|
||||||
final Snapshot snapshot = restoreCompletionResponse.getSnapshot();
|
final RestoreInProgress.Entry prevEntry = restoreInProgress(changedEvent.previousState(), snapshot);
|
||||||
if (snapshot.getRepository().equals(request.repository()) &&
|
final RestoreInProgress.Entry newEntry = restoreInProgress(changedEvent.state(), snapshot);
|
||||||
snapshot.getSnapshotId().getName().equals(request.snapshot())) {
|
if (prevEntry == null) {
|
||||||
listener.onResponse(new RestoreSnapshotResponse(restoreCompletionResponse.getRestoreInfo()));
|
// When there is a master failure after a restore has been started, this listener might not be registered
|
||||||
restoreService.removeListener(this);
|
// on the current master and as such it might miss some intermediary cluster states due to batching.
|
||||||
|
// Clean up listener in that case and acknowledge completion of restore operation to client.
|
||||||
|
clusterService.remove(this);
|
||||||
|
listener.onResponse(new RestoreSnapshotResponse(null));
|
||||||
|
} else if (newEntry == null) {
|
||||||
|
clusterService.remove(this);
|
||||||
|
ImmutableOpenMap<ShardId, RestoreInProgress.ShardRestoreStatus> shards = prevEntry.shards();
|
||||||
|
assert prevEntry.state().completed() : "expected completed snapshot state but was " + prevEntry.state();
|
||||||
|
assert RestoreService.completed(shards) : "expected all restore entries to be completed";
|
||||||
|
RestoreInfo ri = new RestoreInfo(prevEntry.snapshot().getSnapshotId().getName(),
|
||||||
|
prevEntry.indices(),
|
||||||
|
shards.size(),
|
||||||
|
shards.size() - RestoreService.failedShards(shards));
|
||||||
|
RestoreSnapshotResponse response = new RestoreSnapshotResponse(ri);
|
||||||
|
logger.debug("restore of [{}] completed", snapshot);
|
||||||
|
listener.onResponse(response);
|
||||||
|
} else {
|
||||||
|
// restore not completed yet, wait for next cluster state update
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
};
|
||||||
|
|
||||||
@Override
|
clusterService.addLast(clusterStateListener);
|
||||||
public void onFailure(Exception e) {
|
|
||||||
listener.onFailure(e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
} else {
|
||||||
listener.onResponse(new RestoreSnapshotResponse(restoreInfo));
|
listener.onResponse(new RestoreSnapshotResponse(restoreCompletionResponse.getRestoreInfo()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -20,8 +20,6 @@
|
||||||
package org.elasticsearch.action.admin.cluster.snapshots.status;
|
package org.elasticsearch.action.admin.cluster.snapshots.status;
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public enum SnapshotIndexShardStage {
|
public enum SnapshotIndexShardStage {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -29,8 +29,6 @@ import org.elasticsearch.index.snapshots.IndexShardSnapshotStatus;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class SnapshotIndexShardStatus extends BroadcastShardResponse implements ToXContent {
|
public class SnapshotIndexShardStatus extends BroadcastShardResponse implements ToXContent {
|
||||||
|
|
||||||
private SnapshotIndexShardStage stage = SnapshotIndexShardStage.INIT;
|
private SnapshotIndexShardStage stage = SnapshotIndexShardStage.INIT;
|
||||||
|
|
|
@ -28,8 +28,6 @@ import org.elasticsearch.index.snapshots.IndexShardSnapshotStatus;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class SnapshotStats implements Streamable, ToXContent {
|
public class SnapshotStats implements Streamable, ToXContent {
|
||||||
private long startTime;
|
private long startTime;
|
||||||
|
|
||||||
|
|
|
@ -56,8 +56,6 @@ import java.util.Set;
|
||||||
import java.util.function.Function;
|
import java.util.function.Function;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportSnapshotsStatusAction extends TransportMasterNodeAction<SnapshotsStatusRequest, SnapshotsStatusResponse> {
|
public class TransportSnapshotsStatusAction extends TransportMasterNodeAction<SnapshotsStatusRequest, SnapshotsStatusResponse> {
|
||||||
|
|
||||||
private final SnapshotsService snapshotsService;
|
private final SnapshotsService snapshotsService;
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.state;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterStateAction extends Action<ClusterStateRequest, ClusterStateResponse, ClusterStateRequestBuilder> {
|
public class ClusterStateAction extends Action<ClusterStateRequest, ClusterStateResponse, ClusterStateRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterStateAction INSTANCE = new ClusterStateAction();
|
public static final ClusterStateAction INSTANCE = new ClusterStateAction();
|
||||||
|
|
|
@ -29,9 +29,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterStateRequest extends MasterNodeReadRequest<ClusterStateRequest> implements IndicesRequest.Replaceable {
|
public class ClusterStateRequest extends MasterNodeReadRequest<ClusterStateRequest> implements IndicesRequest.Replaceable {
|
||||||
|
|
||||||
private boolean routingTable = true;
|
private boolean routingTable = true;
|
||||||
|
|
|
@ -23,9 +23,6 @@ import org.elasticsearch.action.support.IndicesOptions;
|
||||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterStateRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterStateRequest, ClusterStateResponse, ClusterStateRequestBuilder> {
|
public class ClusterStateRequestBuilder extends MasterNodeReadOperationRequestBuilder<ClusterStateRequest, ClusterStateResponse, ClusterStateRequestBuilder> {
|
||||||
|
|
||||||
public ClusterStateRequestBuilder(ElasticsearchClient client, ClusterStateAction action) {
|
public ClusterStateRequestBuilder(ElasticsearchClient client, ClusterStateAction action) {
|
||||||
|
|
|
@ -27,9 +27,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterStateResponse extends ActionResponse {
|
public class ClusterStateResponse extends ActionResponse {
|
||||||
|
|
||||||
private ClusterName clusterName;
|
private ClusterName clusterName;
|
||||||
|
|
|
@ -36,9 +36,6 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportClusterStateAction extends TransportMasterNodeReadAction<ClusterStateRequest, ClusterStateResponse> {
|
public class TransportClusterStateAction extends TransportMasterNodeReadAction<ClusterStateRequest, ClusterStateResponse> {
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.stats;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClusterStatsAction extends Action<ClusterStatsRequest, ClusterStatsResponse, ClusterStatsRequestBuilder> {
|
public class ClusterStatsAction extends Action<ClusterStatsRequest, ClusterStatsResponse, ClusterStatsRequestBuilder> {
|
||||||
|
|
||||||
public static final ClusterStatsAction INSTANCE = new ClusterStatsAction();
|
public static final ClusterStatsAction INSTANCE = new ClusterStatsAction();
|
||||||
|
|
|
@ -22,9 +22,6 @@ package org.elasticsearch.action.admin.cluster.stats;
|
||||||
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
import org.elasticsearch.action.support.nodes.NodesOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterStatsRequestBuilder extends NodesOperationRequestBuilder<ClusterStatsRequest, ClusterStatsResponse, ClusterStatsRequestBuilder> {
|
public class ClusterStatsRequestBuilder extends NodesOperationRequestBuilder<ClusterStatsRequest, ClusterStatsResponse, ClusterStatsRequestBuilder> {
|
||||||
|
|
||||||
public ClusterStatsRequestBuilder(ElasticsearchClient client, ClusterStatsAction action) {
|
public ClusterStatsRequestBuilder(ElasticsearchClient client, ClusterStatsAction action) {
|
||||||
|
|
|
@ -33,9 +33,6 @@ import java.io.IOException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Locale;
|
import java.util.Locale;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClusterStatsResponse extends BaseNodesResponse<ClusterStatsNodeResponse> implements ToXContent {
|
public class ClusterStatsResponse extends BaseNodesResponse<ClusterStatsNodeResponse> implements ToXContent {
|
||||||
|
|
||||||
ClusterStatsNodes nodesStats;
|
ClusterStatsNodes nodesStats;
|
||||||
|
|
|
@ -47,9 +47,6 @@ import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class TransportClusterStatsAction extends TransportNodesAction<ClusterStatsRequest, ClusterStatsResponse,
|
public class TransportClusterStatsAction extends TransportNodesAction<ClusterStatsRequest, ClusterStatsResponse,
|
||||||
TransportClusterStatsAction.ClusterStatsNodeRequest, ClusterStatsNodeResponse> {
|
TransportClusterStatsAction.ClusterStatsNodeRequest, ClusterStatsNodeResponse> {
|
||||||
|
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.storedscripts;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class DeleteStoredScriptAction extends Action<DeleteStoredScriptRequest, DeleteStoredScriptResponse,
|
public class DeleteStoredScriptAction extends Action<DeleteStoredScriptRequest, DeleteStoredScriptResponse,
|
||||||
DeleteStoredScriptRequestBuilder> {
|
DeleteStoredScriptRequestBuilder> {
|
||||||
|
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.storedscripts;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class GetStoredScriptAction extends Action<GetStoredScriptRequest, GetStoredScriptResponse,
|
public class GetStoredScriptAction extends Action<GetStoredScriptRequest, GetStoredScriptResponse,
|
||||||
GetStoredScriptRequestBuilder> {
|
GetStoredScriptRequestBuilder> {
|
||||||
|
|
||||||
|
|
|
@ -23,8 +23,6 @@ import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class PutStoredScriptAction extends Action<PutStoredScriptRequest, PutStoredScriptResponse,
|
public class PutStoredScriptAction extends Action<PutStoredScriptRequest, PutStoredScriptResponse,
|
||||||
PutStoredScriptRequestBuilder> {
|
PutStoredScriptRequestBuilder> {
|
||||||
|
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.tasks;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class PendingClusterTasksAction extends Action<PendingClusterTasksRequest, PendingClusterTasksResponse, PendingClusterTasksRequestBuilder> {
|
public class PendingClusterTasksAction extends Action<PendingClusterTasksRequest, PendingClusterTasksResponse, PendingClusterTasksRequestBuilder> {
|
||||||
|
|
||||||
public static final PendingClusterTasksAction INSTANCE = new PendingClusterTasksAction();
|
public static final PendingClusterTasksAction INSTANCE = new PendingClusterTasksAction();
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.tasks;
|
||||||
import org.elasticsearch.action.ActionRequestValidationException;
|
import org.elasticsearch.action.ActionRequestValidationException;
|
||||||
import org.elasticsearch.action.support.master.MasterNodeReadRequest;
|
import org.elasticsearch.action.support.master.MasterNodeReadRequest;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class PendingClusterTasksRequest extends MasterNodeReadRequest<PendingClusterTasksRequest> {
|
public class PendingClusterTasksRequest extends MasterNodeReadRequest<PendingClusterTasksRequest> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.cluster.tasks;
|
||||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class PendingClusterTasksRequestBuilder extends MasterNodeReadOperationRequestBuilder<PendingClusterTasksRequest, PendingClusterTasksResponse, PendingClusterTasksRequestBuilder> {
|
public class PendingClusterTasksRequestBuilder extends MasterNodeReadOperationRequestBuilder<PendingClusterTasksRequest, PendingClusterTasksResponse, PendingClusterTasksRequestBuilder> {
|
||||||
|
|
||||||
public PendingClusterTasksRequestBuilder(ElasticsearchClient client, PendingClusterTasksAction action) {
|
public PendingClusterTasksRequestBuilder(ElasticsearchClient client, PendingClusterTasksAction action) {
|
||||||
|
|
|
@ -32,8 +32,6 @@ import java.util.ArrayList;
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class PendingClusterTasksResponse extends ActionResponse implements Iterable<PendingClusterTask>, ToXContent {
|
public class PendingClusterTasksResponse extends ActionResponse implements Iterable<PendingClusterTask>, ToXContent {
|
||||||
|
|
||||||
private List<PendingClusterTask> pendingTasks;
|
private List<PendingClusterTask> pendingTasks;
|
||||||
|
|
|
@ -35,8 +35,6 @@ import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportPendingClusterTasksAction extends TransportMasterNodeReadAction<PendingClusterTasksRequest, PendingClusterTasksResponse> {
|
public class TransportPendingClusterTasksAction extends TransportMasterNodeReadAction<PendingClusterTasksRequest, PendingClusterTasksResponse> {
|
||||||
|
|
||||||
private final ClusterService clusterService;
|
private final ClusterService clusterService;
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.alias;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class IndicesAliasesAction extends Action<IndicesAliasesRequest, IndicesAliasesResponse, IndicesAliasesRequestBuilder> {
|
public class IndicesAliasesAction extends Action<IndicesAliasesRequest, IndicesAliasesResponse, IndicesAliasesRequestBuilder> {
|
||||||
|
|
||||||
public static final IndicesAliasesAction INSTANCE = new IndicesAliasesAction();
|
public static final IndicesAliasesAction INSTANCE = new IndicesAliasesAction();
|
||||||
|
|
|
@ -23,8 +23,6 @@ import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest;
|
import org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class AliasesExistAction extends Action<GetAliasesRequest, AliasesExistResponse, AliasesExistRequestBuilder> {
|
public class AliasesExistAction extends Action<GetAliasesRequest, AliasesExistResponse, AliasesExistRequestBuilder> {
|
||||||
|
|
||||||
public static final AliasesExistAction INSTANCE = new AliasesExistAction();
|
public static final AliasesExistAction INSTANCE = new AliasesExistAction();
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.alias.exists;
|
||||||
import org.elasticsearch.action.admin.indices.alias.get.BaseAliasesRequestBuilder;
|
import org.elasticsearch.action.admin.indices.alias.get.BaseAliasesRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class AliasesExistRequestBuilder extends BaseAliasesRequestBuilder<AliasesExistResponse, AliasesExistRequestBuilder> {
|
public class AliasesExistRequestBuilder extends BaseAliasesRequestBuilder<AliasesExistResponse, AliasesExistRequestBuilder> {
|
||||||
|
|
||||||
public AliasesExistRequestBuilder(ElasticsearchClient client, AliasesExistAction action, String... aliases) {
|
public AliasesExistRequestBuilder(ElasticsearchClient client, AliasesExistAction action, String... aliases) {
|
||||||
|
|
|
@ -25,8 +25,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class AliasesExistResponse extends ActionResponse {
|
public class AliasesExistResponse extends ActionResponse {
|
||||||
|
|
||||||
private boolean exists;
|
private boolean exists;
|
||||||
|
|
|
@ -32,8 +32,6 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
import org.elasticsearch.threadpool.ThreadPool;
|
import org.elasticsearch.threadpool.ThreadPool;
|
||||||
import org.elasticsearch.transport.TransportService;
|
import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportAliasesExistAction extends TransportMasterNodeReadAction<GetAliasesRequest, AliasesExistResponse> {
|
public class TransportAliasesExistAction extends TransportMasterNodeReadAction<GetAliasesRequest, AliasesExistResponse> {
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
|
|
@ -26,8 +26,6 @@ import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBui
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
import org.elasticsearch.common.util.ArrayUtils;
|
import org.elasticsearch.common.util.ArrayUtils;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public abstract class BaseAliasesRequestBuilder<Response extends ActionResponse, Builder extends BaseAliasesRequestBuilder<Response, Builder>> extends MasterNodeReadOperationRequestBuilder<GetAliasesRequest, Response, Builder> {
|
public abstract class BaseAliasesRequestBuilder<Response extends ActionResponse, Builder extends BaseAliasesRequestBuilder<Response, Builder>> extends MasterNodeReadOperationRequestBuilder<GetAliasesRequest, Response, Builder> {
|
||||||
|
|
||||||
public BaseAliasesRequestBuilder(ElasticsearchClient client, Action<GetAliasesRequest, Response, Builder> action, String... aliases) {
|
public BaseAliasesRequestBuilder(ElasticsearchClient client, Action<GetAliasesRequest, Response, Builder> action, String... aliases) {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.alias.get;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class GetAliasesAction extends Action<GetAliasesRequest, GetAliasesResponse, GetAliasesRequestBuilder> {
|
public class GetAliasesAction extends Action<GetAliasesRequest, GetAliasesResponse, GetAliasesRequestBuilder> {
|
||||||
|
|
||||||
public static final GetAliasesAction INSTANCE = new GetAliasesAction();
|
public static final GetAliasesAction INSTANCE = new GetAliasesAction();
|
||||||
|
|
|
@ -28,8 +28,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class GetAliasesRequest extends MasterNodeReadRequest<GetAliasesRequest> implements AliasesRequest {
|
public class GetAliasesRequest extends MasterNodeReadRequest<GetAliasesRequest> implements AliasesRequest {
|
||||||
|
|
||||||
private String[] indices = Strings.EMPTY_ARRAY;
|
private String[] indices = Strings.EMPTY_ARRAY;
|
||||||
|
|
|
@ -21,8 +21,6 @@ package org.elasticsearch.action.admin.indices.alias.get;
|
||||||
|
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class GetAliasesRequestBuilder extends BaseAliasesRequestBuilder<GetAliasesResponse, GetAliasesRequestBuilder> {
|
public class GetAliasesRequestBuilder extends BaseAliasesRequestBuilder<GetAliasesResponse, GetAliasesRequestBuilder> {
|
||||||
|
|
||||||
public GetAliasesRequestBuilder(ElasticsearchClient client, GetAliasesAction action, String... aliases) {
|
public GetAliasesRequestBuilder(ElasticsearchClient client, GetAliasesAction action, String... aliases) {
|
||||||
|
|
|
@ -31,8 +31,6 @@ import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class GetAliasesResponse extends ActionResponse {
|
public class GetAliasesResponse extends ActionResponse {
|
||||||
|
|
||||||
private ImmutableOpenMap<String, List<AliasMetaData>> aliases = ImmutableOpenMap.of();
|
private ImmutableOpenMap<String, List<AliasMetaData>> aliases = ImmutableOpenMap.of();
|
||||||
|
|
|
@ -35,8 +35,6 @@ import org.elasticsearch.transport.TransportService;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TransportGetAliasesAction extends TransportMasterNodeReadAction<GetAliasesRequest, GetAliasesResponse> {
|
public class TransportGetAliasesAction extends TransportMasterNodeReadAction<GetAliasesRequest, GetAliasesResponse> {
|
||||||
|
|
||||||
@Inject
|
@Inject
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.analyze;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class AnalyzeAction extends Action<AnalyzeRequest, AnalyzeResponse, AnalyzeRequestBuilder> {
|
public class AnalyzeAction extends Action<AnalyzeRequest, AnalyzeResponse, AnalyzeRequestBuilder> {
|
||||||
|
|
||||||
public static final AnalyzeAction INSTANCE = new AnalyzeAction();
|
public static final AnalyzeAction INSTANCE = new AnalyzeAction();
|
||||||
|
|
|
@ -23,9 +23,6 @@ import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class AnalyzeRequestBuilder extends SingleShardOperationRequestBuilder<AnalyzeRequest, AnalyzeResponse, AnalyzeRequestBuilder> {
|
public class AnalyzeRequestBuilder extends SingleShardOperationRequestBuilder<AnalyzeRequest, AnalyzeResponse, AnalyzeRequestBuilder> {
|
||||||
|
|
||||||
public AnalyzeRequestBuilder(ElasticsearchClient client, AnalyzeAction action) {
|
public AnalyzeRequestBuilder(ElasticsearchClient client, AnalyzeAction action) {
|
||||||
|
|
|
@ -32,9 +32,6 @@ import java.util.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class AnalyzeResponse extends ActionResponse implements Iterable<AnalyzeResponse.AnalyzeToken>, ToXContent {
|
public class AnalyzeResponse extends ActionResponse implements Iterable<AnalyzeResponse.AnalyzeToken>, ToXContent {
|
||||||
|
|
||||||
public static class AnalyzeToken implements Streamable, ToXContent {
|
public static class AnalyzeToken implements Streamable, ToXContent {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.cache.clear;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class ClearIndicesCacheAction extends Action<ClearIndicesCacheRequest, ClearIndicesCacheResponse, ClearIndicesCacheRequestBuilder> {
|
public class ClearIndicesCacheAction extends Action<ClearIndicesCacheRequest, ClearIndicesCacheResponse, ClearIndicesCacheRequestBuilder> {
|
||||||
|
|
||||||
public static final ClearIndicesCacheAction INSTANCE = new ClearIndicesCacheAction();
|
public static final ClearIndicesCacheAction INSTANCE = new ClearIndicesCacheAction();
|
||||||
|
|
|
@ -25,9 +25,6 @@ import org.elasticsearch.common.io.stream.StreamOutput;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClearIndicesCacheRequest extends BroadcastRequest<ClearIndicesCacheRequest> {
|
public class ClearIndicesCacheRequest extends BroadcastRequest<ClearIndicesCacheRequest> {
|
||||||
|
|
||||||
private boolean queryCache = false;
|
private boolean queryCache = false;
|
||||||
|
|
|
@ -22,9 +22,6 @@ package org.elasticsearch.action.admin.indices.cache.clear;
|
||||||
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
|
import org.elasticsearch.action.support.broadcast.BroadcastOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class ClearIndicesCacheRequestBuilder extends BroadcastOperationRequestBuilder<ClearIndicesCacheRequest, ClearIndicesCacheResponse, ClearIndicesCacheRequestBuilder> {
|
public class ClearIndicesCacheRequestBuilder extends BroadcastOperationRequestBuilder<ClearIndicesCacheRequest, ClearIndicesCacheResponse, ClearIndicesCacheRequestBuilder> {
|
||||||
|
|
||||||
public ClearIndicesCacheRequestBuilder(ElasticsearchClient client, ClearIndicesCacheAction action) {
|
public ClearIndicesCacheRequestBuilder(ElasticsearchClient client, ClearIndicesCacheAction action) {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.close;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class CloseIndexAction extends Action<CloseIndexRequest, CloseIndexResponse, CloseIndexRequestBuilder> {
|
public class CloseIndexAction extends Action<CloseIndexRequest, CloseIndexResponse, CloseIndexRequestBuilder> {
|
||||||
|
|
||||||
public static final CloseIndexAction INSTANCE = new CloseIndexAction();
|
public static final CloseIndexAction INSTANCE = new CloseIndexAction();
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.create;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class CreateIndexAction extends Action<CreateIndexRequest, CreateIndexResponse, CreateIndexRequestBuilder> {
|
public class CreateIndexAction extends Action<CreateIndexRequest, CreateIndexResponse, CreateIndexRequestBuilder> {
|
||||||
|
|
||||||
public static final CreateIndexAction INSTANCE = new CreateIndexAction();
|
public static final CreateIndexAction INSTANCE = new CreateIndexAction();
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.delete;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class DeleteIndexAction extends Action<DeleteIndexRequest, DeleteIndexResponse, DeleteIndexRequestBuilder> {
|
public class DeleteIndexAction extends Action<DeleteIndexRequest, DeleteIndexResponse, DeleteIndexRequestBuilder> {
|
||||||
|
|
||||||
public static final DeleteIndexAction INSTANCE = new DeleteIndexAction();
|
public static final DeleteIndexAction INSTANCE = new DeleteIndexAction();
|
||||||
|
|
|
@ -24,9 +24,6 @@ import org.elasticsearch.action.support.master.MasterNodeOperationRequestBuilder
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
import org.elasticsearch.common.unit.TimeValue;
|
import org.elasticsearch.common.unit.TimeValue;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class DeleteIndexRequestBuilder extends MasterNodeOperationRequestBuilder<DeleteIndexRequest, DeleteIndexResponse, DeleteIndexRequestBuilder> {
|
public class DeleteIndexRequestBuilder extends MasterNodeOperationRequestBuilder<DeleteIndexRequest, DeleteIndexResponse, DeleteIndexRequestBuilder> {
|
||||||
|
|
||||||
public DeleteIndexRequestBuilder(ElasticsearchClient client, DeleteIndexAction action, String... indices) {
|
public DeleteIndexRequestBuilder(ElasticsearchClient client, DeleteIndexAction action, String... indices) {
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.exists.indices;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class IndicesExistsAction extends Action<IndicesExistsRequest, IndicesExistsResponse, IndicesExistsRequestBuilder> {
|
public class IndicesExistsAction extends Action<IndicesExistsRequest, IndicesExistsResponse, IndicesExistsRequestBuilder> {
|
||||||
|
|
||||||
public static final IndicesExistsAction INSTANCE = new IndicesExistsAction();
|
public static final IndicesExistsAction INSTANCE = new IndicesExistsAction();
|
||||||
|
|
|
@ -23,9 +23,6 @@ import org.elasticsearch.action.support.IndicesOptions;
|
||||||
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
import org.elasticsearch.action.support.master.MasterNodeReadOperationRequestBuilder;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class IndicesExistsRequestBuilder extends MasterNodeReadOperationRequestBuilder<IndicesExistsRequest, IndicesExistsResponse, IndicesExistsRequestBuilder> {
|
public class IndicesExistsRequestBuilder extends MasterNodeReadOperationRequestBuilder<IndicesExistsRequest, IndicesExistsResponse, IndicesExistsRequestBuilder> {
|
||||||
|
|
||||||
public IndicesExistsRequestBuilder(ElasticsearchClient client, IndicesExistsAction action, String... indices) {
|
public IndicesExistsRequestBuilder(ElasticsearchClient client, IndicesExistsAction action, String... indices) {
|
||||||
|
|
|
@ -21,8 +21,6 @@ package org.elasticsearch.action.admin.indices.exists.types;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TypesExistsAction extends Action<TypesExistsRequest, TypesExistsResponse, TypesExistsRequestBuilder> {
|
public class TypesExistsAction extends Action<TypesExistsRequest, TypesExistsResponse, TypesExistsRequestBuilder> {
|
||||||
|
|
||||||
public static final TypesExistsAction INSTANCE = new TypesExistsAction();
|
public static final TypesExistsAction INSTANCE = new TypesExistsAction();
|
||||||
|
|
|
@ -29,8 +29,6 @@ import java.io.IOException;
|
||||||
|
|
||||||
import static org.elasticsearch.action.ValidateActions.addValidationError;
|
import static org.elasticsearch.action.ValidateActions.addValidationError;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class TypesExistsRequest extends MasterNodeReadRequest<TypesExistsRequest> implements IndicesRequest.Replaceable {
|
public class TypesExistsRequest extends MasterNodeReadRequest<TypesExistsRequest> implements IndicesRequest.Replaceable {
|
||||||
|
|
||||||
private String[] indices;
|
private String[] indices;
|
||||||
|
|
|
@ -22,8 +22,6 @@ package org.elasticsearch.action.admin.indices.flush;
|
||||||
import org.elasticsearch.action.Action;
|
import org.elasticsearch.action.Action;
|
||||||
import org.elasticsearch.client.ElasticsearchClient;
|
import org.elasticsearch.client.ElasticsearchClient;
|
||||||
|
|
||||||
/**
|
|
||||||
*/
|
|
||||||
public class FlushAction extends Action<FlushRequest, FlushResponse, FlushRequestBuilder> {
|
public class FlushAction extends Action<FlushRequest, FlushResponse, FlushRequestBuilder> {
|
||||||
|
|
||||||
public static final FlushAction INSTANCE = new FlushAction();
|
public static final FlushAction INSTANCE = new FlushAction();
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue