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

[Rename] server/src/main/java/org/opensearch/index/analysis, cache, codec and engine (#295) 

* Refactor server/src/main/java/org/opensearch/index/analysis, cache, codec & engine

Signed-off-by: Harold Wang <harowang@amazon.com>
This commit is contained in:
Harold Wang 2021-03-12 17:56:39 -08:00 committed by Nick Knize
parent fe2b5d6d39
commit 9f0547e47b
88 changed files with 509 additions and 509 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/main/java/org/opensearch/index/analysis/AbstractCharFilterFactory.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
public abstract class AbstractCharFilterFactory extends AbstractIndexComponent implements CharFilterFactory {

8
server/src/main/java/org/opensearch/index/analysis/AbstractIndexAnalyzerProvider.java
View File

@ -17,13 +17,13 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.util.Version;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
public abstract class AbstractIndexAnalyzerProvider<T extends Analyzer> extends AbstractIndexComponent implements AnalyzerProvider<T> {

8
server/src/main/java/org/opensearch/index/analysis/AbstractTokenFilterFactory.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.util.Version;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
public abstract class AbstractTokenFilterFactory extends AbstractIndexComponent implements TokenFilterFactory {

8
server/src/main/java/org/opensearch/index/analysis/AbstractTokenizerFactory.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.util.Version;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
public abstract class AbstractTokenizerFactory extends AbstractIndexComponent implements TokenizerFactory {
protected final Version version;

12
server/src/main/java/org/opensearch/index/analysis/Analysis.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.analysis.CharArraySet;
@ -56,10 +56,10 @@ import org.apache.lucene.analysis.sv.SwedishAnalyzer;
import org.apache.lucene.analysis.th.ThaiAnalyzer;
import org.apache.lucene.analysis.tr.TurkishAnalyzer;
import org.apache.lucene.util.Version;
import org.elasticsearch.common.Strings;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.opensearch.common.Strings;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import java.io.BufferedReader;
import java.io.IOException;
@ -92,7 +92,7 @@ public class Analysis {
return Lucene.parseVersion(sVersion, Version.LATEST, logger);
}
// resolve the analysis version based on the version the index was created with
return org.elasticsearch.Version.indexCreated(indexSettings).luceneVersion;
return org.opensearch.Version.indexCreated(indexSettings).luceneVersion;
}
public static CharArraySet parseStemExclusion(Settings settings, CharArraySet defaultStemExclusion) {

2
server/src/main/java/org/opensearch/index/analysis/AnalysisMode.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
/**
* Enum representing the mode in which token filters and analyzers are allowed to operate.

24
server/src/main/java/org/opensearch/index/analysis/AnalysisRegistry.java
View File

@ -16,23 +16,23 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.core.KeywordTokenizer;
import org.apache.lucene.analysis.core.WhitespaceTokenizer;
import org.elasticsearch.OpenSearchException;
import org.elasticsearch.Version;
import org.opensearch.OpenSearchException;
import org.opensearch.Version;
import org.opensearch.cluster.metadata.IndexMetadata;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.mapper.TextFieldMapper;
import org.elasticsearch.indices.analysis.AnalysisModule;
import org.elasticsearch.indices.analysis.AnalysisModule.AnalysisProvider;
import org.elasticsearch.indices.analysis.PreBuiltAnalyzers;
import org.opensearch.common.settings.Settings;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.mapper.TextFieldMapper;
import org.opensearch.indices.analysis.AnalysisModule;
import org.opensearch.indices.analysis.AnalysisModule.AnalysisProvider;
import org.opensearch.indices.analysis.PreBuiltAnalyzers;
import java.io.Closeable;
import java.io.IOException;
@ -639,7 +639,7 @@ public final class AnalysisRegistry implements Closeable {
}
// Some analysis components emit deprecation warnings or throw exceptions when used
// with the wrong version of elasticsearch. These exceptions and warnings are
// with the wrong version of opensearch. These exceptions and warnings are
// normally thrown when tokenstreams are constructed, which unless we build a
// tokenstream up-front does not happen until a document is indexed. In order to
// surface these warnings or exceptions as early as possible, we build an empty

4
server/src/main/java/org/opensearch/index/analysis/AnalyzerComponents.java
View File

@ -17,9 +17,9 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.common.settings.Settings;
import org.opensearch.common.settings.Settings;
import java.util.ArrayList;
import java.util.List;

2
server/src/main/java/org/opensearch/index/analysis/AnalyzerComponentsProvider.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
/**
* Analyzers that provide access to their token filters should implement this

4
server/src/main/java/org/opensearch/index/analysis/AnalyzerProvider.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.elasticsearch.common.inject.Provider;
import org.opensearch.common.inject.Provider;
public interface AnalyzerProvider<T extends Analyzer> extends Provider<T> {

2
server/src/main/java/org/opensearch/index/analysis/AnalyzerScope.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
public enum AnalyzerScope {
INDEX,

2
server/src/main/java/org/opensearch/index/analysis/CharFilterFactory.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import java.io.Reader;

4
server/src/main/java/org/opensearch/index/analysis/CustomAnalyzer.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.Tokenizer;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.util.CollectionUtils;
import java.io.Reader;

10
server/src/main/java/org/opensearch/index/analysis/CustomAnalyzerProvider.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.mapper.TextFieldMapper;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.mapper.TextFieldMapper;
import java.util.Map;
import static org.elasticsearch.index.analysis.AnalyzerComponents.createComponents;
import static org.opensearch.index.analysis.AnalyzerComponents.createComponents;
/**
* A custom analyzer that is built out of a single {@link org.apache.lucene.analysis.Tokenizer} and a list

6
server/src/main/java/org/opensearch/index/analysis/CustomNormalizerProvider.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.IndexSettings;
import java.util.ArrayList;
import java.util.List;

4
server/src/main/java/org/opensearch/index/analysis/FieldNameAnalyzer.java
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.DelegatingAnalyzerWrapper;
import org.elasticsearch.common.collect.CopyOnWriteHashMap;
import org.opensearch.common.collect.CopyOnWriteHashMap;
import java.util.Map;

8
server/src/main/java/org/opensearch/index/analysis/HunspellTokenFilterFactory.java
View File

@ -16,14 +16,14 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.hunspell.Dictionary;
import org.apache.lucene.analysis.hunspell.HunspellStemFilter;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.indices.analysis.HunspellService;
import org.opensearch.common.settings.Settings;
import org.opensearch.index.IndexSettings;
import org.opensearch.indices.analysis.HunspellService;
import java.util.Locale;

10
server/src/main/java/org/opensearch/index/analysis/IndexAnalyzers.java
View File

@ -16,9 +16,9 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.core.internal.io.IOUtils;
import org.opensearch.core.internal.io.IOUtils;
import java.io.Closeable;
import java.io.IOException;
@ -28,9 +28,9 @@ import java.util.stream.Collectors;
import java.util.stream.Stream;
import static java.util.Collections.unmodifiableMap;
import static org.elasticsearch.index.analysis.AnalysisRegistry.DEFAULT_ANALYZER_NAME;
import static org.elasticsearch.index.analysis.AnalysisRegistry.DEFAULT_SEARCH_ANALYZER_NAME;
import static org.elasticsearch.index.analysis.AnalysisRegistry.DEFAULT_SEARCH_QUOTED_ANALYZER_NAME;
import static org.opensearch.index.analysis.AnalysisRegistry.DEFAULT_ANALYZER_NAME;
import static org.opensearch.index.analysis.AnalysisRegistry.DEFAULT_SEARCH_ANALYZER_NAME;
import static org.opensearch.index.analysis.AnalysisRegistry.DEFAULT_SEARCH_QUOTED_ANALYZER_NAME;
/**
* IndexAnalyzers contains a name to analyzer mapping for a specific index.

10
server/src/main/java/org/opensearch/index/analysis/KeywordAnalyzerProvider.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.core.KeywordAnalyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class KeywordAnalyzerProvider extends AbstractIndexAnalyzerProvider<KeywordAnalyzer> {
@ -37,4 +37,4 @@ public class KeywordAnalyzerProvider extends AbstractIndexAnalyzerProvider<Keywo
public KeywordAnalyzer get() {
return this.keywordAnalyzer;
}
}
}

2
server/src/main/java/org/opensearch/index/analysis/LowercaseNormalizer.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.LowerCaseFilter;

10
server/src/main/java/org/opensearch/index/analysis/LowercaseNormalizerProvider.java
View File

@ -18,11 +18,11 @@
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
/**
@ -41,4 +41,4 @@ public class LowercaseNormalizerProvider extends AbstractIndexAnalyzerProvider<L
public LowercaseNormalizer get() {
return analyzer;
}
}
}

18
server/src/main/java/org/opensearch/index/analysis/NameOrDefinition.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentParseException;
import org.elasticsearch.common.xcontent.XContentParser;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.settings.Settings;
import org.opensearch.common.xcontent.ToXContentFragment;
import org.opensearch.common.xcontent.XContentBuilder;
import org.opensearch.common.xcontent.XContentParseException;
import org.opensearch.common.xcontent.XContentParser;
import java.io.IOException;
import java.util.Map;

8
server/src/main/java/org/opensearch/index/analysis/NamedAnalyzer.java
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.DelegatingAnalyzerWrapper;
import org.elasticsearch.index.mapper.MapperException;
import org.opensearch.index.mapper.MapperException;
import java.util.ArrayList;
import java.util.List;
@ -53,8 +53,8 @@ public class NamedAnalyzer extends DelegatingAnalyzerWrapper {
this.scope = scope;
this.analyzer = analyzer;
this.positionIncrementGap = positionIncrementGap;
if (analyzer instanceof org.elasticsearch.index.analysis.AnalyzerComponentsProvider) {
this.analysisMode = ((org.elasticsearch.index.analysis.AnalyzerComponentsProvider) analyzer).getComponents().analysisMode();
if (analyzer instanceof org.opensearch.index.analysis.AnalyzerComponentsProvider) {
this.analysisMode = ((org.opensearch.index.analysis.AnalyzerComponentsProvider) analyzer).getComponents().analysisMode();
} else {
this.analysisMode = AnalysisMode.ALL;
}

2
server/src/main/java/org/opensearch/index/analysis/NormalizingCharFilterFactory.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import java.io.Reader;

2
server/src/main/java/org/opensearch/index/analysis/NormalizingTokenFilterFactory.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.TokenStream;

2
server/src/main/java/org/opensearch/index/analysis/PreBuiltAnalyzerProvider.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;

16
server/src/main/java/org/opensearch/index/analysis/PreBuiltAnalyzerProviderFactory.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.elasticsearch.Version;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.indices.analysis.PreBuiltAnalyzers;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory;
import org.opensearch.Version;
import org.opensearch.common.settings.Settings;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
import org.opensearch.indices.analysis.PreBuiltAnalyzers;
import org.opensearch.indices.analysis.PreBuiltCacheFactory;
import java.io.Closeable;
import java.io.IOException;

14
server/src/main/java/org/opensearch/index/analysis/PreConfiguredAnalysisComponent.java
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.elasticsearch.Version;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.indices.analysis.AnalysisModule;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory;
import org.opensearch.Version;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
import org.opensearch.indices.analysis.AnalysisModule;
import org.opensearch.indices.analysis.PreBuiltCacheFactory;
import java.io.IOException;

20
server/src/main/java/org/opensearch/index/analysis/PreConfiguredCharFilter.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.CharFilter;
import org.apache.lucene.analysis.TokenFilter;
import org.elasticsearch.Version;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import org.opensearch.Version;
import org.opensearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import java.io.Reader;
import java.util.function.BiFunction;
@ -41,10 +41,10 @@ public class PreConfiguredCharFilter extends PreConfiguredAnalysisComponent<Char
}
/**
* Create a pre-configured char filter that may not vary at all, provide access to the elasticsearch version
* Create a pre-configured char filter that may not vary at all, provide access to the openearch version
*/
public static PreConfiguredCharFilter singletonWithVersion(String name, boolean useFilterForMultitermQueries,
BiFunction<Reader, org.elasticsearch.Version, Reader> create) {
BiFunction<Reader, org.opensearch.Version, Reader> create) {
return new PreConfiguredCharFilter(name, CachingStrategy.ONE, useFilterForMultitermQueries,
(reader, version) -> create.apply(reader, version));
}
@ -59,18 +59,18 @@ public class PreConfiguredCharFilter extends PreConfiguredAnalysisComponent<Char
}
/**
* Create a pre-configured token filter that may vary based on the Elasticsearch version.
* Create a pre-configured token filter that may vary based on the OpenSearch version.
*/
public static PreConfiguredCharFilter elasticsearchVersion(String name, boolean useFilterForMultitermQueries,
BiFunction<Reader, org.elasticsearch.Version, Reader> create) {
return new PreConfiguredCharFilter(name, CachingStrategy.ELASTICSEARCH, useFilterForMultitermQueries, create);
public static PreConfiguredCharFilter openSearchVersion(String name, boolean useFilterForMultitermQueries,
BiFunction<Reader, org.opensearch.Version, Reader> create) {
return new PreConfiguredCharFilter(name, CachingStrategy.OPENSEARCH, useFilterForMultitermQueries, create);
}
private final boolean useFilterForMultitermQueries;
private final BiFunction<Reader, Version, Reader> create;
protected PreConfiguredCharFilter(String name, CachingStrategy cache, boolean useFilterForMultitermQueries,
BiFunction<Reader, org.elasticsearch.Version, Reader> create) {
BiFunction<Reader, org.opensearch.Version, Reader> create) {
super(name, cache);
this.useFilterForMultitermQueries = useFilterForMultitermQueries;
this.create = create;

24
server/src/main/java/org/opensearch/index/analysis/PreConfiguredTokenFilter.java
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.TokenFilter;
import org.apache.lucene.analysis.TokenStream;
import org.elasticsearch.Version;
import org.elasticsearch.common.logging.DeprecationLogger;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import org.opensearch.Version;
import org.opensearch.common.logging.DeprecationLogger;
import org.opensearch.indices.analysis.PreBuiltCacheFactory;
import org.opensearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import java.util.function.BiFunction;
import java.util.function.Function;
@ -65,21 +65,21 @@ public final class PreConfiguredTokenFilter extends PreConfiguredAnalysisCompone
}
/**
* Create a pre-configured token filter that may vary based on the Elasticsearch version.
* Create a pre-configured token filter that may vary based on the OpenSearch version.
*/
public static PreConfiguredTokenFilter elasticsearchVersion(String name, boolean useFilterForMultitermQueries,
BiFunction<TokenStream, org.elasticsearch.Version, TokenStream> create) {
return new PreConfiguredTokenFilter(name, useFilterForMultitermQueries, true, CachingStrategy.ELASTICSEARCH, create);
public static PreConfiguredTokenFilter openSearchVersion(String name, boolean useFilterForMultitermQueries,
BiFunction<TokenStream, org.opensearch.Version, TokenStream> create) {
return new PreConfiguredTokenFilter(name, useFilterForMultitermQueries, true, CachingStrategy.OPENSEARCH, create);
}
/**
* Create a pre-configured token filter that may vary based on the Elasticsearch version.
* Create a pre-configured token filter that may vary based on the OpenSearch version.
*/
public static PreConfiguredTokenFilter elasticsearchVersion(String name, boolean useFilterForMultitermQueries,
public static PreConfiguredTokenFilter openSearchVersion(String name, boolean useFilterForMultitermQueries,
boolean useFilterForParsingSynonyms,
BiFunction<TokenStream, Version, TokenStream> create) {
return new PreConfiguredTokenFilter(name, useFilterForMultitermQueries, useFilterForParsingSynonyms,
CachingStrategy.ELASTICSEARCH, create);
CachingStrategy.OPENSEARCH, create);
}
private final boolean useFilterForMultitermQueries;

18
server/src/main/java/org/opensearch/index/analysis/PreConfiguredTokenizer.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Tokenizer;
import org.elasticsearch.Version;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory;
import org.elasticsearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import org.opensearch.Version;
import org.opensearch.indices.analysis.PreBuiltCacheFactory;
import org.opensearch.indices.analysis.PreBuiltCacheFactory.CachingStrategy;
import java.util.function.Function;
import java.util.function.Supplier;
@ -33,7 +33,7 @@ import java.util.function.Supplier;
public final class PreConfiguredTokenizer extends PreConfiguredAnalysisComponent<TokenizerFactory> {
/**
* Create a pre-configured tokenizer that may not vary at all.
*
*
* @param name the name of the tokenizer in the api
* @param create builds the tokenizer
*/
@ -52,17 +52,17 @@ public final class PreConfiguredTokenizer extends PreConfiguredAnalysisComponent
}
/**
* Create a pre-configured tokenizer that may vary based on the Elasticsearch version.
* Create a pre-configured tokenizer that may vary based on the OpenSearch version.
*
* @param name the name of the tokenizer in the api
* @param create builds the tokenizer
*/
public static PreConfiguredTokenizer elasticsearchVersion(String name, Function<org.elasticsearch.Version, Tokenizer> create) {
return new PreConfiguredTokenizer(name, CachingStrategy.ELASTICSEARCH, create);
public static PreConfiguredTokenizer openSearchVersion(String name, Function<org.opensearch.Version, Tokenizer> create) {
return new PreConfiguredTokenizer(name, CachingStrategy.OPENSEARCH, create);
}
private final Function<Version, Tokenizer> create;
private PreConfiguredTokenizer(String name, PreBuiltCacheFactory.CachingStrategy cache, Function<Version, Tokenizer> create) {
super(name, cache);
this.create = create;

6
server/src/main/java/org/opensearch/index/analysis/ReloadableCustomAnalyzer.java
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.Tokenizer;
import org.apache.lucene.util.CloseableThreadLocal;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.util.CollectionUtils;
import org.opensearch.common.settings.Settings;
import org.opensearch.common.util.CollectionUtils;
import java.io.Reader;
import java.util.Map;

12
server/src/main/java/org/opensearch/index/analysis/ShingleTokenFilterFactory.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.miscellaneous.DisableGraphAttribute;
import org.apache.lucene.analysis.shingle.ShingleFilter;
import org.elasticsearch.Version;
import org.elasticsearch.common.logging.DeprecationLogger;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.Version;
import org.opensearch.common.logging.DeprecationLogger;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class ShingleTokenFilterFactory extends AbstractTokenFilterFactory {

8
server/src/main/java/org/opensearch/index/analysis/SimpleAnalyzerProvider.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.core.SimpleAnalyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class SimpleAnalyzerProvider extends AbstractIndexAnalyzerProvider<SimpleAnalyzer> {

8
server/src/main/java/org/opensearch/index/analysis/StandardAnalyzerProvider.java
View File

@ -17,13 +17,13 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.CharArraySet;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class StandardAnalyzerProvider extends AbstractIndexAnalyzerProvider<StandardAnalyzer> {

8
server/src/main/java/org/opensearch/index/analysis/StandardTokenizerFactory.java
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Tokenizer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.analysis.standard.StandardTokenizer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class StandardTokenizerFactory extends AbstractTokenizerFactory {

8
server/src/main/java/org/opensearch/index/analysis/StopAnalyzerProvider.java
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.CharArraySet;
import org.apache.lucene.analysis.core.StopAnalyzer;
import org.apache.lucene.analysis.en.EnglishAnalyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class StopAnalyzerProvider extends AbstractIndexAnalyzerProvider<StopAnalyzer> {

8
server/src/main/java/org/opensearch/index/analysis/StopTokenFilterFactory.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.CharArraySet;
import org.apache.lucene.analysis.StopFilter;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.en.EnglishAnalyzer;
import org.apache.lucene.search.suggest.analyzing.SuggestStopFilter;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
import java.util.Set;

4
server/src/main/java/org/opensearch/index/analysis/TokenFilterFactory.java
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.TokenStream;
import org.apache.lucene.analysis.tokenattributes.OffsetAttribute;
import org.elasticsearch.search.fetch.subphase.highlight.FastVectorHighlighter;
import org.opensearch.search.fetch.subphase.highlight.FastVectorHighlighter;
import java.util.List;
import java.util.function.Function;

2
server/src/main/java/org/opensearch/index/analysis/TokenizerFactory.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.Tokenizer;

8
server/src/main/java/org/opensearch/index/analysis/WhitespaceAnalyzerProvider.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.analysis;
package org.opensearch.index.analysis;
import org.apache.lucene.analysis.core.WhitespaceAnalyzer;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.env.Environment;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.common.settings.Settings;
import org.opensearch.env.Environment;
import org.opensearch.index.IndexSettings;
public class WhitespaceAnalyzerProvider extends AbstractIndexAnalyzerProvider<WhitespaceAnalyzer> {

12
server/src/main/java/org/opensearch/index/cache/IndexCache.java vendored
View File

@ -17,13 +17,13 @@
* under the License.
*/
package org.elasticsearch.index.cache;
package org.opensearch.index.cache;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.cache.bitset.BitsetFilterCache;
import org.elasticsearch.index.cache.query.QueryCache;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.cache.bitset.BitsetFilterCache;
import org.opensearch.index.cache.query.QueryCache;
import java.io.Closeable;
import java.io.IOException;

46
server/src/main/java/org/opensearch/index/cache/bitset/BitsetFilterCache.java vendored
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.cache.bitset;
package org.opensearch.index.cache.bitset;
import org.apache.logging.log4j.message.ParameterizedMessage;
import org.apache.lucene.index.IndexReader;
@ -33,26 +33,26 @@ import org.apache.lucene.search.join.BitSetProducer;
import org.apache.lucene.util.Accountable;
import org.apache.lucene.util.BitDocIdSet;
import org.apache.lucene.util.BitSet;
import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.common.cache.Cache;
import org.elasticsearch.common.cache.CacheBuilder;
import org.elasticsearch.common.cache.RemovalListener;
import org.elasticsearch.common.cache.RemovalNotification;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.elasticsearch.common.lucene.search.Queries;
import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.IndexWarmer;
import org.elasticsearch.index.IndexWarmer.TerminationHandle;
import org.elasticsearch.index.mapper.DocumentMapper;
import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.index.mapper.ObjectMapper;
import org.elasticsearch.index.shard.IndexShard;
import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.index.shard.ShardUtils;
import org.opensearch.ExceptionsHelper;
import org.opensearch.common.cache.Cache;
import org.opensearch.common.cache.CacheBuilder;
import org.opensearch.common.cache.RemovalListener;
import org.opensearch.common.cache.RemovalNotification;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.common.lucene.search.Queries;
import org.opensearch.common.settings.Setting;
import org.opensearch.common.settings.Setting.Property;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.IndexWarmer;
import org.opensearch.index.IndexWarmer.TerminationHandle;
import org.opensearch.index.mapper.DocumentMapper;
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.mapper.ObjectMapper;
import org.opensearch.index.shard.IndexShard;
import org.opensearch.index.shard.ShardId;
import org.opensearch.index.shard.ShardUtils;
import org.opensearch.threadpool.ThreadPool;
import java.io.Closeable;
@ -69,7 +69,7 @@ import java.util.concurrent.Executor;
* <p>
* Use this cache with care, only components that require that a filter is to be materialized as a {@link BitDocIdSet}
* and require that it should always be around should use this cache, otherwise the
* {@link org.elasticsearch.index.cache.query.QueryCache} should be used instead.
* {@link org.opensearch.index.cache.query.QueryCache} should be used instead.
*/
public final class BitsetFilterCache extends AbstractIndexComponent
implements IndexReader.ClosedListener, RemovalListener<IndexReader.CacheKey, Cache<Query, BitsetFilterCache.Value>>, Closeable {
@ -188,7 +188,7 @@ public final class BitsetFilterCache extends AbstractIndexComponent
QueryWrapperBitSetProducer(Query query) {
this.query = Objects.requireNonNull(query);
}
// TODO: convertToElastic might need to be renamed
@Override
public BitSet getBitSet(LeafReaderContext context) throws IOException {
try {

10
server/src/main/java/org/opensearch/index/cache/bitset/ShardBitsetFilterCache.java vendored
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.cache.bitset;
package org.opensearch.index.cache.bitset;
import org.elasticsearch.common.metrics.CounterMetric;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.shard.AbstractIndexShardComponent;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.metrics.CounterMetric;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.shard.AbstractIndexShardComponent;
import org.opensearch.index.shard.ShardId;
public class ShardBitsetFilterCache extends AbstractIndexShardComponent {

6
server/src/main/java/org/opensearch/index/cache/query/DisabledQueryCache.java vendored
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.cache.query;
package org.opensearch.index.cache.query;
import org.apache.lucene.search.QueryCachingPolicy;
import org.apache.lucene.search.Weight;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
public class DisabledQueryCache extends AbstractIndexComponent implements QueryCache {

10
server/src/main/java/org/opensearch/index/cache/query/IndexQueryCache.java vendored
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.cache.query;
package org.opensearch.index.cache.query;
import org.apache.lucene.search.QueryCachingPolicy;
import org.apache.lucene.search.Weight;
import org.elasticsearch.OpenSearchException;
import org.elasticsearch.index.AbstractIndexComponent;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.indices.IndicesQueryCache;
import org.opensearch.OpenSearchException;
import org.opensearch.index.AbstractIndexComponent;
import org.opensearch.index.IndexSettings;
import org.opensearch.indices.IndicesQueryCache;
/**
* The index-level query cache. This class mostly delegates to the node-level

4
server/src/main/java/org/opensearch/index/cache/query/QueryCache.java vendored
View File

@ -17,9 +17,9 @@
* under the License.
*/
package org.elasticsearch.index.cache.query;
package org.opensearch.index.cache.query;
import org.elasticsearch.index.IndexComponent;
import org.opensearch.index.IndexComponent;
import java.io.Closeable;

16
server/src/main/java/org/opensearch/index/cache/query/QueryCacheStats.java vendored
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.cache.query;
package org.opensearch.index.cache.query;
import org.apache.lucene.search.DocIdSet;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.xcontent.ToXContent;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.xcontent.ToXContent;
import org.opensearch.common.xcontent.ToXContentFragment;
import org.opensearch.common.xcontent.XContentBuilder;
import java.io.IOException;

14
server/src/main/java/org/opensearch/index/cache/request/RequestCacheStats.java vendored
View File

@ -17,14 +17,14 @@
* under the License.
*/
package org.elasticsearch.index.cache.request;
package org.opensearch.index.cache.request;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.xcontent.ToXContentFragment;
import org.opensearch.common.xcontent.XContentBuilder;
import java.io.IOException;

6
server/src/main/java/org/opensearch/index/cache/request/ShardRequestCache.java vendored
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.cache.request;
package org.opensearch.index.cache.request;
import org.apache.lucene.util.Accountable;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.metrics.CounterMetric;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.metrics.CounterMetric;
/**
* Tracks the portion of the request cache in use for a particular shard.

10
server/src/main/java/org/opensearch/index/codec/CodecService.java
View File

@ -17,22 +17,22 @@
* under the License.
*/
package org.elasticsearch.index.codec;
package org.opensearch.index.codec;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.codecs.Codec;
import org.apache.lucene.codecs.lucene87.Lucene87Codec;
import org.apache.lucene.codecs.lucene87.Lucene87StoredFieldsFormat.Mode;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.collect.MapBuilder;
import org.elasticsearch.index.mapper.MapperService;
import org.opensearch.common.Nullable;
import org.opensearch.common.collect.MapBuilder;
import org.opensearch.index.mapper.MapperService;
import java.util.Map;
/**
* Since Lucene 4.0 low level index segments are read and written through a
* codec layer that allows to use use-case specific file formats &amp;
* data-structures per field. Elasticsearch exposes the full
* data-structures per field. OpenSearch exposes the full
* {@link Codec} capabilities through this {@link CodecService}.
*/
public class CodecService {

12
server/src/main/java/org/opensearch/index/codec/PerFieldMappingPostingFormatCodec.java
View File

@ -17,21 +17,21 @@
* under the License.
*/
package org.elasticsearch.index.codec;
package org.opensearch.index.codec;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.codecs.Codec;
import org.apache.lucene.codecs.PostingsFormat;
import org.apache.lucene.codecs.lucene87.Lucene87StoredFieldsFormat;
import org.apache.lucene.codecs.lucene87.Lucene87Codec;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.index.mapper.CompletionFieldMapper;
import org.elasticsearch.index.mapper.MappedFieldType;
import org.elasticsearch.index.mapper.MapperService;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.index.mapper.CompletionFieldMapper;
import org.opensearch.index.mapper.MappedFieldType;
import org.opensearch.index.mapper.MapperService;
/**
* {@link PerFieldMappingPostingFormatCodec This postings format} is the default
* {@link PostingsFormat} for Elasticsearch. It utilizes the
* {@link PostingsFormat} for OpenSearch. It utilizes the
* {@link MapperService} to lookup a {@link PostingsFormat} per field. This
* allows users to change the low level postings format for individual fields
* per index in real time via the mapping API. If no specific postings format is

8
server/src/main/java/org/opensearch/index/engine/CombinedDeletionPolicy.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import com.carrotsearch.hppc.ObjectIntHashMap;
import org.apache.logging.log4j.Logger;
@ -25,9 +25,9 @@ import org.apache.lucene.index.IndexCommit;
import org.apache.lucene.index.IndexDeletionPolicy;
import org.apache.lucene.index.SegmentInfos;
import org.apache.lucene.store.Directory;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.index.translog.TranslogDeletionPolicy;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.translog.Translog;
import org.opensearch.index.translog.TranslogDeletionPolicy;
import java.io.IOException;
import java.nio.file.Path;

8
server/src/main/java/org/opensearch/index/engine/CombinedDocValues.java
View File

@ -17,13 +17,13 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.LeafReader;
import org.apache.lucene.index.NumericDocValues;
import org.elasticsearch.index.mapper.SeqNoFieldMapper;
import org.elasticsearch.index.mapper.SourceFieldMapper;
import org.elasticsearch.index.mapper.VersionFieldMapper;
import org.opensearch.index.mapper.SeqNoFieldMapper;
import org.opensearch.index.mapper.SourceFieldMapper;
import org.opensearch.index.mapper.VersionFieldMapper;
import java.io.IOException;
import java.util.Objects;

16
server/src/main/java/org/opensearch/index/engine/CommitStats.java
View File

@ -16,16 +16,16 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.SegmentInfos;
import org.elasticsearch.common.collect.MapBuilder;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.common.collect.MapBuilder;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.xcontent.ToXContentFragment;
import org.opensearch.common.xcontent.XContentBuilder;
import java.io.IOException;
import java.util.Base64;

12
server/src/main/java/org/opensearch/index/engine/CompletionStatsCache.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import com.carrotsearch.hppc.ObjectLongHashMap;
import com.carrotsearch.hppc.cursors.ObjectLongCursor;
@ -28,11 +28,11 @@ import org.apache.lucene.search.ReferenceManager;
import org.apache.lucene.search.suggest.document.CompletionTerms;
import org.opensearch.action.ActionListener;
import org.opensearch.action.support.PlainActionFuture;
import org.elasticsearch.common.FieldMemoryStats;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.regex.Regex;
import org.elasticsearch.common.util.CollectionUtils;
import org.elasticsearch.search.suggest.completion.CompletionStats;
import org.opensearch.common.FieldMemoryStats;
import org.opensearch.common.Nullable;
import org.opensearch.common.regex.Regex;
import org.opensearch.common.util.CollectionUtils;
import org.opensearch.search.suggest.completion.CompletionStats;
import java.util.function.Supplier;

2
server/src/main/java/org/opensearch/index/engine/DeleteVersionValue.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.util.RamUsageEstimator;

6
server/src/main/java/org/opensearch/index/engine/DocumentMissingException.java
View File

@ -16,10 +16,10 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import org.opensearch.rest.RestStatus;
import java.io.IOException;

6
server/src/main/java/org/opensearch/index/engine/DocumentSourceMissingException.java
View File

@ -16,10 +16,10 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import org.opensearch.rest.RestStatus;
import java.io.IOException;

80
server/src/main/java/org/opensearch/index/engine/Engine.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage;
@ -41,41 +41,41 @@ import org.apache.lucene.store.IOContext;
import org.apache.lucene.util.Accountable;
import org.apache.lucene.util.Accountables;
import org.apache.lucene.util.SetOnce;
import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.common.CheckedRunnable;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.collect.ImmutableOpenMap;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.lease.Releasable;
import org.elasticsearch.common.lease.Releasables;
import org.elasticsearch.common.logging.Loggers;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.elasticsearch.common.lucene.uid.Versions;
import org.elasticsearch.common.lucene.uid.VersionsAndSeqNoResolver;
import org.elasticsearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndVersion;
import org.elasticsearch.common.metrics.CounterMetric;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.ReleasableLock;
import org.elasticsearch.index.VersionType;
import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.index.mapper.Mapping;
import org.elasticsearch.index.mapper.ParseContext.Document;
import org.elasticsearch.index.mapper.ParsedDocument;
import org.elasticsearch.index.merge.MergeStats;
import org.elasticsearch.index.seqno.SeqNoStats;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.DocsStats;
import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.index.store.Store;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.index.translog.TranslogStats;
import org.elasticsearch.search.suggest.completion.CompletionStats;
import org.opensearch.ExceptionsHelper;
import org.opensearch.action.index.IndexRequest;
import org.opensearch.common.CheckedRunnable;
import org.opensearch.common.Nullable;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.collect.ImmutableOpenMap;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.lease.Releasables;
import org.opensearch.common.logging.Loggers;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.common.lucene.uid.Versions;
import org.opensearch.common.lucene.uid.VersionsAndSeqNoResolver;
import org.opensearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndVersion;
import org.opensearch.common.metrics.CounterMetric;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.common.util.concurrent.ReleasableLock;
import org.opensearch.index.VersionType;
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.mapper.Mapping;
import org.opensearch.index.mapper.ParseContext.Document;
import org.opensearch.index.mapper.ParsedDocument;
import org.opensearch.index.merge.MergeStats;
import org.opensearch.index.seqno.SeqNoStats;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.shard.DocsStats;
import org.opensearch.index.shard.ShardId;
import org.opensearch.index.store.Store;
import org.opensearch.index.translog.Translog;
import org.opensearch.index.translog.TranslogStats;
import org.opensearch.search.suggest.completion.CompletionStats;
import java.io.Closeable;
import java.io.FileNotFoundException;
@ -103,8 +103,8 @@ import java.util.function.BiFunction;
import java.util.function.Function;
import java.util.stream.Stream;
import static org.elasticsearch.index.seqno.SequenceNumbers.UNASSIGNED_PRIMARY_TERM;
import static org.elasticsearch.index.seqno.SequenceNumbers.UNASSIGNED_SEQ_NO;
import static org.opensearch.index.seqno.SequenceNumbers.UNASSIGNED_PRIMARY_TERM;
import static org.opensearch.index.seqno.SequenceNumbers.UNASSIGNED_SEQ_NO;
public abstract class Engine implements Closeable {
@ -1076,7 +1076,7 @@ public abstract class Engine implements Closeable {
/**
* checks and removes translog files that no longer need to be retained. See
* {@link org.elasticsearch.index.translog.TranslogDeletionPolicy} for details
* {@link org.opensearch.index.translog.TranslogDeletionPolicy} for details
*/
public abstract void trimUnreferencedTranslogFiles() throws EngineException;
@ -1448,7 +1448,7 @@ public abstract class Engine implements Closeable {
}
/**
* Returns a positive timestamp if the ID of this document is auto-generated by elasticsearch.
* Returns a positive timestamp if the ID of this document is auto-generated by opensearch.
* if this property is non-negative indexing code might optimize the addition of this document
* due to it's append only nature.
*/

38
server/src/main/java/org/opensearch/index/engine/EngineConfig.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.codecs.Codec;
@ -26,21 +26,21 @@ import org.apache.lucene.search.QueryCachingPolicy;
import org.apache.lucene.search.ReferenceManager;
import org.apache.lucene.search.Sort;
import org.apache.lucene.search.similarities.Similarity;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.MemorySizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.codec.CodecService;
import org.elasticsearch.index.mapper.ParsedDocument;
import org.elasticsearch.index.seqno.RetentionLeases;
import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.index.store.Store;
import org.elasticsearch.index.translog.TranslogConfig;
import org.elasticsearch.indices.IndexingMemoryController;
import org.elasticsearch.indices.breaker.CircuitBreakerService;
import org.opensearch.common.Nullable;
import org.opensearch.common.settings.Setting;
import org.opensearch.common.settings.Setting.Property;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.unit.MemorySizeValue;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.codec.CodecService;
import org.opensearch.index.mapper.ParsedDocument;
import org.opensearch.index.seqno.RetentionLeases;
import org.opensearch.index.shard.ShardId;
import org.opensearch.index.store.Store;
import org.opensearch.index.translog.TranslogConfig;
import org.opensearch.indices.IndexingMemoryController;
import org.opensearch.indices.breaker.CircuitBreakerService;
import org.opensearch.threadpool.ThreadPool;
import java.util.List;
@ -128,7 +128,7 @@ public final class EngineConfig {
private final TranslogConfig translogConfig;
/**
* Creates a new {@link org.elasticsearch.index.engine.EngineConfig}
* Creates a new {@link org.opensearch.index.engine.EngineConfig}
*/
public EngineConfig(ShardId shardId, ThreadPool threadPool,
IndexSettings indexSettings, Engine.Warmer warmer, Store store,
@ -232,14 +232,14 @@ public final class EngineConfig {
}
/**
* Returns an {@link org.elasticsearch.index.engine.Engine.Warmer} used to warm new searchers before they are used for searching.
* Returns an {@link org.opensearch.index.engine.Engine.Warmer} used to warm new searchers before they are used for searching.
*/
public Engine.Warmer getWarmer() {
return warmer;
}
/**
* Returns the {@link org.elasticsearch.index.store.Store} instance that provides access to the
* Returns the {@link org.opensearch.index.store.Store} instance that provides access to the
* {@link org.apache.lucene.store.Directory} used for the engines {@link org.apache.lucene.index.IndexWriter} to write it's index files
* to.
* <p>

8
server/src/main/java/org/opensearch/index/engine/EngineCreationFailureException.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;
@ -39,4 +39,4 @@ public class EngineCreationFailureException extends EngineException {
super(in);
}
}
}

8
server/src/main/java/org/opensearch/index/engine/EngineException.java
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.OpenSearchException;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.OpenSearchException;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;

2
server/src/main/java/org/opensearch/index/engine/EngineFactory.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
/**
* Simple Engine Factory

8
server/src/main/java/org/opensearch/index/engine/FlushFailedEngineException.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;
@ -33,4 +33,4 @@ public class FlushFailedEngineException extends EngineException {
public FlushFailedEngineException(StreamInput in) throws IOException{
super(in);
}
}
}

4
server/src/main/java/org/opensearch/index/engine/IndexVersionValue.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.util.RamUsageEstimator;
import org.elasticsearch.index.translog.Translog;
import org.opensearch.index.translog.Translog;
import java.util.Objects;

90
server/src/main/java/org/opensearch/index/engine/InternalEngine.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.message.ParameterizedMessage;
@ -52,50 +52,50 @@ import org.apache.lucene.store.Directory;
import org.apache.lucene.store.LockObtainFailedException;
import org.apache.lucene.util.BytesRef;
import org.apache.lucene.util.InfoStream;
import org.elasticsearch.Assertions;
import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.common.Booleans;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.SuppressForbidden;
import org.elasticsearch.common.lease.Releasable;
import org.elasticsearch.common.lucene.LoggerInfoStream;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.elasticsearch.common.lucene.uid.Versions;
import org.elasticsearch.common.lucene.uid.VersionsAndSeqNoResolver;
import org.elasticsearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndSeqNo;
import org.elasticsearch.common.metrics.CounterMetric;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.AbstractRunnable;
import org.elasticsearch.common.util.concurrent.KeyedLock;
import org.elasticsearch.common.util.concurrent.ReleasableLock;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.VersionType;
import org.elasticsearch.index.fieldvisitor.IdOnlyFieldVisitor;
import org.elasticsearch.index.mapper.IdFieldMapper;
import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.index.mapper.ParseContext;
import org.elasticsearch.index.mapper.ParsedDocument;
import org.elasticsearch.index.mapper.SeqNoFieldMapper;
import org.elasticsearch.index.mapper.SourceFieldMapper;
import org.elasticsearch.index.mapper.Uid;
import org.elasticsearch.index.merge.MergeStats;
import org.elasticsearch.index.merge.OnGoingMerge;
import org.elasticsearch.index.seqno.LocalCheckpointTracker;
import org.elasticsearch.index.seqno.SeqNoStats;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.OpenSearchMergePolicy;
import org.elasticsearch.index.shard.ShardId;
import org.elasticsearch.index.store.Store;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.index.translog.TranslogConfig;
import org.elasticsearch.index.translog.TranslogCorruptedException;
import org.elasticsearch.index.translog.TranslogDeletionPolicy;
import org.elasticsearch.index.translog.TranslogStats;
import org.elasticsearch.search.suggest.completion.CompletionStats;
import org.opensearch.Assertions;
import org.opensearch.ExceptionsHelper;
import org.opensearch.action.index.IndexRequest;
import org.opensearch.common.Booleans;
import org.opensearch.common.Nullable;
import org.opensearch.common.SuppressForbidden;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.lucene.LoggerInfoStream;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.common.lucene.uid.Versions;
import org.opensearch.common.lucene.uid.VersionsAndSeqNoResolver;
import org.opensearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndSeqNo;
import org.opensearch.common.metrics.CounterMetric;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.common.util.concurrent.AbstractRunnable;
import org.opensearch.common.util.concurrent.KeyedLock;
import org.opensearch.common.util.concurrent.ReleasableLock;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.VersionType;
import org.opensearch.index.fieldvisitor.IdOnlyFieldVisitor;
import org.opensearch.index.mapper.IdFieldMapper;
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.mapper.ParseContext;
import org.opensearch.index.mapper.ParsedDocument;
import org.opensearch.index.mapper.SeqNoFieldMapper;
import org.opensearch.index.mapper.SourceFieldMapper;
import org.opensearch.index.mapper.Uid;
import org.opensearch.index.merge.MergeStats;
import org.opensearch.index.merge.OnGoingMerge;
import org.opensearch.index.seqno.LocalCheckpointTracker;
import org.opensearch.index.seqno.SeqNoStats;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.shard.OpenSearchMergePolicy;
import org.opensearch.index.shard.ShardId;
import org.opensearch.index.store.Store;
import org.opensearch.index.translog.Translog;
import org.opensearch.index.translog.TranslogConfig;
import org.opensearch.index.translog.TranslogCorruptedException;
import org.opensearch.index.translog.TranslogDeletionPolicy;
import org.opensearch.index.translog.TranslogStats;
import org.opensearch.search.suggest.completion.CompletionStats;
import org.opensearch.threadpool.ThreadPool;
import java.io.Closeable;

2
server/src/main/java/org/opensearch/index/engine/InternalEngineFactory.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
public class InternalEngineFactory implements EngineFactory {
@Override

8
server/src/main/java/org/opensearch/index/engine/LiveVersionMap.java
View File

@ -17,15 +17,15 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.search.ReferenceManager;
import org.apache.lucene.util.Accountable;
import org.apache.lucene.util.BytesRef;
import org.apache.lucene.util.RamUsageEstimator;
import org.elasticsearch.common.lease.Releasable;
import org.elasticsearch.common.util.concurrent.ConcurrentCollections;
import org.elasticsearch.common.util.concurrent.KeyedLock;
import org.opensearch.common.lease.Releasable;
import org.opensearch.common.util.concurrent.ConcurrentCollections;
import org.opensearch.common.util.concurrent.KeyedLock;
import java.io.IOException;
import java.util.Collection;

22
server/src/main/java/org/opensearch/index/engine/LuceneChangesSnapshot.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.document.LongPoint;
import org.apache.lucene.index.LeafReader;
@ -34,16 +34,16 @@ import org.apache.lucene.search.Sort;
import org.apache.lucene.search.SortField;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.util.ArrayUtil;
import org.elasticsearch.common.bytes.BytesReference;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.index.fieldvisitor.FieldsVisitor;
import org.elasticsearch.index.mapper.IdFieldMapper;
import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.index.mapper.SeqNoFieldMapper;
import org.elasticsearch.index.mapper.SourceFieldMapper;
import org.elasticsearch.index.mapper.Uid;
import org.elasticsearch.index.translog.Translog;
import org.opensearch.common.bytes.BytesReference;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.index.fieldvisitor.FieldsVisitor;
import org.opensearch.index.mapper.IdFieldMapper;
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.mapper.SeqNoFieldMapper;
import org.opensearch.index.mapper.SourceFieldMapper;
import org.opensearch.index.mapper.Uid;
import org.opensearch.index.translog.Translog;
import java.io.Closeable;
import java.io.IOException;

2
server/src/main/java/org/opensearch/index/engine/MissingHistoryOperationsException.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
/**
* Exception indicating that not all requested operations from {@link LuceneChangesSnapshot}

18
server/src/main/java/org/opensearch/index/engine/NoOpEngine.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexCommit;
@ -26,14 +26,14 @@ import org.apache.lucene.index.LeafReader;
import org.apache.lucene.index.LeafReaderContext;
import org.apache.lucene.index.SegmentReader;
import org.apache.lucene.store.Directory;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.util.concurrent.ReleasableLock;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.DocsStats;
import org.elasticsearch.index.store.Store;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.index.translog.TranslogConfig;
import org.elasticsearch.index.translog.TranslogDeletionPolicy;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.util.concurrent.ReleasableLock;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.shard.DocsStats;
import org.opensearch.index.store.Store;
import org.opensearch.index.translog.Translog;
import org.opensearch.index.translog.TranslogConfig;
import org.opensearch.index.translog.TranslogDeletionPolicy;
import java.io.IOException;
import java.io.UncheckedIOException;

28
server/src/main/java/org/opensearch/index/engine/OpenSearchConcurrentMergeScheduler.java
View File

@ -17,26 +17,26 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.logging.log4j.Logger;
import org.apache.lucene.index.ConcurrentMergeScheduler;
import org.apache.lucene.index.MergePolicy;
import org.apache.lucene.index.MergeScheduler;
import org.apache.lucene.index.OneMergeHelper;
import org.elasticsearch.common.logging.Loggers;
import org.elasticsearch.common.metrics.CounterMetric;
import org.elasticsearch.common.metrics.MeanMetric;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.ConcurrentCollections;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.index.IndexSettings;
import org.elasticsearch.index.MergeSchedulerConfig;
import org.elasticsearch.index.merge.MergeStats;
import org.elasticsearch.index.merge.OnGoingMerge;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.logging.Loggers;
import org.opensearch.common.metrics.CounterMetric;
import org.opensearch.common.metrics.MeanMetric;
import org.opensearch.common.settings.Settings;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.unit.TimeValue;
import org.opensearch.common.util.concurrent.ConcurrentCollections;
import org.opensearch.common.util.concurrent.EsExecutors;
import org.opensearch.index.IndexSettings;
import org.opensearch.index.MergeSchedulerConfig;
import org.opensearch.index.merge.MergeStats;
import org.opensearch.index.merge.OnGoingMerge;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;
import java.util.Collections;

6
server/src/main/java/org/opensearch/index/engine/OpenSearchReaderManager.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import java.io.IOException;
import java.util.function.BiConsumer;
@ -26,8 +26,8 @@ import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.search.ReferenceManager;
import org.apache.lucene.search.SearcherManager;
import org.elasticsearch.common.SuppressForbidden;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.common.SuppressForbidden;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
/**
* Utility class to safely share {@link OpenSearchDirectoryReader} instances across

2
server/src/main/java/org/opensearch/index/engine/PrunePostingsMergePolicy.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.codecs.FieldsProducer;
import org.apache.lucene.index.CodecReader;

10
server/src/main/java/org/opensearch/index/engine/RamAccountingRefreshListener.java
View File

@ -17,15 +17,15 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.index.LeafReaderContext;
import org.apache.lucene.index.SegmentReader;
import org.elasticsearch.common.breaker.CircuitBreaker;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.elasticsearch.indices.breaker.CircuitBreakerService;
import org.opensearch.common.breaker.CircuitBreaker;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.indices.breaker.CircuitBreakerService;
import java.util.Collections;
import java.util.HashSet;

32
server/src/main/java/org/opensearch/index/engine/ReadOnlyEngine.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.DirectoryReader;
import org.apache.lucene.index.IndexCommit;
@ -26,21 +26,21 @@ import org.apache.lucene.index.SoftDeletesDirectoryReaderWrapper;
import org.apache.lucene.search.ReferenceManager;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.Lock;
import org.elasticsearch.Version;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.lucene.index.OpenSearchDirectoryReader;
import org.elasticsearch.common.util.concurrent.ReleasableLock;
import org.elasticsearch.core.internal.io.IOUtils;
import org.elasticsearch.index.mapper.MapperService;
import org.elasticsearch.index.seqno.SeqNoStats;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.store.Store;
import org.elasticsearch.index.translog.Translog;
import org.elasticsearch.index.translog.TranslogConfig;
import org.elasticsearch.index.translog.TranslogDeletionPolicy;
import org.elasticsearch.index.translog.TranslogStats;
import org.elasticsearch.search.suggest.completion.CompletionStats;
import org.elasticsearch.transport.Transports;
import org.opensearch.Version;
import org.opensearch.common.lucene.Lucene;
import org.opensearch.common.lucene.index.OpenSearchDirectoryReader;
import org.opensearch.common.util.concurrent.ReleasableLock;
import org.opensearch.core.internal.io.IOUtils;
import org.opensearch.index.mapper.MapperService;
import org.opensearch.index.seqno.SeqNoStats;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.store.Store;
import org.opensearch.index.translog.Translog;
import org.opensearch.index.translog.TranslogConfig;
import org.opensearch.index.translog.TranslogDeletionPolicy;
import org.opensearch.index.translog.TranslogStats;
import org.opensearch.search.suggest.completion.CompletionStats;
import org.opensearch.transport.Transports;
import java.io.Closeable;
import java.io.IOException;

10
server/src/main/java/org/opensearch/index/engine/RecoveryEngineException.java
View File

@ -17,11 +17,11 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;
@ -48,4 +48,4 @@ public class RecoveryEngineException extends EngineException {
public int phase() {
return phase;
}
}
}

2
server/src/main/java/org/opensearch/index/engine/RecoverySourcePruneMergePolicy.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.codecs.DocValuesProducer;
import org.apache.lucene.codecs.StoredFieldsReader;

8
server/src/main/java/org/opensearch/index/engine/RefreshFailedEngineException.java
View File

@ -17,10 +17,10 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.shard.ShardId;
import java.io.IOException;
@ -33,4 +33,4 @@ public class RefreshFailedEngineException extends EngineException {
public RefreshFailedEngineException(StreamInput in) throws IOException{
super(in);
}
}
}

4
server/src/main/java/org/opensearch/index/engine/SafeCommitInfo.java
View File

@ -16,9 +16,9 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.opensearch.index.seqno.SequenceNumbers;
/**
* Information about the safe commit, for making decisions about recoveries.

16
server/src/main/java/org/opensearch/index/engine/Segment.java
View File

@ -17,7 +17,7 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.search.Sort;
import org.apache.lucene.search.SortField;
@ -27,13 +27,13 @@ import org.apache.lucene.search.SortedSetSelector;
import org.apache.lucene.search.SortedNumericSelector;
import org.apache.lucene.util.Accountable;
import org.apache.lucene.util.Accountables;
import org.elasticsearch.Version;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.lucene.Lucene;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.opensearch.Version;
import org.opensearch.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.opensearch.common.lucene.Lucene;
import org.opensearch.common.unit.ByteSizeValue;
import java.io.IOException;
import java.util.ArrayList;

16
server/src/main/java/org/opensearch/index/engine/SegmentsStats.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
import org.elasticsearch.common.collect.ImmutableOpenMap;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.io.stream.Writeable;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.xcontent.ToXContentFragment;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.opensearch.common.collect.ImmutableOpenMap;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamOutput;
import org.opensearch.common.io.stream.Writeable;
import org.opensearch.common.unit.ByteSizeValue;
import org.opensearch.common.xcontent.ToXContentFragment;
import org.opensearch.common.xcontent.XContentBuilder;
import java.io.IOException;

4
server/src/main/java/org/opensearch/index/engine/SnapshotFailedEngineException.java
View File

@ -17,9 +17,9 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.opensearch.common.io.stream.StreamInput;
import java.io.IOException;

16
server/src/main/java/org/opensearch/index/engine/SoftDeletesPolicy.java
View File

@ -17,16 +17,16 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.document.LongPoint;
import org.apache.lucene.search.Query;
import org.elasticsearch.common.lease.Releasable;
import org.elasticsearch.index.mapper.SeqNoFieldMapper;
import org.elasticsearch.index.seqno.RetentionLease;
import org.elasticsearch.index.seqno.RetentionLeases;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.translog.Translog;
import org.opensearch.common.lease.Releasable;
import org.opensearch.index.mapper.SeqNoFieldMapper;
import org.opensearch.index.seqno.RetentionLease;
import org.opensearch.index.seqno.RetentionLeases;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.translog.Translog;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
@ -63,7 +63,7 @@ final class SoftDeletesPolicy {
/**
* Updates the number of soft-deleted documents prior to the global checkpoint to be retained
* See {@link org.elasticsearch.index.IndexSettings#INDEX_SOFT_DELETES_RETENTION_OPERATIONS_SETTING}
* See {@link org.opensearch.index.IndexSettings#INDEX_SOFT_DELETES_RETENTION_OPERATIONS_SETTING}
*/
synchronized void setRetentionOperations(long retentionOperations) {
this.retentionOperations = retentionOperations;

14
server/src/main/java/org/opensearch/index/engine/TranslogLeafReader.java
View File

@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.index.BinaryDocValues;
import org.apache.lucene.index.DocValuesType;
@ -35,12 +35,12 @@ import org.apache.lucene.index.StoredFieldVisitor;
import org.apache.lucene.index.Terms;
import org.apache.lucene.util.Bits;
import org.apache.lucene.util.BytesRef;
import org.elasticsearch.common.util.set.Sets;
import org.elasticsearch.index.mapper.IdFieldMapper;
import org.elasticsearch.index.mapper.RoutingFieldMapper;
import org.elasticsearch.index.mapper.SourceFieldMapper;
import org.elasticsearch.index.mapper.Uid;
import org.elasticsearch.index.translog.Translog;
import org.opensearch.common.util.set.Sets;
import org.opensearch.index.mapper.IdFieldMapper;
import org.opensearch.index.mapper.RoutingFieldMapper;
import org.opensearch.index.mapper.SourceFieldMapper;
import org.opensearch.index.mapper.Uid;
import org.opensearch.index.translog.Translog;
import java.io.IOException;
import java.nio.charset.StandardCharsets;

8
server/src/main/java/org/opensearch/index/engine/VersionConflictEngineException.java
View File

@ -16,11 +16,11 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.ShardId;
import org.opensearch.common.io.stream.StreamInput;
import org.opensearch.index.seqno.SequenceNumbers;
import org.opensearch.index.shard.ShardId;
import org.opensearch.rest.RestStatus;
import java.io.IOException;

6
server/src/main/java/org/opensearch/index/engine/VersionValue.java
View File

@ -17,12 +17,12 @@
* under the License.
*/
package org.elasticsearch.index.engine;
package org.opensearch.index.engine;
import org.apache.lucene.util.Accountable;
import org.apache.lucene.util.RamUsageEstimator;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.index.translog.Translog;
import org.opensearch.common.Nullable;
import org.opensearch.index.translog.Translog;
import java.util.Collection;
import java.util.Collections;