[Rename] o.e.common subpackages round 1 (#332)
* [Rename] o.e.common subpackages round 1 This commit refactors the following subpackages of o.e.common: * o.e.common.joda * o.e.common.lease * o.e.common.metrics * o.e.common.network * o.e.common.path * o.e.common.recycling * o.e.common.regex * o.e.common.rounding * o.e.common.text * o.e.common.time * o.e.common.transport to the o.opensearch namespace. All references throughout the codebase have been refactored. Signed-off-by: Nicholas Knize <nknize@amazon.com> * fix imports 1 Signed-off-by: Nicholas Knize <nknize@amazon.com>
This commit is contained in:
parent
d9d56f5019
commit
946c7bb2dc
|
@ -29,7 +29,7 @@ import org.opensearch.client.benchmark.ops.bulk.BulkRequestExecutor;
|
|||
import org.opensearch.client.benchmark.ops.search.SearchRequestExecutor;
|
||||
import org.opensearch.client.transport.TransportClient;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
import org.elasticsearch.index.query.QueryBuilders;
|
||||
import org.opensearch.plugin.noop.NoopPlugin;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.client.indices;
|
|||
|
||||
import org.opensearch.client.core.BroadcastResponse;
|
||||
import org.elasticsearch.common.ParseField;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.xcontent.ConstructingObjectParser;
|
||||
import org.elasticsearch.common.xcontent.ObjectParser;
|
||||
import org.elasticsearch.common.xcontent.XContentParser;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.action.admin.indices.rollover.MaxDocsCondition;
|
|||
import org.opensearch.action.admin.indices.rollover.MaxSizeCondition;
|
||||
import org.opensearch.client.TimedRequest;
|
||||
import org.opensearch.client.indices.CreateIndexRequest;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.ToXContentObject;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
|
|
|
@ -34,8 +34,8 @@ import org.elasticsearch.action.index.IndexRequest;
|
|||
import org.elasticsearch.action.search.SearchRequest;
|
||||
import org.opensearch.common.Strings;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -49,7 +49,7 @@ import org.opensearch.cluster.metadata.Template;
|
|||
import org.opensearch.cluster.routing.allocation.decider.EnableAllocationDecider;
|
||||
import org.opensearch.common.compress.CompressedXContent;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
import org.elasticsearch.common.xcontent.support.XContentMapValues;
|
||||
|
|
|
@ -49,8 +49,8 @@ import org.opensearch.client.indices.GetIndexRequest;
|
|||
import org.opensearch.common.Strings;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -105,8 +105,8 @@ import org.opensearch.common.bytes.BytesArray;
|
|||
import org.opensearch.common.compress.CompressedXContent;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -36,7 +36,7 @@ import org.opensearch.action.admin.cluster.snapshots.status.SnapshotsStatusReque
|
|||
import org.opensearch.action.support.master.AcknowledgedRequest;
|
||||
import org.elasticsearch.common.io.PathUtils;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.repositories.fs.FsRepository;
|
||||
import org.elasticsearch.test.ESTestCase;
|
||||
|
||||
|
|
|
@ -64,8 +64,8 @@ import org.opensearch.client.indices.CreateIndexResponse;
|
|||
import org.opensearch.common.Strings;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -50,7 +50,7 @@ import org.opensearch.cluster.routing.allocation.decider.EnableAllocationDecider
|
|||
import org.opensearch.common.Priority;
|
||||
import org.opensearch.common.compress.CompressedXContent;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
import org.elasticsearch.indices.recovery.RecoverySettings;
|
||||
|
|
|
@ -93,8 +93,8 @@ import org.opensearch.cluster.metadata.MappingMetadata;
|
|||
import org.opensearch.cluster.metadata.Template;
|
||||
import org.opensearch.common.compress.CompressedXContent;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -24,7 +24,7 @@ import org.opensearch.common.geo.GeoPoint;
|
|||
import org.opensearch.common.geo.ShapeRelation;
|
||||
import org.opensearch.common.geo.builders.CoordinatesBuilder;
|
||||
import org.opensearch.common.geo.builders.MultiPointBuilder;
|
||||
import org.elasticsearch.common.unit.DistanceUnit;
|
||||
import org.opensearch.common.unit.DistanceUnit;
|
||||
import org.elasticsearch.index.query.GeoShapeQueryBuilder;
|
||||
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
|
||||
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder.FilterFunctionBuilder;
|
||||
|
|
|
@ -54,8 +54,8 @@ import org.opensearch.client.indices.CreateIndexRequest;
|
|||
import org.opensearch.client.indices.CreateIndexResponse;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.document.DocumentField;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.elasticsearch.common.unit.Fuzziness;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.opensearch.common.unit.Fuzziness;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.opensearch.OpenSearchException;
|
|||
import org.opensearch.action.admin.indices.datastream.DataStreamsStatsAction;
|
||||
import org.opensearch.action.support.DefaultShardOperationFailedException;
|
||||
import org.opensearch.client.AbstractResponseTestCase;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentParser;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.opensearch.action.admin.indices.rollover.Condition;
|
|||
import org.opensearch.action.admin.indices.rollover.MaxAgeCondition;
|
||||
import org.opensearch.action.admin.indices.rollover.MaxDocsCondition;
|
||||
import org.opensearch.action.admin.indices.rollover.MaxSizeCondition;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.test.ESTestCase;
|
||||
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.opensearch.action.admin.indices.rollover.Condition;
|
|||
import org.opensearch.action.admin.indices.rollover.MaxAgeCondition;
|
||||
import org.opensearch.action.admin.indices.rollover.MaxDocsCondition;
|
||||
import org.opensearch.action.admin.indices.rollover.MaxSizeCondition;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.opensearch.cluster.node.DiscoveryNode;
|
|||
import org.opensearch.cluster.node.DiscoveryNodes;
|
||||
import org.opensearch.common.io.stream.StreamInput;
|
||||
import org.opensearch.common.io.stream.StreamOutput;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentParser;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -24,7 +24,7 @@ import io.netty.util.concurrent.GlobalEventExecutor;
|
|||
|
||||
import org.opensearch.client.transport.TransportClient;
|
||||
import org.elasticsearch.common.SuppressForbidden;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.opensearch.index.reindex.ReindexPlugin;
|
||||
import org.opensearch.join.ParentJoinPlugin;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.transport.client;
|
|||
|
||||
import com.carrotsearch.randomizedtesting.RandomizedTest;
|
||||
import org.opensearch.client.transport.TransportClient;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.opensearch.index.reindex.ReindexPlugin;
|
||||
import org.opensearch.join.ParentJoinPlugin;
|
||||
|
|
|
@ -20,7 +20,7 @@ package org.opensearch.search.aggregations.matrix.stats;
|
|||
|
||||
import org.apache.lucene.index.LeafReaderContext;
|
||||
import org.apache.lucene.search.ScoreMode;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.util.BigArrays;
|
||||
import org.elasticsearch.common.util.ObjectArray;
|
||||
import org.elasticsearch.index.fielddata.NumericDoubleValues;
|
||||
|
|
|
@ -117,7 +117,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
|
|||
import org.opensearch.cluster.service.ClusterService;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.logging.DeprecationLogger;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
|
||||
import org.elasticsearch.env.Environment;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.analysis.common;
|
|||
|
||||
import org.apache.lucene.analysis.Analyzer;
|
||||
import org.apache.lucene.analysis.CharArraySet;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.env.Environment;
|
||||
import org.elasticsearch.index.IndexSettings;
|
||||
|
|
|
@ -20,7 +20,7 @@ package org.opensearch.analysis.common;
|
|||
|
||||
import org.apache.lucene.analysis.pattern.PatternReplaceCharFilter;
|
||||
import org.opensearch.common.Strings;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.opensearch.env.Environment;
|
||||
import org.elasticsearch.index.IndexSettings;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.analysis.common;
|
|||
|
||||
import org.apache.lucene.analysis.TokenStream;
|
||||
import org.apache.lucene.analysis.pattern.PatternReplaceFilter;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.opensearch.env.Environment;
|
||||
import org.elasticsearch.index.IndexSettings;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.analysis.common;
|
|||
|
||||
import org.apache.lucene.analysis.Tokenizer;
|
||||
import org.apache.lucene.analysis.pattern.PatternTokenizer;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.opensearch.env.Environment;
|
||||
import org.elasticsearch.index.IndexSettings;
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
|
|
|
@ -19,8 +19,8 @@
|
|||
|
||||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.elasticsearch.common.time.DateFormatter;
|
||||
import org.elasticsearch.common.time.DateFormatters;
|
||||
import org.opensearch.common.time.DateFormatter;
|
||||
import org.opensearch.common.time.DateFormatters;
|
||||
|
||||
import java.time.Instant;
|
||||
import java.time.LocalDate;
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.elasticsearch.common.time.DateFormatter;
|
||||
import org.opensearch.common.time.DateFormatter;
|
||||
import org.elasticsearch.ingest.AbstractProcessor;
|
||||
import org.elasticsearch.ingest.ConfigurationUtils;
|
||||
import org.elasticsearch.ingest.IngestDocument;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.ingest.common;
|
|||
|
||||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.time.DateFormatter;
|
||||
import org.opensearch.common.time.DateFormatter;
|
||||
import org.elasticsearch.common.util.LocaleUtils;
|
||||
import org.elasticsearch.ingest.AbstractProcessor;
|
||||
import org.elasticsearch.ingest.ConfigurationUtils;
|
||||
|
|
|
@ -20,8 +20,8 @@
|
|||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.opensearch.OpenSearchException;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.ingest.IngestDocument;
|
||||
import org.elasticsearch.ingest.Processor;
|
||||
import org.elasticsearch.ingest.RandomDocumentPicks;
|
||||
|
|
|
@ -20,8 +20,8 @@
|
|||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.elasticsearch.bootstrap.JavaVersion;
|
||||
import org.elasticsearch.common.time.DateFormatter;
|
||||
import org.elasticsearch.common.time.DateUtils;
|
||||
import org.opensearch.common.time.DateFormatter;
|
||||
import org.opensearch.common.time.DateUtils;
|
||||
import org.elasticsearch.test.ESTestCase;
|
||||
|
||||
import java.time.ZoneId;
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.opensearch.ingest.common;
|
||||
|
||||
import org.elasticsearch.common.time.DateFormatter;
|
||||
import org.opensearch.common.time.DateFormatter;
|
||||
import org.elasticsearch.ingest.IngestDocument;
|
||||
import org.elasticsearch.ingest.TestTemplateService;
|
||||
import org.elasticsearch.test.ESTestCase;
|
||||
|
|
|
@ -31,8 +31,8 @@ import com.maxmind.geoip2.record.Location;
|
|||
import com.maxmind.geoip2.record.Subdivision;
|
||||
import org.opensearch.OpenSearchParseException;
|
||||
import org.elasticsearch.SpecialPermission;
|
||||
import org.elasticsearch.common.network.InetAddresses;
|
||||
import org.elasticsearch.common.network.NetworkAddress;
|
||||
import org.opensearch.common.network.InetAddresses;
|
||||
import org.opensearch.common.network.NetworkAddress;
|
||||
import org.elasticsearch.ingest.AbstractProcessor;
|
||||
import org.elasticsearch.ingest.IngestDocument;
|
||||
import org.elasticsearch.ingest.Processor;
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.opensearch.ingest.geoip;
|
||||
|
||||
import com.maxmind.geoip2.model.AbstractResponse;
|
||||
import org.elasticsearch.common.network.InetAddresses;
|
||||
import org.opensearch.common.network.InetAddresses;
|
||||
import org.opensearch.ingest.geoip.IngestGeoIpPlugin.GeoIpCache;
|
||||
import org.elasticsearch.test.ESTestCase;
|
||||
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.apache.lucene.search.TotalHits;
|
|||
import org.elasticsearch.action.search.SearchResponse;
|
||||
import org.elasticsearch.action.search.ShardSearchFailure;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -28,8 +28,8 @@ import org.apache.lucene.search.ScoreMode;
|
|||
import org.apache.lucene.search.Scorer;
|
||||
import org.apache.lucene.search.Weight;
|
||||
import org.apache.lucene.util.Bits;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.lucene.Lucene;
|
||||
import org.elasticsearch.common.util.BigArrays;
|
||||
import org.elasticsearch.common.util.BitArray;
|
||||
|
|
|
@ -27,7 +27,7 @@ import org.opensearch.common.bytes.BytesArray;
|
|||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.geo.GeoPoint;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.DistanceUnit;
|
||||
import org.opensearch.common.unit.DistanceUnit;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.apache.lucene.search.Query;
|
|||
import org.apache.lucene.search.QueryVisitor;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.document.DocumentField;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.search.SearchHit;
|
||||
import org.opensearch.search.fetch.FetchContext;
|
||||
import org.opensearch.search.fetch.FetchSubPhase;
|
||||
|
|
|
@ -114,7 +114,7 @@ import java.util.function.Function;
|
|||
import java.util.function.Supplier;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
import static org.elasticsearch.common.network.InetAddresses.forString;
|
||||
import static org.opensearch.common.network.InetAddresses.forString;
|
||||
import static org.hamcrest.Matchers.equalTo;
|
||||
import static org.hamcrest.Matchers.instanceOf;
|
||||
|
||||
|
|
|
@ -53,7 +53,7 @@ import org.opensearch.common.io.stream.InputStreamStreamInput;
|
|||
import org.opensearch.common.io.stream.NamedWriteableAwareStreamInput;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.opensearch.common.io.stream.StreamInput;
|
||||
import org.elasticsearch.common.network.InetAddresses;
|
||||
import org.opensearch.common.network.InetAddresses;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -60,7 +60,7 @@ import org.opensearch.Version;
|
|||
import org.elasticsearch.common.lucene.search.function.CombineFunction;
|
||||
import org.elasticsearch.common.lucene.search.function.FunctionScoreQuery;
|
||||
import org.elasticsearch.common.lucene.search.function.RandomScoreFunction;
|
||||
import org.elasticsearch.common.network.InetAddresses;
|
||||
import org.opensearch.common.network.InetAddresses;
|
||||
import org.elasticsearch.index.search.ESToParentBlockJoinQuery;
|
||||
import org.opensearch.percolator.QueryAnalyzer.QueryExtraction;
|
||||
import org.opensearch.percolator.QueryAnalyzer.Result;
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.opensearch.action.OriginalIndices;
|
|||
import org.opensearch.common.Strings;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.opensearch.index.rankeval;
|
|||
import org.opensearch.action.OriginalIndices;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.opensearch.index.rankeval;
|
|||
import org.opensearch.action.OriginalIndices;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.opensearch.index.rankeval;
|
|||
import org.opensearch.action.OriginalIndices;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -31,7 +31,7 @@ import org.opensearch.common.breaker.CircuitBreakingException;
|
|||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.BytesStreamOutput;
|
||||
import org.opensearch.common.io.stream.StreamInput;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.opensearch.index.rankeval;
|
|||
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentParser;
|
||||
import org.elasticsearch.common.xcontent.XContentType;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.opensearch.index.rankeval;
|
|||
import org.opensearch.action.OriginalIndices;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.xcontent.ToXContent;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
|
|
|
@ -37,7 +37,7 @@ import org.elasticsearch.action.index.IndexRequest;
|
|||
import org.opensearch.action.support.TransportAction;
|
||||
import org.opensearch.client.ParentTaskAssigningClient;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
|
||||
import org.elasticsearch.index.VersionType;
|
||||
|
|
|
@ -34,7 +34,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
|
|||
import org.opensearch.cluster.service.ClusterService;
|
||||
import org.opensearch.common.Strings;
|
||||
import org.elasticsearch.common.logging.DeprecationLogger;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.index.IndexNotFoundException;
|
||||
import org.elasticsearch.index.reindex.ReindexRequest;
|
||||
|
|
|
@ -60,7 +60,7 @@ import org.opensearch.cluster.node.DiscoveryNode;
|
|||
import org.elasticsearch.common.CheckedConsumer;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
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;
|
||||
|
|
|
@ -34,7 +34,7 @@ import org.opensearch.client.ParentTaskAssigningClient;
|
|||
import org.opensearch.client.support.AbstractClient;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.text.Text;
|
||||
import org.opensearch.common.text.Text;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
|
||||
import org.elasticsearch.index.reindex.ClientScrollableHitSource;
|
||||
|
|
|
@ -35,9 +35,9 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
|
|||
import org.opensearch.cluster.service.ClusterService;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.util.concurrent.ThreadContext;
|
||||
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
|
||||
import org.opensearch.env.Environment;
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.opensearch.action.bulk.Retry;
|
|||
import org.opensearch.client.Client;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
|
||||
import org.elasticsearch.http.HttpInfo;
|
||||
import org.elasticsearch.index.query.QueryBuilders;
|
||||
|
|
|
@ -47,8 +47,8 @@ import org.opensearch.common.ParsingException;
|
|||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.opensearch.common.io.FileSystemUtils;
|
||||
import org.opensearch.common.io.Streams;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
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;
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.opensearch.action.admin.cluster.snapshots.restore.RestoreSnapshotResp
|
|||
import org.opensearch.action.support.master.AcknowledgedResponse;
|
||||
import org.opensearch.client.Client;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.plugin.repository.url.URLRepositoryPlugin;
|
||||
import org.opensearch.plugins.Plugin;
|
||||
import org.opensearch.repositories.fs.FsRepository;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.opensearch.common.blobstore.BlobPath;
|
|||
import org.opensearch.common.blobstore.BlobStore;
|
||||
import org.opensearch.common.blobstore.BlobStoreException;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
|
||||
import java.net.MalformedURLException;
|
||||
import java.net.URL;
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
*/
|
||||
package org.opensearch;
|
||||
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.plugins.Plugin;
|
||||
import org.elasticsearch.test.ESIntegTestCase;
|
||||
|
|
|
@ -25,9 +25,9 @@ import io.netty.util.ReferenceCounted;
|
|||
import org.opensearch.OpenSearchNetty4IntegTestCase;
|
||||
import org.elasticsearch.common.collect.Tuple;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.http.HttpServerTransport;
|
||||
import org.elasticsearch.indices.breaker.HierarchyCircuitBreakerService;
|
||||
import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
|
||||
|
|
|
@ -22,7 +22,7 @@ package org.opensearch.http.netty4;
|
|||
import io.netty.handler.codec.http.FullHttpResponse;
|
||||
import io.netty.util.ReferenceCounted;
|
||||
import org.opensearch.OpenSearchNetty4IntegTestCase;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.http.HttpServerTransport;
|
||||
import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
|
||||
import org.elasticsearch.test.ESIntegTestCase.Scope;
|
||||
|
|
|
@ -24,11 +24,11 @@ import org.opensearch.action.admin.cluster.node.info.NodeInfo;
|
|||
import org.opensearch.action.admin.cluster.node.info.NodesInfoResponse;
|
||||
import org.opensearch.client.transport.TransportClient;
|
||||
import org.opensearch.cluster.health.ClusterHealthStatus;
|
||||
import org.elasticsearch.common.network.NetworkAddress;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkAddress;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.BoundTransportAddress;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.BoundTransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.env.Environment;
|
||||
import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
|
||||
import org.elasticsearch.test.ESIntegTestCase.Scope;
|
||||
|
|
|
@ -22,11 +22,11 @@ package org.opensearch.transport.netty4;
|
|||
import org.opensearch.OpenSearchNetty4IntegTestCase;
|
||||
import org.opensearch.action.admin.cluster.node.info.NodeInfo;
|
||||
import org.opensearch.action.admin.cluster.node.info.NodesInfoResponse;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.network.NetworkUtils;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkUtils;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.BoundTransportAddress;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.BoundTransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.test.ESIntegTestCase;
|
||||
import org.opensearch.transport.Netty4Plugin;
|
||||
import org.opensearch.transport.TransportInfo;
|
||||
|
|
|
@ -25,7 +25,7 @@ import org.opensearch.client.Response;
|
|||
import org.opensearch.client.ResponseException;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.http.HttpTransportSettings;
|
||||
import org.elasticsearch.test.rest.ESRestTestCase;
|
||||
import org.elasticsearch.test.rest.yaml.ObjectPath;
|
||||
|
|
|
@ -42,13 +42,13 @@ import io.netty.util.AttributeKey;
|
|||
import org.apache.logging.log4j.LogManager;
|
||||
import org.apache.logging.log4j.Logger;
|
||||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Setting.Property;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
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.elasticsearch.common.xcontent.NamedXContentRegistry;
|
||||
|
|
|
@ -39,7 +39,7 @@ import io.netty.channel.ChannelOutboundBuffer;
|
|||
import io.netty.channel.RecvByteBufAllocator;
|
||||
import io.netty.channel.socket.nio.NioSocketChannel;
|
||||
import org.elasticsearch.common.SuppressForbidden;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.ByteBuffer;
|
||||
|
|
|
@ -22,8 +22,8 @@ package org.opensearch.transport;
|
|||
import org.apache.lucene.util.SetOnce;
|
||||
import org.opensearch.Version;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
|
|
|
@ -30,7 +30,7 @@ import io.netty.channel.socket.nio.NioServerSocketChannel;
|
|||
import org.apache.logging.log4j.LogManager;
|
||||
import org.apache.logging.log4j.Logger;
|
||||
import org.elasticsearch.common.Booleans;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.monitor.jvm.JvmInfo;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
|
|
|
@ -29,7 +29,7 @@ import org.opensearch.OpenSearchException;
|
|||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.opensearch.common.bytes.BytesReference;
|
||||
import org.opensearch.common.bytes.ReleasableBytesReference;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.util.PageCacheRecycler;
|
||||
import org.opensearch.threadpool.ThreadPool;
|
||||
import org.opensearch.transport.InboundPipeline;
|
||||
|
|
|
@ -40,13 +40,13 @@ import org.opensearch.Version;
|
|||
import org.opensearch.cluster.node.DiscoveryNode;
|
||||
import org.elasticsearch.common.SuppressForbidden;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Setting.Property;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
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.elasticsearch.core.internal.net.NetUtils;
|
||||
|
|
|
@ -22,10 +22,10 @@ package org.opensearch.http.netty4;
|
|||
import io.netty.handler.codec.http.FullHttpResponse;
|
||||
import io.netty.util.ReferenceCounted;
|
||||
import org.opensearch.OpenSearchException;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
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;
|
||||
|
|
|
@ -43,8 +43,8 @@ import io.netty.handler.codec.http.HttpResponse;
|
|||
import io.netty.handler.codec.http.HttpResponseDecoder;
|
||||
import io.netty.handler.codec.http.HttpVersion;
|
||||
import org.elasticsearch.common.collect.Tuple;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.tasks.Task;
|
||||
import org.opensearch.transport.NettyAllocator;
|
||||
|
||||
|
|
|
@ -29,10 +29,10 @@ import io.netty.channel.SimpleChannelInboundHandler;
|
|||
import io.netty.handler.codec.http.FullHttpResponse;
|
||||
import io.netty.util.ReferenceCounted;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.util.MockBigArrays;
|
||||
import org.elasticsearch.common.util.MockPageCacheRecycler;
|
||||
import org.elasticsearch.http.HttpPipelinedRequest;
|
||||
|
|
|
@ -46,13 +46,13 @@ import io.netty.handler.codec.http.HttpVersion;
|
|||
import org.apache.logging.log4j.message.ParameterizedMessage;
|
||||
import org.opensearch.OpenSearchException;
|
||||
import org.opensearch.common.bytes.BytesArray;
|
||||
import org.elasticsearch.common.network.NetworkAddress;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkAddress;
|
||||
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.transport.TransportAddress;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.util.MockBigArrays;
|
||||
import org.elasticsearch.common.util.MockPageCacheRecycler;
|
||||
|
|
|
@ -21,9 +21,9 @@ package org.opensearch.transport.netty4;
|
|||
|
||||
import org.opensearch.Version;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.util.MockPageCacheRecycler;
|
||||
import org.elasticsearch.common.util.PageCacheRecycler;
|
||||
import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;
|
||||
|
|
|
@ -21,8 +21,8 @@ package org.opensearch.transport.netty4;
|
|||
import org.opensearch.Version;
|
||||
import org.opensearch.common.component.Lifecycle;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.network.NetworkUtils;
|
||||
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;
|
||||
|
|
|
@ -24,10 +24,10 @@ import org.opensearch.action.ActionListener;
|
|||
import org.elasticsearch.bootstrap.JavaVersion;
|
||||
import org.opensearch.cluster.node.DiscoveryNode;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.ClusterSettings;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.transport.TransportAddress;
|
||||
import org.opensearch.common.transport.TransportAddress;
|
||||
import org.elasticsearch.common.util.PageCacheRecycler;
|
||||
import org.elasticsearch.core.internal.io.IOUtils;
|
||||
import org.elasticsearch.core.internal.net.NetUtils;
|
||||
|
|
|
@ -33,7 +33,7 @@ import org.opensearch.cluster.service.ClusterService;
|
|||
import org.opensearch.common.Strings;
|
||||
import org.opensearch.common.inject.Inject;
|
||||
import org.opensearch.common.io.stream.Writeable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.opensearch.index.IndexService;
|
||||
import org.opensearch.index.engine.Engine;
|
||||
import org.opensearch.index.get.GetResult;
|
||||
|
|
|
@ -40,7 +40,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.lucene.uid.Versions;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.xcontent.XContentBuilder;
|
||||
import org.elasticsearch.common.xcontent.XContentFactory;
|
||||
import org.elasticsearch.common.xcontent.XContentHelper;
|
||||
|
|
|
@ -33,8 +33,8 @@ import org.opensearch.action.support.TransportActions;
|
|||
import org.opensearch.cluster.ClusterState;
|
||||
import org.elasticsearch.cluster.routing.GroupShardsIterator;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
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.elasticsearch.index.shard.ShardId;
|
||||
|
|
|
@ -23,7 +23,7 @@ import org.apache.lucene.util.FixedBitSet;
|
|||
import org.opensearch.action.ActionListener;
|
||||
import org.opensearch.cluster.ClusterState;
|
||||
import org.opensearch.cluster.routing.GroupShardsIterator;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.elasticsearch.search.SearchService.CanMatchResponse;
|
||||
import org.elasticsearch.search.SearchShardTarget;
|
||||
import org.opensearch.search.builder.SearchSourceBuilder;
|
||||
|
|
|
@ -26,8 +26,8 @@ import org.elasticsearch.action.search.SearchPhaseController.TopDocsStats;
|
|||
import org.opensearch.common.breaker.CircuitBreaker;
|
||||
import org.opensearch.common.breaker.CircuitBreakingException;
|
||||
import org.opensearch.common.io.stream.NamedWriteableRegistry;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
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.elasticsearch.search.SearchPhaseResult;
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.elasticsearch.action.search;
|
|||
import org.apache.logging.log4j.Logger;
|
||||
import org.opensearch.action.OriginalIndices;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.util.concurrent.AtomicArray;
|
||||
import org.elasticsearch.search.SearchPhaseResult;
|
||||
import org.elasticsearch.search.SearchShardTarget;
|
||||
|
|
|
@ -24,8 +24,8 @@ import org.apache.lucene.index.PostingsEnum;
|
|||
import org.apache.lucene.search.Query;
|
||||
import org.apache.lucene.util.BytesRef;
|
||||
import org.elasticsearch.common.Nullable;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.util.BigArrays;
|
||||
import org.elasticsearch.common.util.BytesRefHash;
|
||||
import org.elasticsearch.common.util.IntArray;
|
||||
|
|
|
@ -26,7 +26,7 @@ import org.apache.lucene.search.spell.LevenshteinDistance;
|
|||
import org.apache.lucene.util.CollectionUtil;
|
||||
import org.elasticsearch.ExceptionsHelper;
|
||||
import org.elasticsearch.common.collect.Tuple;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
|
|
|
@ -64,8 +64,8 @@ import org.opensearch.cluster.service.ClusterApplierService;
|
|||
import org.opensearch.cluster.service.ClusterService;
|
||||
import org.elasticsearch.cluster.service.MasterService;
|
||||
import org.elasticsearch.common.logging.Loggers;
|
||||
import org.elasticsearch.common.network.NetworkModule;
|
||||
import org.elasticsearch.common.network.NetworkService;
|
||||
import org.opensearch.common.network.NetworkModule;
|
||||
import org.opensearch.common.network.NetworkService;
|
||||
import org.elasticsearch.common.settings.Setting.Property;
|
||||
import org.elasticsearch.common.util.PageCacheRecycler;
|
||||
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
||||
|
|
|
@ -27,9 +27,9 @@ import org.elasticsearch.common.Booleans;
|
|||
import org.elasticsearch.common.Nullable;
|
||||
import org.opensearch.common.Strings;
|
||||
import org.elasticsearch.common.collect.Tuple;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.MemorySizeValue;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.MemorySizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.DeprecationHandler;
|
||||
import org.elasticsearch.common.xcontent.NamedXContentRegistry;
|
||||
|
|
|
@ -30,9 +30,9 @@ import org.opensearch.common.io.stream.StreamInput;
|
|||
import org.opensearch.common.io.stream.StreamOutput;
|
||||
import org.elasticsearch.common.logging.DeprecationLogger;
|
||||
import org.elasticsearch.common.logging.LogConfigurator;
|
||||
import org.elasticsearch.common.unit.ByteSizeUnit;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.unit.MemorySizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeUnit;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.MemorySizeValue;
|
||||
import org.elasticsearch.common.unit.TimeValue;
|
||||
import org.elasticsearch.common.xcontent.DeprecationHandler;
|
||||
import org.elasticsearch.common.xcontent.LoggingDeprecationHandler;
|
||||
|
@ -73,7 +73,7 @@ import java.util.function.UnaryOperator;
|
|||
import java.util.stream.Collectors;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import static org.elasticsearch.common.unit.ByteSizeValue.parseBytesSizeValue;
|
||||
import static org.opensearch.common.unit.ByteSizeValue.parseBytesSizeValue;
|
||||
import static org.elasticsearch.common.unit.TimeValue.parseTimeValue;
|
||||
|
||||
/**
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch.common.settings;
|
||||
|
||||
import org.opensearch.common.Strings;
|
||||
import org.elasticsearch.common.regex.Regex;
|
||||
import org.opensearch.common.regex.Regex;
|
||||
import org.elasticsearch.common.xcontent.ToXContent.Params;
|
||||
import org.opensearch.rest.RestRequest;
|
||||
|
||||
|
|
|
@ -21,8 +21,8 @@ package org.elasticsearch.common.util;
|
|||
|
||||
import org.apache.lucene.util.ArrayUtil;
|
||||
import org.apache.lucene.util.RamUsageEstimator;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.recycler.Recycler;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.opensearch.common.recycler.Recycler;
|
||||
|
||||
import java.lang.reflect.Array;
|
||||
import java.util.Arrays;
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
|
||||
/**
|
||||
* Base implementation for {@link BytesRefHash} and {@link LongHash}, or any class that
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch.common.util;
|
||||
|
||||
import com.carrotsearch.hppc.BitMixer;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
|
||||
/**
|
||||
* Base implementation for a hash table that is paged, recycles arrays and grows in-place.
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.apache.lucene.util.Accountable;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
|
||||
/** Base abstraction of an array. */
|
||||
public interface BigArray extends Releasable, Accountable {
|
||||
|
|
|
@ -25,9 +25,9 @@ import org.apache.lucene.util.RamUsageEstimator;
|
|||
import org.elasticsearch.common.Nullable;
|
||||
import org.opensearch.common.breaker.CircuitBreaker;
|
||||
import org.opensearch.common.breaker.CircuitBreakingException;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.elasticsearch.common.recycler.Recycler;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
import org.opensearch.common.recycler.Recycler;
|
||||
import org.elasticsearch.indices.breaker.CircuitBreakerService;
|
||||
|
||||
import java.util.Arrays;
|
||||
|
|
|
@ -19,8 +19,8 @@
|
|||
|
||||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
|
||||
/**
|
||||
* A bit array that is implemented using a growing {@link LongArray}
|
||||
|
|
|
@ -21,8 +21,8 @@ package org.elasticsearch.common.util;
|
|||
|
||||
import com.carrotsearch.hppc.BitMixer;
|
||||
import org.apache.lucene.util.BytesRef;
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
|
||||
/**
|
||||
* Specialized hash table implementation similar to Lucene's BytesRefHash that maps
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.apache.lucene.store.RateLimiter;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
|
||||
import java.util.concurrent.atomic.AtomicLong;
|
||||
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
|
||||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.elasticsearch.common.lease.Releasable;
|
||||
import org.opensearch.common.lease.Releasable;
|
||||
|
||||
/**
|
||||
* Specialized hash table implementation similar to BytesRefHash that maps
|
||||
|
|
|
@ -21,7 +21,7 @@ package org.elasticsearch.common.util;
|
|||
|
||||
import com.carrotsearch.hppc.BitMixer;
|
||||
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
|
||||
/**
|
||||
* Specialized hash table implementation similar to BytesRefHash that maps
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
package org.elasticsearch.common.util;
|
||||
|
||||
|
||||
import org.elasticsearch.common.lease.Releasables;
|
||||
import org.opensearch.common.lease.Releasables;
|
||||
|
||||
import java.util.Iterator;
|
||||
import java.util.NoSuchElementException;
|
||||
|
|
|
@ -20,21 +20,21 @@
|
|||
package org.elasticsearch.common.util;
|
||||
|
||||
import org.apache.lucene.util.RamUsageEstimator;
|
||||
import org.elasticsearch.common.recycler.AbstractRecyclerC;
|
||||
import org.elasticsearch.common.recycler.Recycler;
|
||||
import org.opensearch.common.recycler.AbstractRecyclerC;
|
||||
import org.opensearch.common.recycler.Recycler;
|
||||
import org.elasticsearch.common.settings.Setting;
|
||||
import org.elasticsearch.common.settings.Setting.Property;
|
||||
import org.elasticsearch.common.settings.Settings;
|
||||
import org.elasticsearch.common.unit.ByteSizeValue;
|
||||
import org.opensearch.common.unit.ByteSizeValue;
|
||||
import org.elasticsearch.common.util.concurrent.EsExecutors;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Locale;
|
||||
|
||||
import static org.elasticsearch.common.recycler.Recyclers.concurrent;
|
||||
import static org.elasticsearch.common.recycler.Recyclers.concurrentDeque;
|
||||
import static org.elasticsearch.common.recycler.Recyclers.dequeFactory;
|
||||
import static org.elasticsearch.common.recycler.Recyclers.none;
|
||||
import static org.opensearch.common.recycler.Recyclers.concurrent;
|
||||
import static org.opensearch.common.recycler.Recyclers.concurrentDeque;
|
||||
import static org.opensearch.common.recycler.Recyclers.dequeFactory;
|
||||
import static org.opensearch.common.recycler.Recyclers.none;
|
||||
|
||||
/** A recycler of fixed-size pages. */
|
||||
public class PageCacheRecycler {
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue