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

[Rename] o.e.common.util (#337) 

This commit refactors the o.e.common.util package to the
o.opensearch.common.util namespace. All references throughout the codebase have
been refactored.

Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
This commit is contained in:
Nick Knize 2021-03-17 00:08:23 -05:00 committed by Nick Knize
parent b118646bef
commit 3fc453eace
510 changed files with 916 additions and 824 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client/rest-high-level/src/main/java/org/opensearch/client/RequestConverters.java
View File

@ -63,7 +63,7 @@ import org.elasticsearch.common.SuppressForbidden;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.lucene.uid.Versions;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.DeprecationHandler;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.ToXContent;

2
client/rest-high-level/src/main/java/org/opensearch/client/indices/GetIndexRequest.java
View File

@ -21,7 +21,7 @@ package org.opensearch.client.indices;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.client.TimedRequest;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
/**
* A request to retrieve information about an index.

2
client/rest-high-level/src/test/java/org/opensearch/client/ClusterRequestConvertersTests.java
View File

@ -30,7 +30,7 @@ import org.opensearch.action.support.master.AcknowledgedRequest;
import org.opensearch.client.cluster.RemoteInfoRequest;
import org.opensearch.cluster.health.ClusterHealthStatus;
import org.opensearch.common.Priority;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.test.ESTestCase;
import org.hamcrest.CoreMatchers;
import org.junit.Assert;

2
client/rest-high-level/src/test/java/org/opensearch/client/IndicesRequestConvertersTests.java
View File

@ -64,7 +64,7 @@ import org.elasticsearch.common.CheckedFunction;
import org.opensearch.common.Strings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.test.ESTestCase;
import org.junit.Assert;

2
client/rest-high-level/src/test/java/org/opensearch/client/OpenSearchRestHighLevelClientTestCase.java
View File

@ -37,7 +37,7 @@ import org.elasticsearch.common.Booleans;
import org.elasticsearch.common.CheckedRunnable;
import org.opensearch.common.bytes.BytesReference;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.common.xcontent.XContentHelper;
import org.elasticsearch.common.xcontent.XContentType;

2
client/rest-high-level/src/test/java/org/opensearch/client/RestHighLevelClientTests.java
View File

@ -55,7 +55,7 @@ import org.opensearch.client.core.MainResponse;
import org.elasticsearch.common.CheckedFunction;
import org.opensearch.common.bytes.BytesReference;
import org.elasticsearch.common.collect.Tuple;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.set.Sets;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.ToXContent;
import org.elasticsearch.common.xcontent.ToXContentFragment;

2
client/rest-high-level/src/test/java/org/opensearch/client/core/CountRequestTests.java
View File

@ -22,7 +22,7 @@ package org.opensearch.client.core;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.client.AbstractRequestTestCase;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.index.query.MatchAllQueryBuilder;

2
libs/nio/src/test/java/org/opensearch/nio/BytesChannelContextTests.java
View File

@ -20,7 +20,7 @@
package org.opensearch.nio;
import org.elasticsearch.common.CheckedFunction;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.test.ESTestCase;
import org.junit.Before;

2
libs/nio/src/test/java/org/opensearch/nio/NioSelectorGroupTests.java
View File

@ -27,7 +27,7 @@ import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.function.Consumer;
import static org.elasticsearch.common.util.concurrent.EsExecutors.daemonThreadFactory;
import static org.opensearch.common.util.concurrent.EsExecutors.daemonThreadFactory;
import static org.mockito.Mockito.mock;
public class NioSelectorGroupTests extends ESTestCase {

2
libs/nio/src/test/java/org/opensearch/nio/NioSelectorTests.java
View File

@ -21,7 +21,7 @@ package org.opensearch.nio;
import org.elasticsearch.common.CheckedRunnable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.test.ESTestCase;
import org.junit.Before;
import org.mockito.ArgumentCaptor;

4
modules/aggs-matrix-stats/src/main/java/org/opensearch/search/aggregations/matrix/stats/MatrixStatsAggregator.java
View File

@ -21,8 +21,8 @@ package org.opensearch.search.aggregations.matrix.stats;
import org.apache.lucene.index.LeafReaderContext;
import org.apache.lucene.search.ScoreMode;
import org.opensearch.common.lease.Releasables;
import org.elasticsearch.common.util.BigArrays;
import org.elasticsearch.common.util.ObjectArray;
import org.opensearch.common.util.BigArrays;
import org.opensearch.common.util.ObjectArray;
import org.elasticsearch.index.fielddata.NumericDoubleValues;
import org.opensearch.search.MultiValueMode;
import org.elasticsearch.search.aggregations.Aggregator;

2
modules/analysis-common/src/main/java/org/opensearch/analysis/common/HtmlStripCharFilterFactory.java
View File

@ -30,7 +30,7 @@ import java.util.List;
import java.util.Set;
import static java.util.Collections.unmodifiableSet;
import static org.elasticsearch.common.util.set.Sets.newHashSet;
import static org.opensearch.common.util.set.Sets.newHashSet;
public class HtmlStripCharFilterFactory extends AbstractCharFilterFactory {
private final Set<String> escapedTags;

2
modules/ingest-common/src/main/java/org/opensearch/ingest/common/DateProcessor.java
View File

@ -22,7 +22,7 @@ package org.opensearch.ingest.common;
import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.common.Nullable;
import org.opensearch.common.time.DateFormatter;
import org.elasticsearch.common.util.LocaleUtils;
import org.opensearch.common.util.LocaleUtils;
import org.elasticsearch.ingest.AbstractProcessor;
import org.elasticsearch.ingest.ConfigurationUtils;
import org.elasticsearch.ingest.IngestDocument;

2
modules/ingest-common/src/main/java/org/opensearch/ingest/common/KeyValueProcessor.java
View File

@ -19,7 +19,7 @@
package org.opensearch.ingest.common;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.set.Sets;
import org.elasticsearch.ingest.AbstractProcessor;
import org.elasticsearch.ingest.ConfigurationUtils;
import org.elasticsearch.ingest.IngestDocument;

10
modules/ingest-common/src/main/java/org/opensearch/ingest/common/ScriptProcessor.java
View File

@ -22,16 +22,16 @@ package org.opensearch.ingest.common;
import org.elasticsearch.common.Nullable;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.logging.DeprecationLogger;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.common.xcontent.LoggingDeprecationHandler;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.common.xcontent.json.JsonXContent;
import org.elasticsearch.ingest.AbstractProcessor;
import org.elasticsearch.ingest.IngestDocument;
import org.elasticsearch.ingest.Processor;
import org.opensearch.ingest.AbstractProcessor;
import org.opensearch.ingest.IngestDocument;
import org.opensearch.ingest.Processor;
import org.opensearch.script.DynamicMap;
import org.opensearch.script.IngestScript;
import org.opensearch.script.Script;
@ -44,7 +44,7 @@ import java.util.Arrays;
import java.util.Map;
import java.util.function.Function;
import static org.elasticsearch.ingest.ConfigurationUtils.newConfigurationException;
import static org.opensearch.ingest.ConfigurationUtils.newConfigurationException;
/**
* Processor that evaluates a script with an ingest document in its context.

2
modules/ingest-common/src/test/java/org/opensearch/ingest/common/AppendProcessorTests.java
View File

@ -19,7 +19,7 @@
package org.opensearch.ingest.common;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.set.Sets;
import org.elasticsearch.ingest.IngestDocument;
import org.elasticsearch.ingest.IngestDocument.Metadata;
import org.elasticsearch.ingest.Processor;

2
modules/ingest-common/src/test/java/org/opensearch/ingest/common/KeyValueProcessorFactoryTests.java
View File

@ -21,7 +21,7 @@ package org.opensearch.ingest.common;
import org.opensearch.OpenSearchException;
import org.opensearch.OpenSearchParseException;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.set.Sets;
import org.elasticsearch.test.ESTestCase;
import java.util.Arrays;

2
modules/ingest-common/src/test/java/org/opensearch/ingest/common/KeyValueProcessorTests.java
View File

@ -19,7 +19,7 @@
package org.opensearch.ingest.common;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.set.Sets;
import org.elasticsearch.ingest.IngestDocument;
import org.elasticsearch.ingest.Processor;
import org.elasticsearch.ingest.RandomDocumentPicks;

4
modules/lang-mustache/src/main/java/org/opensearch/script/mustache/CustomReflectionObjectHandler.java
View File

@ -20,8 +20,8 @@
package org.opensearch.script.mustache;
import com.github.mustachejava.reflect.ReflectionObjectHandler;
import org.elasticsearch.common.util.CollectionUtils;
import org.elasticsearch.common.util.iterable.Iterables;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.common.util.iterable.Iterables;
import java.lang.reflect.Array;
import java.util.AbstractMap;

2
modules/lang-painless/src/main/java/org/opensearch/painless/lookup/PainlessClass.java
View File

@ -19,7 +19,7 @@
package org.opensearch.painless.lookup;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.lang.invoke.MethodHandle;
import java.util.Map;

2
modules/lang-painless/src/main/java/org/opensearch/painless/lookup/PainlessLookup.java
View File

@ -19,7 +19,7 @@
package org.opensearch.painless.lookup;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.lang.invoke.MethodHandle;
import java.util.Map;

4
modules/parent-join/src/main/java/org/opensearch/join/aggregations/ParentJoinAggregator.java
View File

@ -31,8 +31,8 @@ import org.apache.lucene.util.Bits;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.lease.Releasables;
import org.opensearch.common.lucene.Lucene;
import org.elasticsearch.common.util.BigArrays;
import org.elasticsearch.common.util.BitArray;
import org.opensearch.common.util.BigArrays;
import org.opensearch.common.util.BitArray;
import org.elasticsearch.search.aggregations.Aggregator;
import org.elasticsearch.search.aggregations.AggregatorFactories;
import org.elasticsearch.search.aggregations.CardinalityUpperBound;

2
modules/rank-eval/src/test/java/org/opensearch/index/rankeval/RankEvalRequestTests.java
View File

@ -23,7 +23,7 @@ import org.opensearch.action.search.SearchType;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.common.io.stream.NamedWriteableRegistry;
import org.opensearch.common.io.stream.Writeable.Reader;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.test.AbstractWireSerializingTestCase;
import org.junit.AfterClass;

2
modules/reindex/src/main/java/org/opensearch/index/reindex/AbstractAsyncBulkByScrollAction.java
View File

@ -39,7 +39,7 @@ import org.opensearch.client.ParentTaskAssigningClient;
import org.elasticsearch.common.Nullable;
import org.opensearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.index.VersionType;
import org.elasticsearch.index.mapper.IdFieldMapper;
import org.elasticsearch.index.mapper.IndexFieldMapper;

2
modules/reindex/src/main/java/org/opensearch/index/reindex/remote/RemoteResponseParsers.java
View File

@ -25,7 +25,7 @@ import org.elasticsearch.common.ParseField;
import org.opensearch.common.ParsingException;
import org.opensearch.common.bytes.BytesReference;
import org.elasticsearch.common.collect.Tuple;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.common.xcontent.ConstructingObjectParser;
import org.elasticsearch.common.xcontent.ObjectParser;
import org.elasticsearch.common.xcontent.ObjectParser.ValueType;

6
modules/reindex/src/main/java/org/opensearch/index/reindex/remote/RemoteScrollableHitSource.java
View File

@ -39,14 +39,14 @@ import org.elasticsearch.common.Nullable;
import org.opensearch.common.Strings;
import org.opensearch.common.bytes.BytesReference;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.xcontent.LoggingDeprecationHandler;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.common.xcontent.XContentParseException;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.reindex.RejectAwareActionListener;
import org.elasticsearch.index.reindex.ScrollableHitSource;
import org.opensearch.index.reindex.RejectAwareActionListener;
import org.opensearch.index.reindex.ScrollableHitSource;
import org.opensearch.rest.RestStatus;
import org.opensearch.threadpool.ThreadPool;

4
modules/reindex/src/test/java/org/opensearch/index/reindex/AsyncBulkByScrollActionTests.java
View File

@ -62,8 +62,8 @@ import org.opensearch.common.bytes.BytesArray;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.text.Text;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.common.xcontent.XContentType;
import org.opensearch.index.Index;
import org.opensearch.index.engine.VersionConflictEngineException;

2
modules/reindex/src/test/java/org/opensearch/index/reindex/ClientScrollableHitSourceTests.java
View File

@ -36,7 +36,7 @@ import org.opensearch.common.bytes.BytesArray;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.text.Text;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.index.reindex.ClientScrollableHitSource;
import org.elasticsearch.index.reindex.ScrollableHitSource;
import org.opensearch.search.SearchHit;

2
modules/reindex/src/test/java/org/opensearch/index/reindex/ReindexFromRemoteWithAuthTests.java
View File

@ -38,7 +38,7 @@ import org.opensearch.common.io.stream.NamedWriteableRegistry;
import org.opensearch.common.network.NetworkModule;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.transport.TransportAddress;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.opensearch.env.Environment;
import org.opensearch.env.NodeEnvironment;

3
modules/reindex/src/test/java/org/opensearch/index/reindex/ReindexSourceTargetValidationTests.java
View File

@ -35,9 +35,8 @@ import org.opensearch.common.bytes.BytesArray;
import org.opensearch.common.bytes.BytesReference;
import org.elasticsearch.common.settings.ClusterSettings;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.index.reindex.RemoteInfo;
import org.opensearch.indices.SystemIndices;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.elasticsearch.test.ESTestCase;
import java.util.HashMap;

2
modules/reindex/src/test/java/org/opensearch/index/reindex/RetryTests.java
View File

@ -30,7 +30,7 @@ import org.opensearch.client.Client;
import org.opensearch.common.bytes.BytesArray;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.transport.TransportAddress;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.http.HttpInfo;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.reindex.AbstractBulkByScrollRequestBuilder;

4
modules/reindex/src/test/java/org/opensearch/index/reindex/remote/RemoteResponseParsersTests.java
View File

@ -20,11 +20,11 @@
package org.opensearch.index.reindex.remote;
import org.opensearch.action.search.ShardSearchFailure;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.common.xcontent.ToXContent;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.index.reindex.ScrollableHitSource;
import org.opensearch.index.reindex.ScrollableHitSource;
import org.elasticsearch.test.ESTestCase;
import org.hamcrest.Matchers;

4
modules/reindex/src/test/java/org/opensearch/index/reindex/remote/RemoteScrollableHitSourceTests.java
View File

@ -50,8 +50,8 @@ import org.opensearch.common.io.Streams;
import org.opensearch.common.unit.ByteSizeUnit;
import org.opensearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsExecutors;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.index.reindex.RejectAwareActionListener;
import org.elasticsearch.index.reindex.ScrollableHitSource;
import org.elasticsearch.index.reindex.ScrollableHitSource.Response;

2
modules/repository-url/src/main/java/org/opensearch/repositories/url/URLRepository.java
View File

@ -29,7 +29,7 @@ import org.opensearch.common.blobstore.BlobStore;
import org.opensearch.common.blobstore.url.URLBlobStore;
import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.util.URIPattern;
import org.opensearch.common.util.URIPattern;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.opensearch.env.Environment;
import org.elasticsearch.indices.recovery.RecoverySettings;

4
modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpServerTransport.java
View File

@ -49,8 +49,8 @@ import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.unit.ByteSizeUnit;
import org.opensearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.util.BigArrays;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.opensearch.common.util.BigArrays;
import org.opensearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.core.internal.net.NetUtils;

4
modules/transport-netty4/src/main/java/org/opensearch/transport/Netty4Plugin.java
View File

@ -27,8 +27,8 @@ import org.opensearch.common.network.NetworkService;
import org.elasticsearch.common.settings.ClusterSettings;
import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.util.BigArrays;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.BigArrays;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.http.HttpServerTransport;
import org.opensearch.http.netty4.Netty4HttpServerTransport;

2
modules/transport-netty4/src/main/java/org/opensearch/transport/SharedGroupFactory.java
View File

@ -33,7 +33,7 @@ import org.opensearch.transport.netty4.Netty4Transport;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import static org.elasticsearch.common.util.concurrent.EsExecutors.daemonThreadFactory;
import static org.opensearch.common.util.concurrent.EsExecutors.daemonThreadFactory;
/**
* Creates and returns {@link io.netty.channel.EventLoopGroup} instances. It will return a shared group for

2
modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4MessageChannelHandler.java
View File

@ -30,7 +30,7 @@ import org.elasticsearch.ExceptionsHelper;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.bytes.ReleasableBytesReference;
import org.opensearch.common.lease.Releasables;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.PageCacheRecycler;
import org.opensearch.threadpool.ThreadPool;
import org.opensearch.transport.InboundPipeline;
import org.opensearch.transport.Transport;

6
modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4Transport.java
View File

@ -47,8 +47,8 @@ import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.unit.ByteSizeUnit;
import org.opensearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.opensearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.core.internal.net.NetUtils;
import org.elasticsearch.indices.breaker.CircuitBreakerService;
import org.opensearch.threadpool.ThreadPool;
@ -66,7 +66,7 @@ import java.util.Map;
import static org.elasticsearch.common.settings.Setting.byteSizeSetting;
import static org.elasticsearch.common.settings.Setting.intSetting;
import static org.elasticsearch.common.util.concurrent.ConcurrentCollections.newConcurrentMap;
import static org.opensearch.common.util.concurrent.ConcurrentCollections.newConcurrentMap;
/**
* There are 4 types of connections per node, low/med/high/ping. Low if for batch oriented APIs (like recovery or

2
modules/transport-netty4/src/test/java/org/opensearch/http/netty4/Netty4BadRequestTests.java
View File

@ -28,7 +28,7 @@ import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.transport.TransportAddress;
import org.elasticsearch.common.util.MockBigArrays;
import org.elasticsearch.common.util.MockPageCacheRecycler;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.elasticsearch.http.HttpServerTransport;
import org.elasticsearch.http.HttpTransportSettings;
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;

2
modules/transport-netty4/src/test/java/org/opensearch/http/netty4/Netty4HttpServerTransportTests.java
View File

@ -56,7 +56,7 @@ import org.opensearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.MockBigArrays;
import org.elasticsearch.common.util.MockPageCacheRecycler;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.elasticsearch.http.BindHttpException;
import org.elasticsearch.http.CorsHandler;
import org.elasticsearch.http.HttpServerTransport;

2
modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/Netty4SizeHeaderFrameDecoderTests.java
View File

@ -25,7 +25,7 @@ import org.opensearch.common.network.NetworkService;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.transport.TransportAddress;
import org.elasticsearch.common.util.MockPageCacheRecycler;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;
import org.elasticsearch.mocksocket.MockSocket;
import org.elasticsearch.test.ESTestCase;

4
modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/Netty4UtilsTests.java
View File

@ -28,8 +28,8 @@ import org.elasticsearch.common.bytes.AbstractBytesReferenceTestCase;
import org.opensearch.common.bytes.BytesArray;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.io.stream.ReleasableBytesStreamOutput;
import org.elasticsearch.common.util.BigArrays;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.BigArrays;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;
import org.elasticsearch.test.ESTestCase;

2
modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/NettyTransportMultiPortTests.java
View File

@ -25,7 +25,7 @@ import org.opensearch.common.network.NetworkService;
import org.opensearch.common.network.NetworkUtils;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.util.MockPageCacheRecycler;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;
import org.elasticsearch.test.ESTestCase;
import org.opensearch.threadpool.TestThreadPool;

2
modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/SimpleNetty4TransportTests.java
View File

@ -28,7 +28,7 @@ import org.opensearch.common.network.NetworkService;
import org.elasticsearch.common.settings.ClusterSettings;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.transport.TransportAddress;
import org.elasticsearch.common.util.PageCacheRecycler;
import org.opensearch.common.util.PageCacheRecycler;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.core.internal.net.NetUtils;
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;

2
server/src/main/java/org/elasticsearch/ExceptionsHelper.java
View File

@ -27,7 +27,7 @@ import org.apache.lucene.index.IndexFormatTooNewException;
import org.apache.lucene.index.IndexFormatTooOldException;
import org.opensearch.action.ShardOperationFailedException;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.index.Index;
import org.opensearch.rest.RestStatus;

2
server/src/main/java/org/elasticsearch/search/aggregations/InternalAggregation.java
View File

@ -23,7 +23,7 @@ import org.opensearch.common.Strings;
import org.opensearch.common.io.stream.NamedWriteable;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.BigArrays;
import org.opensearch.common.util.BigArrays;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.rest.action.search.RestSearchAction;
import org.opensearch.script.ScriptService;

2
server/src/main/java/org/elasticsearch/search/aggregations/InternalOrder.java
View File

@ -23,7 +23,7 @@ import org.opensearch.common.ParsingException;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.logging.DeprecationLogger;
import org.elasticsearch.common.util.Comparators;
import org.opensearch.common.util.Comparators;
import org.elasticsearch.common.xcontent.XContent;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentParser;

2
server/src/main/java/org/elasticsearch/watcher/FileWatcher.java
View File

@ -21,7 +21,7 @@ package org.elasticsearch.watcher;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.opensearch.common.io.FileSystemUtils;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.IOException;
import java.nio.file.Files;

2
server/src/main/java/org/opensearch/action/ActionRunnable.java
View File

@ -22,7 +22,7 @@ package org.opensearch.action;
import org.elasticsearch.common.CheckedConsumer;
import org.elasticsearch.common.CheckedRunnable;
import org.opensearch.common.CheckedSupplier;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
/**
* Base class for {@link Runnable}s that need to call {@link ActionListener#onFailure(Exception)} in case an uncaught

6
server/src/main/java/org/opensearch/action/StepListener.java
View File

@ -20,9 +20,9 @@
package org.opensearch.action;
import org.elasticsearch.common.CheckedConsumer;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.common.util.concurrent.FutureUtils;
import org.elasticsearch.common.util.concurrent.ListenableFuture;
import org.opensearch.common.util.concurrent.EsExecutors;
import org.opensearch.common.util.concurrent.FutureUtils;
import org.opensearch.common.util.concurrent.ListenableFuture;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;

2
server/src/main/java/org/opensearch/action/admin/cluster/health/TransportClusterHealthAction.java
View File

@ -43,7 +43,7 @@ import org.opensearch.common.Strings;
import org.opensearch.common.inject.Inject;
import org.opensearch.common.io.stream.StreamInput;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.index.IndexNotFoundException;
import org.opensearch.node.NodeClosedException;
import org.opensearch.tasks.Task;

6
server/src/main/java/org/opensearch/action/admin/cluster/node/tasks/get/TransportGetTaskAction.java
View File

@ -31,14 +31,14 @@ import org.opensearch.action.support.HandledTransportAction;
import org.opensearch.client.Client;
import org.opensearch.client.OriginSettingClient;
import org.opensearch.cluster.node.DiscoveryNode;
import org.elasticsearch.cluster.service.ClusterService;
import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.inject.Inject;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.xcontent.LoggingDeprecationHandler;
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.opensearch.common.xcontent.XContentHelper;
import org.elasticsearch.common.xcontent.XContentParser;
import org.elasticsearch.index.IndexNotFoundException;
import org.opensearch.index.IndexNotFoundException;
import org.opensearch.tasks.Task;
import org.opensearch.tasks.TaskId;
import org.opensearch.tasks.TaskInfo;

2
server/src/main/java/org/opensearch/action/admin/cluster/repositories/get/GetRepositoriesRequestBuilder.java
View File

@ -21,7 +21,7 @@ package org.opensearch.action.admin.cluster.repositories.get;
import org.opensearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
/**
* Get repository request builder

2
server/src/main/java/org/opensearch/action/admin/cluster/snapshots/get/GetSnapshotsRequestBuilder.java
View File

@ -21,7 +21,7 @@ package org.opensearch.action.admin.cluster.snapshots.get;
import org.opensearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
/**
* Get snapshots request builder

2
server/src/main/java/org/opensearch/action/admin/cluster/snapshots/status/SnapshotsStatusRequestBuilder.java
View File

@ -21,7 +21,7 @@ package org.opensearch.action.admin.cluster.snapshots.status;
import org.opensearch.action.support.master.MasterNodeOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
/**
* Snapshots status request builder

4
server/src/main/java/org/opensearch/action/admin/cluster/snapshots/status/TransportSnapshotsStatusAction.java
View File

@ -38,8 +38,8 @@ import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.Strings;
import org.opensearch.common.inject.Inject;
import org.opensearch.common.io.stream.StreamInput;
import org.elasticsearch.common.util.CollectionUtils;
import org.elasticsearch.common.util.set.Sets;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.common.util.set.Sets;
import org.opensearch.index.shard.ShardId;
import org.opensearch.index.snapshots.IndexShardSnapshotStatus;
import org.opensearch.repositories.IndexId;

2
server/src/main/java/org/opensearch/action/admin/indices/alias/get/BaseAliasesRequestBuilder.java
View File

@ -24,7 +24,7 @@ import org.opensearch.action.ActionResponse;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
public abstract class BaseAliasesRequestBuilder<Response extends ActionResponse,
Builder extends BaseAliasesRequestBuilder<Response, Builder>>

2
server/src/main/java/org/opensearch/action/admin/indices/alias/get/TransportGetAliasesAction.java
View File

@ -32,7 +32,7 @@ import org.opensearch.common.collect.ImmutableOpenMap;
import org.opensearch.common.inject.Inject;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.logging.DeprecationLogger;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import org.opensearch.indices.SystemIndices;
import org.opensearch.threadpool.ThreadPool;
import org.opensearch.transport.TransportService;

2
server/src/main/java/org/opensearch/action/admin/indices/close/CloseIndexRequest.java
View File

@ -27,7 +27,7 @@ import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.AcknowledgedRequest;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.IOException;

2
server/src/main/java/org/opensearch/action/admin/indices/close/CloseIndexResponse.java
View File

@ -27,7 +27,7 @@ import org.opensearch.common.Strings;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.index.Index;

2
server/src/main/java/org/opensearch/action/admin/indices/datastream/DeleteDataStreamAction.java
View File

@ -45,7 +45,7 @@ import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.regex.Regex;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.index.Index;
import org.opensearch.snapshots.SnapshotInProgressException;
import org.opensearch.snapshots.SnapshotsService;

2
server/src/main/java/org/opensearch/action/admin/indices/delete/DeleteIndexRequest.java
View File

@ -25,7 +25,7 @@ import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.AcknowledgedRequest;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.IOException;

2
server/src/main/java/org/opensearch/action/admin/indices/flush/SyncedFlushResponse.java
View File

@ -23,7 +23,7 @@ import org.opensearch.cluster.routing.ShardRouting;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.iterable.Iterables;
import org.opensearch.common.util.iterable.Iterables;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.indices.flush.ShardsSyncedFlushResult;

2
server/src/main/java/org/opensearch/action/admin/indices/get/GetIndexRequest.java
View File

@ -24,7 +24,7 @@ import org.opensearch.action.ActionRequestValidationException;
import org.opensearch.action.support.master.info.ClusterInfoRequest;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
import java.io.IOException;

2
server/src/main/java/org/opensearch/action/admin/indices/mapping/get/GetFieldMappingsRequestBuilder.java
View File

@ -22,7 +22,7 @@ package org.opensearch.action.admin.indices.mapping.get;
import org.opensearch.action.ActionRequestBuilder;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
/** A helper class to build {@link GetFieldMappingsRequest} objects */
public class GetFieldMappingsRequestBuilder

2
server/src/main/java/org/opensearch/action/admin/indices/mapping/put/PutMappingRequest.java
View File

@ -33,7 +33,7 @@ import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.xcontent.ToXContentObject;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.opensearch.common.xcontent.XContentHelper;

2
server/src/main/java/org/opensearch/action/admin/indices/open/OpenIndexRequest.java
View File

@ -27,7 +27,7 @@ import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.AcknowledgedRequest;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.IOException;

2
server/src/main/java/org/opensearch/action/admin/indices/readonly/AddIndexBlockRequest.java
View File

@ -26,7 +26,7 @@ import org.opensearch.action.support.master.AcknowledgedRequest;
import org.opensearch.cluster.metadata.IndexMetadata.APIBlock;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.IOException;
import java.util.Objects;

2
server/src/main/java/org/opensearch/action/admin/indices/readonly/AddIndexBlockResponse.java
View File

@ -26,7 +26,7 @@ import org.opensearch.common.Strings;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.index.Index;

2
server/src/main/java/org/opensearch/action/admin/indices/resolve/ResolveIndexAction.java
View File

@ -44,7 +44,7 @@ import org.opensearch.common.inject.Inject;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.elasticsearch.common.xcontent.ToXContentObject;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.tasks.Task;

2
server/src/main/java/org/opensearch/action/admin/indices/settings/get/GetSettingsRequestBuilder.java
View File

@ -22,7 +22,7 @@ package org.opensearch.action.admin.indices.settings.get;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
public class GetSettingsRequestBuilder
extends MasterNodeReadOperationRequestBuilder<GetSettingsRequest, GetSettingsResponse, GetSettingsRequestBuilder> {

2
server/src/main/java/org/opensearch/action/admin/indices/shards/TransportIndicesShardStoresAction.java
View File

@ -45,7 +45,7 @@ import org.opensearch.common.collect.ImmutableOpenMap;
import org.elasticsearch.common.collect.Tuple;
import org.opensearch.common.inject.Inject;
import org.opensearch.common.io.stream.StreamInput;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.gateway.AsyncShardFetch;
import org.opensearch.gateway.TransportNodesListGatewayStartedShards;
import org.opensearch.gateway.TransportNodesListGatewayStartedShards.NodeGatewayStartedShards;

2
server/src/main/java/org/opensearch/action/bulk/TransportBulkAction.java
View File

@ -58,7 +58,7 @@ import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.inject.Inject;
import org.opensearch.common.lease.Releasable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.index.Index;
import org.opensearch.index.IndexNotFoundException;
import org.opensearch.index.IndexingPressure;

2
server/src/main/java/org/opensearch/action/fieldcaps/TransportFieldCapabilitiesAction.java
View File

@ -29,7 +29,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.Strings;
import org.opensearch.common.inject.Inject;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.tasks.Task;
import org.opensearch.threadpool.ThreadPool;
import org.opensearch.transport.RemoteClusterAware;

2
server/src/main/java/org/opensearch/action/get/TransportMultiGetAction.java
View File

@ -28,7 +28,7 @@ import org.opensearch.cluster.block.ClusterBlockLevel;
import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.inject.Inject;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.tasks.Task;
import org.opensearch.transport.TransportService;

4
server/src/main/java/org/opensearch/action/search/AbstractSearchAsyncAction.java
View File

@ -34,8 +34,8 @@ import org.elasticsearch.cluster.routing.GroupShardsIterator;
import org.elasticsearch.common.Nullable;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.lease.Releasables;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;

2
server/src/main/java/org/opensearch/action/search/ArraySearchPhaseResults.java
View File

@ -19,7 +19,7 @@
package org.opensearch.action.search;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.SearchPhaseResult;
import java.util.stream.Stream;

2
server/src/main/java/org/opensearch/action/search/ClearScrollController.java
View File

@ -26,7 +26,7 @@ import org.opensearch.action.support.GroupedActionListener;
import org.opensearch.cluster.node.DiscoveryNode;
import org.opensearch.cluster.node.DiscoveryNodes;
import org.opensearch.common.Strings;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.transport.Transport;
import org.opensearch.transport.TransportResponse;

2
server/src/main/java/org/opensearch/action/search/CountedCollector.java
View File

@ -19,7 +19,7 @@
package org.opensearch.action.search;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;

2
server/src/main/java/org/opensearch/action/search/ExpandSearchPhase.java
View File

@ -20,7 +20,7 @@
package org.opensearch.action.search;
import org.opensearch.action.ActionListener;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.InnerHitBuilder;
import org.elasticsearch.index.query.QueryBuilder;

4
server/src/main/java/org/opensearch/action/search/FetchSearchPhase.java
View File

@ -23,8 +23,8 @@ import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage;
import org.apache.lucene.search.ScoreDoc;
import org.opensearch.action.OriginalIndices;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.RescoreDocIds;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;

2
server/src/main/java/org/opensearch/action/search/QueryPhaseResultConsumer.java
View File

@ -28,7 +28,7 @@ import org.opensearch.common.io.stream.NamedWriteableRegistry;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.lease.Releasables;
import org.elasticsearch.common.lucene.search.TopDocsAndMaxScore;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;
import org.elasticsearch.search.aggregations.InternalAggregation.ReduceContextBuilder;

2
server/src/main/java/org/opensearch/action/search/SearchPhaseContext.java
View File

@ -22,7 +22,7 @@ import org.apache.logging.log4j.Logger;
import org.opensearch.action.OriginalIndices;
import org.elasticsearch.common.Nullable;
import org.opensearch.common.lease.Releasable;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;
import org.opensearch.search.internal.InternalSearchResponse;

2
server/src/main/java/org/opensearch/action/search/SearchPhaseExecutionException.java
View File

@ -24,7 +24,7 @@ import org.elasticsearch.ExceptionsHelper;
import org.opensearch.action.ShardOperationFailedException;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.rest.RestStatus;

2
server/src/main/java/org/opensearch/action/search/SearchPhaseResults.java
View File

@ -19,7 +19,7 @@
package org.opensearch.action.search;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.SearchPhaseResult;
import java.util.stream.Stream;

4
server/src/main/java/org/opensearch/action/search/SearchScrollAsyncAction.java
View File

@ -25,8 +25,8 @@ import org.opensearch.action.ActionListener;
import org.opensearch.cluster.node.DiscoveryNode;
import org.opensearch.cluster.node.DiscoveryNodes;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;
import org.opensearch.search.internal.InternalScrollSearchRequest;

2
server/src/main/java/org/opensearch/action/search/SearchScrollQueryAndFetchAsyncAction.java
View File

@ -23,7 +23,7 @@ import org.apache.logging.log4j.Logger;
import org.opensearch.action.ActionListener;
import org.opensearch.cluster.node.DiscoveryNode;
import org.opensearch.cluster.service.ClusterService;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.fetch.QueryFetchSearchResult;
import org.opensearch.search.fetch.ScrollQueryFetchSearchResult;
import org.opensearch.search.internal.InternalScrollSearchRequest;

4
server/src/main/java/org/opensearch/action/search/SearchScrollQueryThenFetchAsyncAction.java
View File

@ -25,8 +25,8 @@ import org.apache.lucene.search.ScoreDoc;
import org.opensearch.action.ActionListener;
import org.opensearch.cluster.node.DiscoveryNode;
import org.opensearch.cluster.service.ClusterService;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.CountDown;
import org.opensearch.search.SearchShardTarget;
import org.opensearch.search.fetch.FetchSearchResult;
import org.opensearch.search.fetch.ShardFetchRequest;

4
server/src/main/java/org/opensearch/action/search/SearchShardIterator.java
View File

@ -24,8 +24,8 @@ import org.opensearch.cluster.routing.PlainShardIterator;
import org.opensearch.cluster.routing.ShardRouting;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.Countable;
import org.elasticsearch.common.util.PlainIterator;
import org.opensearch.common.util.Countable;
import org.opensearch.common.util.PlainIterator;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.search.SearchShardTarget;
import org.opensearch.search.internal.ShardSearchContextId;

2
server/src/main/java/org/opensearch/action/search/SearchTransportService.java
View File

@ -31,7 +31,7 @@ import org.elasticsearch.common.Nullable;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.concurrent.ConcurrentCollections;
import org.opensearch.common.util.concurrent.ConcurrentCollections;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchService;
import org.opensearch.search.dfs.DfsSearchResult;

2
server/src/main/java/org/opensearch/action/search/TransportSearchHelper.java
View File

@ -22,7 +22,7 @@ package org.opensearch.action.search;
import org.apache.lucene.store.ByteArrayDataInput;
import org.apache.lucene.store.RAMOutputStream;
import org.opensearch.Version;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.search.SearchPhaseResult;
import org.opensearch.search.SearchShardTarget;
import org.opensearch.search.internal.InternalScrollSearchRequest;

6
server/src/main/java/org/opensearch/action/support/AdapterActionFuture.java
View File

@ -23,9 +23,9 @@ import org.opensearch.OpenSearchException;
import org.opensearch.action.ActionFuture;
import org.opensearch.action.ActionListener;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.BaseFuture;
import org.elasticsearch.common.util.concurrent.FutureUtils;
import org.elasticsearch.common.util.concurrent.UncategorizedExecutionException;
import org.opensearch.common.util.concurrent.BaseFuture;
import org.opensearch.common.util.concurrent.FutureUtils;
import org.opensearch.common.util.concurrent.UncategorizedExecutionException;
import java.util.concurrent.TimeUnit;

4
server/src/main/java/org/opensearch/action/support/ContextPreservingActionListener.java
View File

@ -19,12 +19,12 @@
package org.opensearch.action.support;
import org.opensearch.action.ActionListener;
import org.elasticsearch.common.util.concurrent.ThreadContext;
import org.opensearch.common.util.concurrent.ThreadContext;
import java.util.function.Supplier;
/**
* Restores the given {@link org.elasticsearch.common.util.concurrent.ThreadContext.StoredContext}
* Restores the given {@link org.opensearch.common.util.concurrent.ThreadContext.StoredContext}
* once the listener is invoked
*/
public final class ContextPreservingActionListener<R> implements ActionListener<R> {

4
server/src/main/java/org/opensearch/action/support/GroupedActionListener.java
View File

@ -19,8 +19,8 @@
package org.opensearch.action.support;
import org.opensearch.action.ActionListener;
import org.elasticsearch.common.util.concurrent.AtomicArray;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.AtomicArray;
import org.opensearch.common.util.concurrent.CountDown;
import java.util.Collection;
import java.util.Collections;

2
server/src/main/java/org/opensearch/action/support/master/info/ClusterInfoRequestBuilder.java
View File

@ -23,7 +23,7 @@ import org.opensearch.action.ActionResponse;
import org.opensearch.action.support.IndicesOptions;
import org.opensearch.action.support.master.MasterNodeReadOperationRequestBuilder;
import org.opensearch.client.OpenSearchClient;
import org.elasticsearch.common.util.ArrayUtils;
import org.opensearch.common.util.ArrayUtils;
public abstract class ClusterInfoRequestBuilder<Request extends ClusterInfoRequest<Request>, Response extends ActionResponse,
Builder extends ClusterInfoRequestBuilder<Request, Response, Builder>>

2
server/src/main/java/org/opensearch/action/support/replication/PendingReplicationActions.java
View File

@ -21,7 +21,7 @@ package org.opensearch.action.support.replication;
import org.opensearch.action.support.RetryableAction;
import org.opensearch.common.lease.Releasable;
import org.elasticsearch.common.util.concurrent.ConcurrentCollections;
import org.opensearch.common.util.concurrent.ConcurrentCollections;
import org.elasticsearch.index.shard.IndexShardClosedException;
import org.elasticsearch.index.shard.ReplicationGroup;
import org.elasticsearch.index.shard.ShardId;

2
server/src/main/java/org/opensearch/action/support/replication/ReplicationOperation.java
View File

@ -36,7 +36,7 @@ import org.elasticsearch.common.Nullable;
import org.opensearch.common.breaker.CircuitBreakingException;
import org.opensearch.common.io.stream.StreamInput;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
import org.opensearch.common.util.concurrent.EsRejectedExecutionException;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.ReplicationGroup;
import org.elasticsearch.index.shard.ShardId;

2
server/src/main/java/org/opensearch/action/support/replication/TransportBroadcastReplicationAction.java
View File

@ -35,7 +35,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
import org.opensearch.cluster.routing.IndexShardRoutingTable;
import org.opensearch.cluster.service.ClusterService;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.util.concurrent.CountDown;
import org.opensearch.common.util.concurrent.CountDown;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.tasks.Task;
import org.opensearch.transport.TransportService;

2
server/src/main/java/org/opensearch/action/support/single/instance/TransportInstanceSingleOperationAction.java
View File

@ -37,7 +37,7 @@ import org.elasticsearch.common.Nullable;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.Writeable;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.index.IndexNotFoundException;
import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.node.NodeClosedException;

Some files were not shown because too many files have changed in this diff Show More