mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-02-26 14:54:56 +00:00
Zap another few raw types warnings
Mostly these come from QueryBuilder. Mostly these are fixed by just using <?> instead of the raw type.
This commit is contained in:
parent
742e1da857
commit
57af014510
@ -179,7 +179,7 @@ public class BulkProcessor implements Closeable {
|
|||||||
|
|
||||||
|
|
||||||
private final ScheduledThreadPoolExecutor scheduler;
|
private final ScheduledThreadPoolExecutor scheduler;
|
||||||
private final ScheduledFuture scheduledFuture;
|
private final ScheduledFuture<?> scheduledFuture;
|
||||||
|
|
||||||
private final AtomicLong executionIdGen = new AtomicLong();
|
private final AtomicLong executionIdGen = new AtomicLong();
|
||||||
|
|
||||||
@ -250,24 +250,24 @@ public class BulkProcessor implements Closeable {
|
|||||||
* (for example, if no id is provided, one will be generated, or usage of the create flag).
|
* (for example, if no id is provided, one will be generated, or usage of the create flag).
|
||||||
*/
|
*/
|
||||||
public BulkProcessor add(IndexRequest request) {
|
public BulkProcessor add(IndexRequest request) {
|
||||||
return add((ActionRequest) request);
|
return add((ActionRequest<?>) request);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds an {@link DeleteRequest} to the list of actions to execute.
|
* Adds an {@link DeleteRequest} to the list of actions to execute.
|
||||||
*/
|
*/
|
||||||
public BulkProcessor add(DeleteRequest request) {
|
public BulkProcessor add(DeleteRequest request) {
|
||||||
return add((ActionRequest) request);
|
return add((ActionRequest<?>) request);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds either a delete or an index request.
|
* Adds either a delete or an index request.
|
||||||
*/
|
*/
|
||||||
public BulkProcessor add(ActionRequest request) {
|
public BulkProcessor add(ActionRequest<?> request) {
|
||||||
return add(request, null);
|
return add(request, null);
|
||||||
}
|
}
|
||||||
|
|
||||||
public BulkProcessor add(ActionRequest request, @Nullable Object payload) {
|
public BulkProcessor add(ActionRequest<?> request, @Nullable Object payload) {
|
||||||
internalAdd(request, payload);
|
internalAdd(request, payload);
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
@ -282,7 +282,7 @@ public class BulkProcessor implements Closeable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private synchronized void internalAdd(ActionRequest request, @Nullable Object payload) {
|
private synchronized void internalAdd(ActionRequest<?> request, @Nullable Object payload) {
|
||||||
ensureOpen();
|
ensureOpen();
|
||||||
bulkRequest.add(request, payload);
|
bulkRequest.add(request, payload);
|
||||||
executeIfNeeded();
|
executeIfNeeded();
|
||||||
|
@ -56,7 +56,7 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
|
|
||||||
private static final int REQUEST_OVERHEAD = 50;
|
private static final int REQUEST_OVERHEAD = 50;
|
||||||
|
|
||||||
final List<ActionRequest> requests = new ArrayList<>();
|
final List<ActionRequest<?>> requests = new ArrayList<>();
|
||||||
List<Object> payloads = null;
|
List<Object> payloads = null;
|
||||||
|
|
||||||
protected TimeValue timeout = BulkShardRequest.DEFAULT_TIMEOUT;
|
protected TimeValue timeout = BulkShardRequest.DEFAULT_TIMEOUT;
|
||||||
@ -72,21 +72,21 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
* Creates a bulk request caused by some other request, which is provided as an
|
* Creates a bulk request caused by some other request, which is provided as an
|
||||||
* argument so that its headers and context can be copied to the new request
|
* argument so that its headers and context can be copied to the new request
|
||||||
*/
|
*/
|
||||||
public BulkRequest(ActionRequest request) {
|
public BulkRequest(ActionRequest<?> request) {
|
||||||
super(request);
|
super(request);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds a list of requests to be executed. Either index or delete requests.
|
* Adds a list of requests to be executed. Either index or delete requests.
|
||||||
*/
|
*/
|
||||||
public BulkRequest add(ActionRequest... requests) {
|
public BulkRequest add(ActionRequest<?>... requests) {
|
||||||
for (ActionRequest request : requests) {
|
for (ActionRequest<?> request : requests) {
|
||||||
add(request, null);
|
add(request, null);
|
||||||
}
|
}
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
|
|
||||||
public BulkRequest add(ActionRequest request) {
|
public BulkRequest add(ActionRequest<?> request) {
|
||||||
return add(request, null);
|
return add(request, null);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -96,7 +96,7 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
* @param payload Optional payload
|
* @param payload Optional payload
|
||||||
* @return the current bulk request
|
* @return the current bulk request
|
||||||
*/
|
*/
|
||||||
public BulkRequest add(ActionRequest request, @Nullable Object payload) {
|
public BulkRequest add(ActionRequest<?> request, @Nullable Object payload) {
|
||||||
if (request instanceof IndexRequest) {
|
if (request instanceof IndexRequest) {
|
||||||
add((IndexRequest) request, payload);
|
add((IndexRequest) request, payload);
|
||||||
} else if (request instanceof DeleteRequest) {
|
} else if (request instanceof DeleteRequest) {
|
||||||
@ -112,8 +112,8 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
/**
|
/**
|
||||||
* Adds a list of requests to be executed. Either index or delete requests.
|
* Adds a list of requests to be executed. Either index or delete requests.
|
||||||
*/
|
*/
|
||||||
public BulkRequest add(Iterable<ActionRequest> requests) {
|
public BulkRequest add(Iterable<ActionRequest<?>> requests) {
|
||||||
for (ActionRequest request : requests) {
|
for (ActionRequest<?> request : requests) {
|
||||||
add(request);
|
add(request);
|
||||||
}
|
}
|
||||||
return this;
|
return this;
|
||||||
@ -196,15 +196,14 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
/**
|
/**
|
||||||
* The list of requests in this bulk request.
|
* The list of requests in this bulk request.
|
||||||
*/
|
*/
|
||||||
public List<ActionRequest> requests() {
|
public List<ActionRequest<?>> requests() {
|
||||||
return this.requests;
|
return this.requests;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@SuppressWarnings("unchecked")
|
|
||||||
public List<? extends IndicesRequest> subRequests() {
|
public List<? extends IndicesRequest> subRequests() {
|
||||||
List<IndicesRequest> indicesRequests = new ArrayList<>();
|
List<IndicesRequest> indicesRequests = new ArrayList<>();
|
||||||
for (ActionRequest request : requests) {
|
for (ActionRequest<?> request : requests) {
|
||||||
assert request instanceof IndicesRequest;
|
assert request instanceof IndicesRequest;
|
||||||
indicesRequests.add((IndicesRequest) request);
|
indicesRequests.add((IndicesRequest) request);
|
||||||
}
|
}
|
||||||
@ -486,7 +485,7 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
if (requests.isEmpty()) {
|
if (requests.isEmpty()) {
|
||||||
validationException = addValidationError("no requests added", validationException);
|
validationException = addValidationError("no requests added", validationException);
|
||||||
}
|
}
|
||||||
for (ActionRequest request : requests) {
|
for (ActionRequest<?> request : requests) {
|
||||||
// We first check if refresh has been set
|
// We first check if refresh has been set
|
||||||
if ((request instanceof DeleteRequest && ((DeleteRequest)request).refresh()) ||
|
if ((request instanceof DeleteRequest && ((DeleteRequest)request).refresh()) ||
|
||||||
(request instanceof UpdateRequest && ((UpdateRequest)request).refresh()) ||
|
(request instanceof UpdateRequest && ((UpdateRequest)request).refresh()) ||
|
||||||
@ -535,7 +534,7 @@ public class BulkRequest extends ActionRequest<BulkRequest> implements Composite
|
|||||||
super.writeTo(out);
|
super.writeTo(out);
|
||||||
out.writeByte(consistencyLevel.id());
|
out.writeByte(consistencyLevel.id());
|
||||||
out.writeVInt(requests.size());
|
out.writeVInt(requests.size());
|
||||||
for (ActionRequest request : requests) {
|
for (ActionRequest<?> request : requests) {
|
||||||
if (request instanceof IndexRequest) {
|
if (request instanceof IndexRequest) {
|
||||||
out.writeByte((byte) 0);
|
out.writeByte((byte) 0);
|
||||||
} else if (request instanceof DeleteRequest) {
|
} else if (request instanceof DeleteRequest) {
|
||||||
|
@ -40,7 +40,8 @@ public interface ElasticsearchClient {
|
|||||||
* @param <RequestBuilder> The request builder type.
|
* @param <RequestBuilder> The request builder type.
|
||||||
* @return A future allowing to get back the response.
|
* @return A future allowing to get back the response.
|
||||||
*/
|
*/
|
||||||
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> ActionFuture<Response> execute(final Action<Request, Response, RequestBuilder> action, final Request request);
|
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> ActionFuture<Response> execute(
|
||||||
|
final Action<Request, Response, RequestBuilder> action, final Request request);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Executes a generic action, denoted by an {@link Action}.
|
* Executes a generic action, denoted by an {@link Action}.
|
||||||
@ -52,7 +53,8 @@ public interface ElasticsearchClient {
|
|||||||
* @param <Response> The response type.
|
* @param <Response> The response type.
|
||||||
* @param <RequestBuilder> The request builder type.
|
* @param <RequestBuilder> The request builder type.
|
||||||
*/
|
*/
|
||||||
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> void execute(final Action<Request, Response, RequestBuilder> action, final Request request, ActionListener<Response> listener);
|
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> void execute(
|
||||||
|
final Action<Request, Response, RequestBuilder> action, final Request request, ActionListener<Response> listener);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Prepares a request builder to execute, specified by {@link Action}.
|
* Prepares a request builder to execute, specified by {@link Action}.
|
||||||
@ -63,7 +65,8 @@ public interface ElasticsearchClient {
|
|||||||
* @param <RequestBuilder> The request builder.
|
* @param <RequestBuilder> The request builder.
|
||||||
* @return The request builder, that can, at a later stage, execute the request.
|
* @return The request builder, that can, at a later stage, execute the request.
|
||||||
*/
|
*/
|
||||||
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> RequestBuilder prepareExecute(final Action<Request, Response, RequestBuilder> action);
|
<Request extends ActionRequest<Request>, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder>> RequestBuilder prepareExecute(
|
||||||
|
final Action<Request, Response, RequestBuilder> action);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the threadpool used to execute requests on this client
|
* Returns the threadpool used to execute requests on this client
|
||||||
|
@ -49,8 +49,8 @@ public abstract class AbstractMatcher<T> implements Matcher<T> {
|
|||||||
@Override
|
@Override
|
||||||
public boolean equals(Object other) {
|
public boolean equals(Object other) {
|
||||||
return other instanceof AndMatcher
|
return other instanceof AndMatcher
|
||||||
&& ((AndMatcher) other).a.equals(a)
|
&& ((AndMatcher<?>) other).a.equals(a)
|
||||||
&& ((AndMatcher) other).b.equals(b);
|
&& ((AndMatcher<?>) other).b.equals(b);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@ -80,8 +80,8 @@ public abstract class AbstractMatcher<T> implements Matcher<T> {
|
|||||||
@Override
|
@Override
|
||||||
public boolean equals(Object other) {
|
public boolean equals(Object other) {
|
||||||
return other instanceof OrMatcher
|
return other instanceof OrMatcher
|
||||||
&& ((OrMatcher) other).a.equals(a)
|
&& ((OrMatcher<?>) other).a.equals(a)
|
||||||
&& ((OrMatcher) other).b.equals(b);
|
&& ((OrMatcher<?>) other).b.equals(b);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -42,7 +42,7 @@ import java.util.Objects;
|
|||||||
* Base class for all classes producing lucene queries.
|
* Base class for all classes producing lucene queries.
|
||||||
* Supports conversion to BytesReference and creation of lucene Query objects.
|
* Supports conversion to BytesReference and creation of lucene Query objects.
|
||||||
*/
|
*/
|
||||||
public abstract class AbstractQueryBuilder<QB extends AbstractQueryBuilder> extends ToXContentToBytes implements QueryBuilder<QB> {
|
public abstract class AbstractQueryBuilder<QB extends AbstractQueryBuilder<QB>> extends ToXContentToBytes implements QueryBuilder<QB> {
|
||||||
|
|
||||||
/** Default for boost to apply to resulting Lucene query. Defaults to 1.0*/
|
/** Default for boost to apply to resulting Lucene query. Defaults to 1.0*/
|
||||||
public static final float DEFAULT_BOOST = 1.0f;
|
public static final float DEFAULT_BOOST = 1.0f;
|
||||||
@ -225,10 +225,10 @@ public abstract class AbstractQueryBuilder<QB extends AbstractQueryBuilder> exte
|
|||||||
* their {@link QueryBuilder#toQuery(QueryShardContext)} method are not added to the
|
* their {@link QueryBuilder#toQuery(QueryShardContext)} method are not added to the
|
||||||
* resulting collection.
|
* resulting collection.
|
||||||
*/
|
*/
|
||||||
protected static Collection<Query> toQueries(Collection<QueryBuilder> queryBuilders, QueryShardContext context) throws QueryShardException,
|
protected static Collection<Query> toQueries(Collection<QueryBuilder<?>> queryBuilders, QueryShardContext context) throws QueryShardException,
|
||||||
IOException {
|
IOException {
|
||||||
List<Query> queries = new ArrayList<>(queryBuilders.size());
|
List<Query> queries = new ArrayList<>(queryBuilders.size());
|
||||||
for (QueryBuilder queryBuilder : queryBuilders) {
|
for (QueryBuilder<?> queryBuilder : queryBuilders) {
|
||||||
Query query = queryBuilder.toQuery(context);
|
Query query = queryBuilder.toQuery(context);
|
||||||
if (query != null) {
|
if (query != null) {
|
||||||
queries.add(query);
|
queries.add(query);
|
||||||
@ -243,15 +243,15 @@ public abstract class AbstractQueryBuilder<QB extends AbstractQueryBuilder> exte
|
|||||||
return getWriteableName();
|
return getWriteableName();
|
||||||
}
|
}
|
||||||
|
|
||||||
protected final void writeQueries(StreamOutput out, List<? extends QueryBuilder> queries) throws IOException {
|
protected final void writeQueries(StreamOutput out, List<? extends QueryBuilder<?>> queries) throws IOException {
|
||||||
out.writeVInt(queries.size());
|
out.writeVInt(queries.size());
|
||||||
for (QueryBuilder query : queries) {
|
for (QueryBuilder<?> query : queries) {
|
||||||
out.writeQuery(query);
|
out.writeQuery(query);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected final List<QueryBuilder> readQueries(StreamInput in) throws IOException {
|
protected final List<QueryBuilder<?>> readQueries(StreamInput in) throws IOException {
|
||||||
List<QueryBuilder> queries = new ArrayList<>();
|
List<QueryBuilder<?>> queries = new ArrayList<>();
|
||||||
int size = in.readVInt();
|
int size = in.readVInt();
|
||||||
for (int i = 0; i < size; i++) {
|
for (int i = 0; i < size; i++) {
|
||||||
queries.add(in.readQuery());
|
queries.add(in.readQuery());
|
||||||
|
@ -49,13 +49,13 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
|
|
||||||
static final BoolQueryBuilder PROTOTYPE = new BoolQueryBuilder();
|
static final BoolQueryBuilder PROTOTYPE = new BoolQueryBuilder();
|
||||||
|
|
||||||
private final List<QueryBuilder> mustClauses = new ArrayList<>();
|
private final List<QueryBuilder<?>> mustClauses = new ArrayList<>();
|
||||||
|
|
||||||
private final List<QueryBuilder> mustNotClauses = new ArrayList<>();
|
private final List<QueryBuilder<?>> mustNotClauses = new ArrayList<>();
|
||||||
|
|
||||||
private final List<QueryBuilder> filterClauses = new ArrayList<>();
|
private final List<QueryBuilder<?>> filterClauses = new ArrayList<>();
|
||||||
|
|
||||||
private final List<QueryBuilder> shouldClauses = new ArrayList<>();
|
private final List<QueryBuilder<?>> shouldClauses = new ArrayList<>();
|
||||||
|
|
||||||
private boolean disableCoord = DISABLE_COORD_DEFAULT;
|
private boolean disableCoord = DISABLE_COORD_DEFAULT;
|
||||||
|
|
||||||
@ -67,7 +67,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
* Adds a query that <b>must</b> appear in the matching documents and will
|
* Adds a query that <b>must</b> appear in the matching documents and will
|
||||||
* contribute to scoring. No <tt>null</tt> value allowed.
|
* contribute to scoring. No <tt>null</tt> value allowed.
|
||||||
*/
|
*/
|
||||||
public BoolQueryBuilder must(QueryBuilder queryBuilder) {
|
public BoolQueryBuilder must(QueryBuilder<?> queryBuilder) {
|
||||||
if (queryBuilder == null) {
|
if (queryBuilder == null) {
|
||||||
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -78,7 +78,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
/**
|
/**
|
||||||
* Gets the queries that <b>must</b> appear in the matching documents.
|
* Gets the queries that <b>must</b> appear in the matching documents.
|
||||||
*/
|
*/
|
||||||
public List<QueryBuilder> must() {
|
public List<QueryBuilder<?>> must() {
|
||||||
return this.mustClauses;
|
return this.mustClauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -86,7 +86,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
* Adds a query that <b>must</b> appear in the matching documents but will
|
* Adds a query that <b>must</b> appear in the matching documents but will
|
||||||
* not contribute to scoring. No <tt>null</tt> value allowed.
|
* not contribute to scoring. No <tt>null</tt> value allowed.
|
||||||
*/
|
*/
|
||||||
public BoolQueryBuilder filter(QueryBuilder queryBuilder) {
|
public BoolQueryBuilder filter(QueryBuilder<?> queryBuilder) {
|
||||||
if (queryBuilder == null) {
|
if (queryBuilder == null) {
|
||||||
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -95,9 +95,9 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Gets the queries that <b>must</b> appear in the matching documents but don't conntribute to scoring
|
* Gets the queries that <b>must</b> appear in the matching documents but don't contribute to scoring
|
||||||
*/
|
*/
|
||||||
public List<QueryBuilder> filter() {
|
public List<QueryBuilder<?>> filter() {
|
||||||
return this.filterClauses;
|
return this.filterClauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -105,7 +105,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
* Adds a query that <b>must not</b> appear in the matching documents.
|
* Adds a query that <b>must not</b> appear in the matching documents.
|
||||||
* No <tt>null</tt> value allowed.
|
* No <tt>null</tt> value allowed.
|
||||||
*/
|
*/
|
||||||
public BoolQueryBuilder mustNot(QueryBuilder queryBuilder) {
|
public BoolQueryBuilder mustNot(QueryBuilder<?> queryBuilder) {
|
||||||
if (queryBuilder == null) {
|
if (queryBuilder == null) {
|
||||||
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -116,7 +116,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
/**
|
/**
|
||||||
* Gets the queries that <b>must not</b> appear in the matching documents.
|
* Gets the queries that <b>must not</b> appear in the matching documents.
|
||||||
*/
|
*/
|
||||||
public List<QueryBuilder> mustNot() {
|
public List<QueryBuilder<?>> mustNot() {
|
||||||
return this.mustNotClauses;
|
return this.mustNotClauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -127,7 +127,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
*
|
*
|
||||||
* @see #minimumNumberShouldMatch(int)
|
* @see #minimumNumberShouldMatch(int)
|
||||||
*/
|
*/
|
||||||
public BoolQueryBuilder should(QueryBuilder queryBuilder) {
|
public BoolQueryBuilder should(QueryBuilder<?> queryBuilder) {
|
||||||
if (queryBuilder == null) {
|
if (queryBuilder == null) {
|
||||||
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -141,7 +141,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
* @see #should(QueryBuilder)
|
* @see #should(QueryBuilder)
|
||||||
* @see #minimumNumberShouldMatch(int)
|
* @see #minimumNumberShouldMatch(int)
|
||||||
*/
|
*/
|
||||||
public List<QueryBuilder> should() {
|
public List<QueryBuilder<?>> should() {
|
||||||
return this.shouldClauses;
|
return this.shouldClauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -244,12 +244,12 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
builder.endObject();
|
builder.endObject();
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void doXArrayContent(String field, List<QueryBuilder> clauses, XContentBuilder builder, Params params) throws IOException {
|
private static void doXArrayContent(String field, List<QueryBuilder<?>> clauses, XContentBuilder builder, Params params) throws IOException {
|
||||||
if (clauses.isEmpty()) {
|
if (clauses.isEmpty()) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
builder.startArray(field);
|
builder.startArray(field);
|
||||||
for (QueryBuilder clause : clauses) {
|
for (QueryBuilder<?> clause : clauses) {
|
||||||
clause.toXContent(builder, params);
|
clause.toXContent(builder, params);
|
||||||
}
|
}
|
||||||
builder.endArray();
|
builder.endArray();
|
||||||
@ -282,8 +282,8 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
return adjustPureNegative ? fixNegativeQueryIfNeeded(query) : query;
|
return adjustPureNegative ? fixNegativeQueryIfNeeded(query) : query;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void addBooleanClauses(QueryShardContext context, BooleanQuery.Builder booleanQueryBuilder, List<QueryBuilder> clauses, Occur occurs) throws IOException {
|
private static void addBooleanClauses(QueryShardContext context, BooleanQuery.Builder booleanQueryBuilder, List<QueryBuilder<?>> clauses, Occur occurs) throws IOException {
|
||||||
for (QueryBuilder query : clauses) {
|
for (QueryBuilder<?> query : clauses) {
|
||||||
Query luceneQuery = null;
|
Query luceneQuery = null;
|
||||||
switch (occurs) {
|
switch (occurs) {
|
||||||
case MUST:
|
case MUST:
|
||||||
@ -321,7 +321,7 @@ public class BoolQueryBuilder extends AbstractQueryBuilder<BoolQueryBuilder> {
|
|||||||
@Override
|
@Override
|
||||||
protected BoolQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
protected BoolQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
||||||
BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
|
BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
|
||||||
List<QueryBuilder> queryBuilders = readQueries(in);
|
List<QueryBuilder<?>> queryBuilders = readQueries(in);
|
||||||
boolQueryBuilder.mustClauses.addAll(queryBuilders);
|
boolQueryBuilder.mustClauses.addAll(queryBuilders);
|
||||||
queryBuilders = readQueries(in);
|
queryBuilders = readQueries(in);
|
||||||
boolQueryBuilder.mustNotClauses.addAll(queryBuilders);
|
boolQueryBuilder.mustNotClauses.addAll(queryBuilders);
|
||||||
|
@ -40,7 +40,7 @@ public class DisMaxQueryBuilder extends AbstractQueryBuilder<DisMaxQueryBuilder>
|
|||||||
|
|
||||||
public static final String NAME = "dis_max";
|
public static final String NAME = "dis_max";
|
||||||
|
|
||||||
private final ArrayList<QueryBuilder> queries = new ArrayList<>();
|
private final List<QueryBuilder<?>> queries = new ArrayList<>();
|
||||||
|
|
||||||
/** Default multiplication factor for breaking ties in document scores.*/
|
/** Default multiplication factor for breaking ties in document scores.*/
|
||||||
public static float DEFAULT_TIE_BREAKER = 0.0f;
|
public static float DEFAULT_TIE_BREAKER = 0.0f;
|
||||||
@ -51,7 +51,7 @@ public class DisMaxQueryBuilder extends AbstractQueryBuilder<DisMaxQueryBuilder>
|
|||||||
/**
|
/**
|
||||||
* Add a sub-query to this disjunction.
|
* Add a sub-query to this disjunction.
|
||||||
*/
|
*/
|
||||||
public DisMaxQueryBuilder add(QueryBuilder queryBuilder) {
|
public DisMaxQueryBuilder add(QueryBuilder<?> queryBuilder) {
|
||||||
if (queryBuilder == null) {
|
if (queryBuilder == null) {
|
||||||
throw new IllegalArgumentException("inner dismax query clause cannot be null");
|
throw new IllegalArgumentException("inner dismax query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -62,7 +62,7 @@ public class DisMaxQueryBuilder extends AbstractQueryBuilder<DisMaxQueryBuilder>
|
|||||||
/**
|
/**
|
||||||
* @return an immutable list copy of the current sub-queries of this disjunction
|
* @return an immutable list copy of the current sub-queries of this disjunction
|
||||||
*/
|
*/
|
||||||
public List<QueryBuilder> innerQueries() {
|
public List<QueryBuilder<?>> innerQueries() {
|
||||||
return this.queries;
|
return this.queries;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -90,7 +90,7 @@ public class DisMaxQueryBuilder extends AbstractQueryBuilder<DisMaxQueryBuilder>
|
|||||||
builder.startObject(NAME);
|
builder.startObject(NAME);
|
||||||
builder.field(DisMaxQueryParser.TIE_BREAKER_FIELD.getPreferredName(), tieBreaker);
|
builder.field(DisMaxQueryParser.TIE_BREAKER_FIELD.getPreferredName(), tieBreaker);
|
||||||
builder.startArray(DisMaxQueryParser.QUERIES_FIELD.getPreferredName());
|
builder.startArray(DisMaxQueryParser.QUERIES_FIELD.getPreferredName());
|
||||||
for (QueryBuilder queryBuilder : queries) {
|
for (QueryBuilder<?> queryBuilder : queries) {
|
||||||
queryBuilder.toXContent(builder, params);
|
queryBuilder.toXContent(builder, params);
|
||||||
}
|
}
|
||||||
builder.endArray();
|
builder.endArray();
|
||||||
@ -112,7 +112,7 @@ public class DisMaxQueryBuilder extends AbstractQueryBuilder<DisMaxQueryBuilder>
|
|||||||
@Override
|
@Override
|
||||||
protected DisMaxQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
protected DisMaxQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
||||||
DisMaxQueryBuilder disMax = new DisMaxQueryBuilder();
|
DisMaxQueryBuilder disMax = new DisMaxQueryBuilder();
|
||||||
List<QueryBuilder> queryBuilders = readQueries(in);
|
List<QueryBuilder<?>> queryBuilders = readQueries(in);
|
||||||
disMax.queries.addAll(queryBuilders);
|
disMax.queries.addAll(queryBuilders);
|
||||||
disMax.tieBreaker = in.readFloat();
|
disMax.tieBreaker = in.readFloat();
|
||||||
return disMax;
|
return disMax;
|
||||||
|
@ -25,7 +25,7 @@ import org.elasticsearch.common.xcontent.ToXContent;
|
|||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
||||||
public interface QueryBuilder<QB extends QueryBuilder> extends NamedWriteable<QB>, ToXContent {
|
public interface QueryBuilder<QB extends QueryBuilder<QB>> extends NamedWriteable<QB>, ToXContent {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converts this QueryBuilder to a lucene {@link Query}.
|
* Converts this QueryBuilder to a lucene {@link Query}.
|
||||||
|
@ -43,7 +43,7 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
/** Default for flag controlling whether matches are required to be in-order */
|
/** Default for flag controlling whether matches are required to be in-order */
|
||||||
public static boolean DEFAULT_IN_ORDER = true;
|
public static boolean DEFAULT_IN_ORDER = true;
|
||||||
|
|
||||||
private final List<SpanQueryBuilder> clauses = new ArrayList<>();
|
private final List<SpanQueryBuilder<?>> clauses = new ArrayList<>();
|
||||||
|
|
||||||
private final int slop;
|
private final int slop;
|
||||||
|
|
||||||
@ -55,7 +55,7 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
* @param initialClause an initial span query clause
|
* @param initialClause an initial span query clause
|
||||||
* @param slop controls the maximum number of intervening unmatched positions permitted
|
* @param slop controls the maximum number of intervening unmatched positions permitted
|
||||||
*/
|
*/
|
||||||
public SpanNearQueryBuilder(SpanQueryBuilder initialClause, int slop) {
|
public SpanNearQueryBuilder(SpanQueryBuilder<?> initialClause, int slop) {
|
||||||
if (initialClause == null) {
|
if (initialClause == null) {
|
||||||
throw new IllegalArgumentException("query must include at least one clause");
|
throw new IllegalArgumentException("query must include at least one clause");
|
||||||
}
|
}
|
||||||
@ -70,7 +70,7 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
return this.slop;
|
return this.slop;
|
||||||
}
|
}
|
||||||
|
|
||||||
public SpanNearQueryBuilder clause(SpanQueryBuilder clause) {
|
public SpanNearQueryBuilder clause(SpanQueryBuilder<?> clause) {
|
||||||
if (clause == null) {
|
if (clause == null) {
|
||||||
throw new IllegalArgumentException("query clauses cannot be null");
|
throw new IllegalArgumentException("query clauses cannot be null");
|
||||||
}
|
}
|
||||||
@ -81,7 +81,7 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
/**
|
/**
|
||||||
* @return the {@link SpanQueryBuilder} clauses that were set for this query
|
* @return the {@link SpanQueryBuilder} clauses that were set for this query
|
||||||
*/
|
*/
|
||||||
public List<SpanQueryBuilder> clauses() {
|
public List<SpanQueryBuilder<?>> clauses() {
|
||||||
return this.clauses;
|
return this.clauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -106,7 +106,7 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
protected void doXContent(XContentBuilder builder, Params params) throws IOException {
|
protected void doXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject(NAME);
|
builder.startObject(NAME);
|
||||||
builder.startArray(SpanNearQueryParser.CLAUSES_FIELD.getPreferredName());
|
builder.startArray(SpanNearQueryParser.CLAUSES_FIELD.getPreferredName());
|
||||||
for (SpanQueryBuilder clause : clauses) {
|
for (SpanQueryBuilder<?> clause : clauses) {
|
||||||
clause.toXContent(builder, params);
|
clause.toXContent(builder, params);
|
||||||
}
|
}
|
||||||
builder.endArray();
|
builder.endArray();
|
||||||
@ -129,10 +129,10 @@ public class SpanNearQueryBuilder extends AbstractQueryBuilder<SpanNearQueryBuil
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected SpanNearQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
protected SpanNearQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
||||||
List<QueryBuilder> clauses = readQueries(in);
|
List<QueryBuilder<?>> clauses = readQueries(in);
|
||||||
SpanNearQueryBuilder queryBuilder = new SpanNearQueryBuilder((SpanQueryBuilder)clauses.get(0), in.readVInt());
|
SpanNearQueryBuilder queryBuilder = new SpanNearQueryBuilder((SpanQueryBuilder<?>)clauses.get(0), in.readVInt());
|
||||||
for (int i = 1; i < clauses.size(); i++) {
|
for (int i = 1; i < clauses.size(); i++) {
|
||||||
queryBuilder.clauses.add((SpanQueryBuilder)clauses.get(i));
|
queryBuilder.clauses.add((SpanQueryBuilder<?>)clauses.get(i));
|
||||||
}
|
}
|
||||||
queryBuilder.inOrder = in.readBoolean();
|
queryBuilder.inOrder = in.readBoolean();
|
||||||
return queryBuilder;
|
return queryBuilder;
|
||||||
|
@ -38,18 +38,18 @@ public class SpanOrQueryBuilder extends AbstractQueryBuilder<SpanOrQueryBuilder>
|
|||||||
|
|
||||||
public static final String NAME = "span_or";
|
public static final String NAME = "span_or";
|
||||||
|
|
||||||
private final List<SpanQueryBuilder> clauses = new ArrayList<>();
|
private final List<SpanQueryBuilder<?>> clauses = new ArrayList<>();
|
||||||
|
|
||||||
static final SpanOrQueryBuilder PROTOTYPE = new SpanOrQueryBuilder(SpanTermQueryBuilder.PROTOTYPE);
|
static final SpanOrQueryBuilder PROTOTYPE = new SpanOrQueryBuilder(SpanTermQueryBuilder.PROTOTYPE);
|
||||||
|
|
||||||
public SpanOrQueryBuilder(SpanQueryBuilder initialClause) {
|
public SpanOrQueryBuilder(SpanQueryBuilder<?> initialClause) {
|
||||||
if (initialClause == null) {
|
if (initialClause == null) {
|
||||||
throw new IllegalArgumentException("query must include at least one clause");
|
throw new IllegalArgumentException("query must include at least one clause");
|
||||||
}
|
}
|
||||||
clauses.add(initialClause);
|
clauses.add(initialClause);
|
||||||
}
|
}
|
||||||
|
|
||||||
public SpanOrQueryBuilder clause(SpanQueryBuilder clause) {
|
public SpanOrQueryBuilder clause(SpanQueryBuilder<?> clause) {
|
||||||
if (clause == null) {
|
if (clause == null) {
|
||||||
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
throw new IllegalArgumentException("inner bool query clause cannot be null");
|
||||||
}
|
}
|
||||||
@ -60,7 +60,7 @@ public class SpanOrQueryBuilder extends AbstractQueryBuilder<SpanOrQueryBuilder>
|
|||||||
/**
|
/**
|
||||||
* @return the {@link SpanQueryBuilder} clauses that were set for this query
|
* @return the {@link SpanQueryBuilder} clauses that were set for this query
|
||||||
*/
|
*/
|
||||||
public List<SpanQueryBuilder> clauses() {
|
public List<SpanQueryBuilder<?>> clauses() {
|
||||||
return this.clauses;
|
return this.clauses;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -68,7 +68,7 @@ public class SpanOrQueryBuilder extends AbstractQueryBuilder<SpanOrQueryBuilder>
|
|||||||
protected void doXContent(XContentBuilder builder, Params params) throws IOException {
|
protected void doXContent(XContentBuilder builder, Params params) throws IOException {
|
||||||
builder.startObject(NAME);
|
builder.startObject(NAME);
|
||||||
builder.startArray(SpanOrQueryParser.CLAUSES_FIELD.getPreferredName());
|
builder.startArray(SpanOrQueryParser.CLAUSES_FIELD.getPreferredName());
|
||||||
for (SpanQueryBuilder clause : clauses) {
|
for (SpanQueryBuilder<?> clause : clauses) {
|
||||||
clause.toXContent(builder, params);
|
clause.toXContent(builder, params);
|
||||||
}
|
}
|
||||||
builder.endArray();
|
builder.endArray();
|
||||||
@ -89,10 +89,10 @@ public class SpanOrQueryBuilder extends AbstractQueryBuilder<SpanOrQueryBuilder>
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected SpanOrQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
protected SpanOrQueryBuilder doReadFrom(StreamInput in) throws IOException {
|
||||||
List<QueryBuilder> clauses = readQueries(in);
|
List<QueryBuilder<?>> clauses = readQueries(in);
|
||||||
SpanOrQueryBuilder queryBuilder = new SpanOrQueryBuilder((SpanQueryBuilder)clauses.get(0));
|
SpanOrQueryBuilder queryBuilder = new SpanOrQueryBuilder((SpanQueryBuilder<?>)clauses.get(0));
|
||||||
for (int i = 1; i < clauses.size(); i++) {
|
for (int i = 1; i < clauses.size(); i++) {
|
||||||
queryBuilder.clauses.add((SpanQueryBuilder)clauses.get(i));
|
queryBuilder.clauses.add((SpanQueryBuilder<?>)clauses.get(i));
|
||||||
}
|
}
|
||||||
return queryBuilder;
|
return queryBuilder;
|
||||||
|
|
||||||
|
@ -22,6 +22,6 @@ package org.elasticsearch.index.query;
|
|||||||
/**
|
/**
|
||||||
* Marker interface for a specific type of {@link QueryBuilder} that allows to build span queries
|
* Marker interface for a specific type of {@link QueryBuilder} that allows to build span queries
|
||||||
*/
|
*/
|
||||||
public interface SpanQueryBuilder<QB extends SpanQueryBuilder> extends QueryBuilder<QB> {
|
public interface SpanQueryBuilder<QB extends SpanQueryBuilder<QB>> extends QueryBuilder<QB> {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -110,7 +110,7 @@ public class BulkRequestTests extends ESTestCase {
|
|||||||
|
|
||||||
public void testBulkAddIterable() {
|
public void testBulkAddIterable() {
|
||||||
BulkRequest bulkRequest = Requests.bulkRequest();
|
BulkRequest bulkRequest = Requests.bulkRequest();
|
||||||
List<ActionRequest> requests = new ArrayList<>();
|
List<ActionRequest<?>> requests = new ArrayList<>();
|
||||||
requests.add(new IndexRequest("test", "test", "id").source("field", "value"));
|
requests.add(new IndexRequest("test", "test", "id").source("field", "value"));
|
||||||
requests.add(new UpdateRequest("test", "test", "id").doc("field", "value"));
|
requests.add(new UpdateRequest("test", "test", "id").doc("field", "value"));
|
||||||
requests.add(new DeleteRequest("test", "test", "id"));
|
requests.add(new DeleteRequest("test", "test", "id"));
|
||||||
|
@ -22,6 +22,7 @@ package org.elasticsearch.index.query;
|
|||||||
import com.carrotsearch.randomizedtesting.generators.CodepointSetGenerator;
|
import com.carrotsearch.randomizedtesting.generators.CodepointSetGenerator;
|
||||||
import com.fasterxml.jackson.core.JsonParseException;
|
import com.fasterxml.jackson.core.JsonParseException;
|
||||||
import com.fasterxml.jackson.core.io.JsonStringEncoder;
|
import com.fasterxml.jackson.core.io.JsonStringEncoder;
|
||||||
|
|
||||||
import org.apache.lucene.search.BoostQuery;
|
import org.apache.lucene.search.BoostQuery;
|
||||||
import org.apache.lucene.search.Query;
|
import org.apache.lucene.search.Query;
|
||||||
import org.apache.lucene.search.TermQuery;
|
import org.apache.lucene.search.TermQuery;
|
||||||
@ -483,7 +484,7 @@ public abstract class AbstractQueryTestCase<QB extends AbstractQueryBuilder<QB>>
|
|||||||
QueryParseContext context = createParseContext();
|
QueryParseContext context = createParseContext();
|
||||||
context.reset(parser);
|
context.reset(parser);
|
||||||
context.parseFieldMatcher(matcher);
|
context.parseFieldMatcher(matcher);
|
||||||
QueryBuilder parseInnerQueryBuilder = context.parseInnerQueryBuilder();
|
QueryBuilder<?> parseInnerQueryBuilder = context.parseInnerQueryBuilder();
|
||||||
assertTrue(parser.nextToken() == null);
|
assertTrue(parser.nextToken() == null);
|
||||||
return parseInnerQueryBuilder;
|
return parseInnerQueryBuilder;
|
||||||
}
|
}
|
||||||
@ -613,7 +614,7 @@ public abstract class AbstractQueryTestCase<QB extends AbstractQueryBuilder<QB>>
|
|||||||
testQuery.writeTo(output);
|
testQuery.writeTo(output);
|
||||||
try (StreamInput in = new NamedWriteableAwareStreamInput(StreamInput.wrap(output.bytes()), namedWriteableRegistry)) {
|
try (StreamInput in = new NamedWriteableAwareStreamInput(StreamInput.wrap(output.bytes()), namedWriteableRegistry)) {
|
||||||
QueryBuilder<?> prototype = queryParser(testQuery.getName()).getBuilderPrototype();
|
QueryBuilder<?> prototype = queryParser(testQuery.getName()).getBuilderPrototype();
|
||||||
QueryBuilder deserializedQuery = prototype.readFrom(in);
|
QueryBuilder<?> deserializedQuery = prototype.readFrom(in);
|
||||||
assertEquals(deserializedQuery, testQuery);
|
assertEquals(deserializedQuery, testQuery);
|
||||||
assertEquals(deserializedQuery.hashCode(), testQuery.hashCode());
|
assertEquals(deserializedQuery.hashCode(), testQuery.hashCode());
|
||||||
assertNotSame(deserializedQuery, testQuery);
|
assertNotSame(deserializedQuery, testQuery);
|
||||||
@ -845,7 +846,7 @@ public abstract class AbstractQueryTestCase<QB extends AbstractQueryBuilder<QB>>
|
|||||||
private static final List<String> TIMEZONE_IDS = new ArrayList<>(DateTimeZone.getAvailableIDs());
|
private static final List<String> TIMEZONE_IDS = new ArrayList<>(DateTimeZone.getAvailableIDs());
|
||||||
|
|
||||||
private static class ClientInvocationHandler implements InvocationHandler {
|
private static class ClientInvocationHandler implements InvocationHandler {
|
||||||
AbstractQueryTestCase delegate;
|
AbstractQueryTestCase<?> delegate;
|
||||||
@Override
|
@Override
|
||||||
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
|
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
|
||||||
if (method.equals(Client.class.getMethod("get", GetRequest.class))) {
|
if (method.equals(Client.class.getMethod("get", GetRequest.class))) {
|
||||||
|
@ -106,16 +106,16 @@ public class BoolQueryBuilderTests extends AbstractQueryTestCase<BoolQueryBuilde
|
|||||||
}
|
}
|
||||||
assertThat(booleanQuery.clauses().size(), equalTo(clauses.size()));
|
assertThat(booleanQuery.clauses().size(), equalTo(clauses.size()));
|
||||||
Iterator<BooleanClause> clauseIterator = clauses.iterator();
|
Iterator<BooleanClause> clauseIterator = clauses.iterator();
|
||||||
for (BooleanClause booleanClause : booleanQuery.getClauses()) {
|
for (BooleanClause booleanClause : booleanQuery.clauses()) {
|
||||||
assertThat(booleanClause, instanceOf(clauseIterator.next().getClass()));
|
assertThat(booleanClause, instanceOf(clauseIterator.next().getClass()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private static List<BooleanClause> getBooleanClauses(List<QueryBuilder> queryBuilders, BooleanClause.Occur occur, QueryShardContext context) throws IOException {
|
private static List<BooleanClause> getBooleanClauses(List<QueryBuilder<?>> queryBuilders, BooleanClause.Occur occur, QueryShardContext context) throws IOException {
|
||||||
List<BooleanClause> clauses = new ArrayList<>();
|
List<BooleanClause> clauses = new ArrayList<>();
|
||||||
for (QueryBuilder query : queryBuilders) {
|
for (QueryBuilder<?> query : queryBuilders) {
|
||||||
Query innerQuery = query.toQuery(context);
|
Query innerQuery = query.toQuery(context);
|
||||||
if (innerQuery != null) {
|
if (innerQuery != null) {
|
||||||
clauses.add(new BooleanClause(innerQuery, occur));
|
clauses.add(new BooleanClause(innerQuery, occur));
|
||||||
@ -132,22 +132,22 @@ public class BoolQueryBuilderTests extends AbstractQueryTestCase<BoolQueryBuilde
|
|||||||
String contentString = "{\n" +
|
String contentString = "{\n" +
|
||||||
" \"bool\" : {\n";
|
" \"bool\" : {\n";
|
||||||
if (tempQueryBuilder.must().size() > 0) {
|
if (tempQueryBuilder.must().size() > 0) {
|
||||||
QueryBuilder must = tempQueryBuilder.must().get(0);
|
QueryBuilder<?> must = tempQueryBuilder.must().get(0);
|
||||||
contentString += "must: " + must.toString() + ",";
|
contentString += "must: " + must.toString() + ",";
|
||||||
expectedQuery.must(must);
|
expectedQuery.must(must);
|
||||||
}
|
}
|
||||||
if (tempQueryBuilder.mustNot().size() > 0) {
|
if (tempQueryBuilder.mustNot().size() > 0) {
|
||||||
QueryBuilder mustNot = tempQueryBuilder.mustNot().get(0);
|
QueryBuilder<?> mustNot = tempQueryBuilder.mustNot().get(0);
|
||||||
contentString += (randomBoolean() ? "must_not: " : "mustNot: ") + mustNot.toString() + ",";
|
contentString += (randomBoolean() ? "must_not: " : "mustNot: ") + mustNot.toString() + ",";
|
||||||
expectedQuery.mustNot(mustNot);
|
expectedQuery.mustNot(mustNot);
|
||||||
}
|
}
|
||||||
if (tempQueryBuilder.should().size() > 0) {
|
if (tempQueryBuilder.should().size() > 0) {
|
||||||
QueryBuilder should = tempQueryBuilder.should().get(0);
|
QueryBuilder<?> should = tempQueryBuilder.should().get(0);
|
||||||
contentString += "should: " + should.toString() + ",";
|
contentString += "should: " + should.toString() + ",";
|
||||||
expectedQuery.should(should);
|
expectedQuery.should(should);
|
||||||
}
|
}
|
||||||
if (tempQueryBuilder.filter().size() > 0) {
|
if (tempQueryBuilder.filter().size() > 0) {
|
||||||
QueryBuilder filter = tempQueryBuilder.filter().get(0);
|
QueryBuilder<?> filter = tempQueryBuilder.filter().get(0);
|
||||||
contentString += "filter: " + filter.toString() + ",";
|
contentString += "filter: " + filter.toString() + ",";
|
||||||
expectedQuery.filter(filter);
|
expectedQuery.filter(filter);
|
||||||
}
|
}
|
||||||
|
@ -74,7 +74,7 @@ public class DisMaxQueryBuilderTests extends AbstractQueryTestCase<DisMaxQueryBu
|
|||||||
@Override
|
@Override
|
||||||
protected Map<String, DisMaxQueryBuilder> getAlternateVersions() {
|
protected Map<String, DisMaxQueryBuilder> getAlternateVersions() {
|
||||||
Map<String, DisMaxQueryBuilder> alternateVersions = new HashMap<>();
|
Map<String, DisMaxQueryBuilder> alternateVersions = new HashMap<>();
|
||||||
QueryBuilder innerQuery = createTestQueryBuilder().innerQueries().get(0);
|
QueryBuilder<?> innerQuery = createTestQueryBuilder().innerQueries().get(0);
|
||||||
DisMaxQueryBuilder expectedQuery = new DisMaxQueryBuilder();
|
DisMaxQueryBuilder expectedQuery = new DisMaxQueryBuilder();
|
||||||
expectedQuery.add(innerQuery);
|
expectedQuery.add(innerQuery);
|
||||||
String contentString = "{\n" +
|
String contentString = "{\n" +
|
||||||
|
@ -50,7 +50,7 @@ public class SpanNearQueryBuilderTests extends AbstractQueryTestCase<SpanNearQue
|
|||||||
assertThat(spanNearQuery.getSlop(), equalTo(queryBuilder.slop()));
|
assertThat(spanNearQuery.getSlop(), equalTo(queryBuilder.slop()));
|
||||||
assertThat(spanNearQuery.isInOrder(), equalTo(queryBuilder.inOrder()));
|
assertThat(spanNearQuery.isInOrder(), equalTo(queryBuilder.inOrder()));
|
||||||
assertThat(spanNearQuery.getClauses().length, equalTo(queryBuilder.clauses().size()));
|
assertThat(spanNearQuery.getClauses().length, equalTo(queryBuilder.clauses().size()));
|
||||||
Iterator<SpanQueryBuilder> spanQueryBuilderIterator = queryBuilder.clauses().iterator();
|
Iterator<SpanQueryBuilder<?>> spanQueryBuilderIterator = queryBuilder.clauses().iterator();
|
||||||
for (SpanQuery spanQuery : spanNearQuery.getClauses()) {
|
for (SpanQuery spanQuery : spanNearQuery.getClauses()) {
|
||||||
assertThat(spanQuery, equalTo(spanQueryBuilderIterator.next().toQuery(context)));
|
assertThat(spanQuery, equalTo(spanQueryBuilderIterator.next().toQuery(context)));
|
||||||
}
|
}
|
||||||
|
@ -45,7 +45,7 @@ public class SpanOrQueryBuilderTests extends AbstractQueryTestCase<SpanOrQueryBu
|
|||||||
assertThat(query, instanceOf(SpanOrQuery.class));
|
assertThat(query, instanceOf(SpanOrQuery.class));
|
||||||
SpanOrQuery spanOrQuery = (SpanOrQuery) query;
|
SpanOrQuery spanOrQuery = (SpanOrQuery) query;
|
||||||
assertThat(spanOrQuery.getClauses().length, equalTo(queryBuilder.clauses().size()));
|
assertThat(spanOrQuery.getClauses().length, equalTo(queryBuilder.clauses().size()));
|
||||||
Iterator<SpanQueryBuilder> spanQueryBuilderIterator = queryBuilder.clauses().iterator();
|
Iterator<SpanQueryBuilder<?>> spanQueryBuilderIterator = queryBuilder.clauses().iterator();
|
||||||
for (SpanQuery spanQuery : spanOrQuery.getClauses()) {
|
for (SpanQuery spanQuery : spanOrQuery.getClauses()) {
|
||||||
assertThat(spanQuery, equalTo(spanQueryBuilderIterator.next().toQuery(context)));
|
assertThat(spanQuery, equalTo(spanQueryBuilderIterator.next().toQuery(context)));
|
||||||
}
|
}
|
||||||
@ -70,32 +70,32 @@ public class SpanOrQueryBuilderTests extends AbstractQueryTestCase<SpanOrQueryBu
|
|||||||
|
|
||||||
public void testFromJson() throws IOException {
|
public void testFromJson() throws IOException {
|
||||||
String json =
|
String json =
|
||||||
"{\n" +
|
"{\n" +
|
||||||
" \"span_or\" : {\n" +
|
" \"span_or\" : {\n" +
|
||||||
" \"clauses\" : [ {\n" +
|
" \"clauses\" : [ {\n" +
|
||||||
" \"span_term\" : {\n" +
|
" \"span_term\" : {\n" +
|
||||||
" \"field\" : {\n" +
|
" \"field\" : {\n" +
|
||||||
" \"value\" : \"value1\",\n" +
|
" \"value\" : \"value1\",\n" +
|
||||||
" \"boost\" : 1.0\n" +
|
" \"boost\" : 1.0\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" }, {\n" +
|
" }, {\n" +
|
||||||
" \"span_term\" : {\n" +
|
" \"span_term\" : {\n" +
|
||||||
" \"field\" : {\n" +
|
" \"field\" : {\n" +
|
||||||
" \"value\" : \"value2\",\n" +
|
" \"value\" : \"value2\",\n" +
|
||||||
" \"boost\" : 1.0\n" +
|
" \"boost\" : 1.0\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" }, {\n" +
|
" }, {\n" +
|
||||||
" \"span_term\" : {\n" +
|
" \"span_term\" : {\n" +
|
||||||
" \"field\" : {\n" +
|
" \"field\" : {\n" +
|
||||||
" \"value\" : \"value3\",\n" +
|
" \"value\" : \"value3\",\n" +
|
||||||
" \"boost\" : 1.0\n" +
|
" \"boost\" : 1.0\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
" } ],\n" +
|
" } ],\n" +
|
||||||
" \"boost\" : 1.0\n" +
|
" \"boost\" : 1.0\n" +
|
||||||
" }\n" +
|
" }\n" +
|
||||||
"}";
|
"}";
|
||||||
|
|
||||||
SpanOrQueryBuilder parsed = (SpanOrQueryBuilder) parseQuery(json);
|
SpanOrQueryBuilder parsed = (SpanOrQueryBuilder) parseQuery(json);
|
||||||
|
@ -20,6 +20,7 @@
|
|||||||
package org.elasticsearch.index.query.functionscore;
|
package org.elasticsearch.index.query.functionscore;
|
||||||
|
|
||||||
import com.fasterxml.jackson.core.JsonParseException;
|
import com.fasterxml.jackson.core.JsonParseException;
|
||||||
|
|
||||||
import org.apache.lucene.index.Term;
|
import org.apache.lucene.index.Term;
|
||||||
import org.apache.lucene.search.MatchAllDocsQuery;
|
import org.apache.lucene.search.MatchAllDocsQuery;
|
||||||
import org.apache.lucene.search.Query;
|
import org.apache.lucene.search.Query;
|
||||||
@ -367,7 +368,7 @@ public class FunctionScoreQueryBuilderTests extends AbstractQueryTestCase<Functi
|
|||||||
assertThat(functionScoreQueryBuilder.maxBoost(), equalTo(10f));
|
assertThat(functionScoreQueryBuilder.maxBoost(), equalTo(10f));
|
||||||
|
|
||||||
if (i < XContentType.values().length) {
|
if (i < XContentType.values().length) {
|
||||||
queryBuilder = parseQuery(((AbstractQueryBuilder)queryBuilder).buildAsBytes(XContentType.values()[i]));
|
queryBuilder = parseQuery(((AbstractQueryBuilder<?>)queryBuilder).buildAsBytes(XContentType.values()[i]));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -414,7 +415,7 @@ public class FunctionScoreQueryBuilderTests extends AbstractQueryTestCase<Functi
|
|||||||
assertThat(functionScoreQueryBuilder.maxBoost(), equalTo(10f));
|
assertThat(functionScoreQueryBuilder.maxBoost(), equalTo(10f));
|
||||||
|
|
||||||
if (i < XContentType.values().length) {
|
if (i < XContentType.values().length) {
|
||||||
queryBuilder = parseQuery(((AbstractQueryBuilder)queryBuilder).buildAsBytes(XContentType.values()[i]));
|
queryBuilder = parseQuery(((AbstractQueryBuilder<?>)queryBuilder).buildAsBytes(XContentType.values()[i]));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user