diff --git a/server/src/main/java/org/opensearch/index/similarity/NonNegativeScoresSimilarity.java b/server/src/main/java/org/opensearch/index/similarity/NonNegativeScoresSimilarity.java index 319ac0ff4b283..b5519427f3d42 100644 --- a/server/src/main/java/org/opensearch/index/similarity/NonNegativeScoresSimilarity.java +++ b/server/src/main/java/org/opensearch/index/similarity/NonNegativeScoresSimilarity.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.index.FieldInvertState; import org.apache.lucene.search.CollectionStatistics; diff --git a/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarity.java b/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarity.java index 1656d9ba0c46b..2e3b62bb7515a 100644 --- a/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarity.java +++ b/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarity.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.index.FieldInvertState; import org.apache.lucene.search.CollectionStatistics; diff --git a/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarityProvider.java b/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarityProvider.java index 0b88cae48a90f..7e88156104a08 100644 --- a/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarityProvider.java +++ b/server/src/main/java/org/opensearch/index/similarity/ScriptedSimilarityProvider.java @@ -17,12 +17,12 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.search.similarities.Similarity; -import org.elasticsearch.Version; -import org.elasticsearch.common.TriFunction; -import org.elasticsearch.common.settings.Settings; +import org.opensearch.Version; +import org.opensearch.common.TriFunction; +import org.opensearch.common.settings.Settings; import org.opensearch.script.Script; import org.opensearch.script.ScriptService; import org.opensearch.script.SimilarityScript; diff --git a/server/src/main/java/org/opensearch/index/similarity/SimilarityProvider.java b/server/src/main/java/org/opensearch/index/similarity/SimilarityProvider.java index f5a870441d43f..eb912d1381db4 100644 --- a/server/src/main/java/org/opensearch/index/similarity/SimilarityProvider.java +++ b/server/src/main/java/org/opensearch/index/similarity/SimilarityProvider.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.search.similarities.Similarity; diff --git a/server/src/main/java/org/opensearch/index/similarity/SimilarityProviders.java b/server/src/main/java/org/opensearch/index/similarity/SimilarityProviders.java index bc7ef5c89f04f..d27b633fd5b54 100644 --- a/server/src/main/java/org/opensearch/index/similarity/SimilarityProviders.java +++ b/server/src/main/java/org/opensearch/index/similarity/SimilarityProviders.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.search.similarities.AfterEffect; import org.apache.lucene.search.similarities.AfterEffectB; @@ -50,9 +50,9 @@ import org.apache.lucene.search.similarities.NormalizationH3; import org.apache.lucene.search.similarities.NormalizationZ; import org.apache.lucene.search.similarity.LegacyBM25Similarity; -import org.elasticsearch.Version; -import org.elasticsearch.common.logging.DeprecationLogger; -import org.elasticsearch.common.settings.Settings; +import org.opensearch.Version; +import org.opensearch.common.logging.DeprecationLogger; +import org.opensearch.common.settings.Settings; import java.util.Arrays; import java.util.HashMap; diff --git a/server/src/main/java/org/opensearch/index/similarity/SimilarityService.java b/server/src/main/java/org/opensearch/index/similarity/SimilarityService.java index 796e3a8da7a5f..9a399cc0070a4 100644 --- a/server/src/main/java/org/opensearch/index/similarity/SimilarityService.java +++ b/server/src/main/java/org/opensearch/index/similarity/SimilarityService.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.similarity; +package org.opensearch.index.similarity; import org.apache.lucene.index.FieldInvertState; import org.apache.lucene.index.IndexOptions; @@ -31,15 +31,15 @@ import org.apache.lucene.search.similarities.Similarity.SimScorer; import org.apache.lucene.search.similarity.LegacyBM25Similarity; import org.apache.lucene.util.BytesRef; -import org.elasticsearch.Version; -import org.elasticsearch.common.TriFunction; -import org.elasticsearch.common.logging.DeprecationLogger; -import org.elasticsearch.common.settings.Settings; -import org.elasticsearch.index.AbstractIndexComponent; -import org.elasticsearch.index.IndexModule; -import org.elasticsearch.index.IndexSettings; -import org.elasticsearch.index.mapper.MappedFieldType; -import org.elasticsearch.index.mapper.MapperService; +import org.opensearch.Version; +import org.opensearch.common.TriFunction; +import org.opensearch.common.logging.DeprecationLogger; +import org.opensearch.common.settings.Settings; +import org.opensearch.index.AbstractIndexComponent; +import org.opensearch.index.IndexModule; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.mapper.MappedFieldType; +import org.opensearch.index.mapper.MapperService; import org.opensearch.script.ScriptService; import java.util.Collections; diff --git a/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreException.java b/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreException.java index a66a4b4de2054..43fe59173bd52 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreException.java +++ b/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreException.java @@ -17,11 +17,11 @@ * under the License. */ -package org.elasticsearch.index.snapshots; +package org.opensearch.index.snapshots; -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; diff --git a/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreFailedException.java b/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreFailedException.java index cc774347451d9..f9b378a445ce6 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreFailedException.java +++ b/server/src/main/java/org/opensearch/index/snapshots/IndexShardRestoreFailedException.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.snapshots; +package org.opensearch.index.snapshots; -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; diff --git a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotException.java b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotException.java index cfdadc472c235..6507097e6f425 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotException.java +++ b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotException.java @@ -17,11 +17,11 @@ * under the License. */ -package org.elasticsearch.index.snapshots; +package org.opensearch.index.snapshots; -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; diff --git a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotFailedException.java b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotFailedException.java index bfb755c9e14f5..80528f6293b58 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotFailedException.java +++ b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotFailedException.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.snapshots; +package org.opensearch.index.snapshots; -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; diff --git a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotStatus.java b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotStatus.java index 129ce08ebd825..47a424e57ab47 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotStatus.java +++ b/server/src/main/java/org/opensearch/index/snapshots/IndexShardSnapshotStatus.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.snapshots; +package org.opensearch.index.snapshots; import java.util.Objects; import java.util.concurrent.atomic.AtomicReference; diff --git a/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshot.java b/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshot.java index 75490e33c33f7..994b779d5ff7a 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshot.java +++ b/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshot.java @@ -17,21 +17,21 @@ * under the License. */ -package org.elasticsearch.index.snapshots.blobstore; +package org.opensearch.index.snapshots.blobstore; import org.apache.lucene.util.BytesRef; import org.apache.lucene.util.Version; -import org.elasticsearch.OpenSearchParseException; -import org.elasticsearch.common.ParseField; -import org.elasticsearch.common.Strings; -import org.elasticsearch.common.lucene.Lucene; -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.elasticsearch.common.xcontent.XContentParser; -import org.elasticsearch.common.xcontent.XContentParserUtils; -import org.elasticsearch.index.store.StoreFileMetadata; +import org.opensearch.OpenSearchParseException; +import org.opensearch.common.ParseField; +import org.opensearch.common.Strings; +import org.opensearch.common.lucene.Lucene; +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 org.opensearch.common.xcontent.XContentParser; +import org.opensearch.common.xcontent.XContentParserUtils; +import org.opensearch.index.store.StoreFileMetadata; import java.io.IOException; import java.util.ArrayList; @@ -179,7 +179,7 @@ public int numberOfParts() { } /** - * Returns file md5 checksum provided by {@link org.elasticsearch.index.store.Store} + * Returns file md5 checksum provided by {@link org.opensearch.index.store.Store} * * @return file checksum */ diff --git a/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshots.java b/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshots.java index 8d40d68357093..55fa917bd8177 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshots.java +++ b/server/src/main/java/org/opensearch/index/snapshots/blobstore/BlobStoreIndexShardSnapshots.java @@ -17,15 +17,15 @@ * under the License. */ -package org.elasticsearch.index.snapshots.blobstore; +package org.opensearch.index.snapshots.blobstore; -import org.elasticsearch.OpenSearchParseException; -import org.elasticsearch.common.ParseField; -import org.elasticsearch.common.xcontent.ToXContentFragment; -import org.elasticsearch.common.xcontent.XContentBuilder; -import org.elasticsearch.common.xcontent.XContentParser; -import org.elasticsearch.common.xcontent.XContentParserUtils; -import org.elasticsearch.index.snapshots.blobstore.BlobStoreIndexShardSnapshot.FileInfo; +import org.opensearch.OpenSearchParseException; +import org.opensearch.common.ParseField; +import org.opensearch.common.xcontent.ToXContentFragment; +import org.opensearch.common.xcontent.XContentBuilder; +import org.opensearch.common.xcontent.XContentParser; +import org.opensearch.common.xcontent.XContentParserUtils; +import org.opensearch.index.snapshots.blobstore.BlobStoreIndexShardSnapshot.FileInfo; import java.io.IOException; import java.util.ArrayList; diff --git a/server/src/main/java/org/opensearch/index/snapshots/blobstore/RateLimitingInputStream.java b/server/src/main/java/org/opensearch/index/snapshots/blobstore/RateLimitingInputStream.java index b1bcc056e6f1e..e0383c8506ff1 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/blobstore/RateLimitingInputStream.java +++ b/server/src/main/java/org/opensearch/index/snapshots/blobstore/RateLimitingInputStream.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.snapshots.blobstore; +package org.opensearch.index.snapshots.blobstore; import org.apache.lucene.store.RateLimiter; diff --git a/server/src/main/java/org/opensearch/index/snapshots/blobstore/SlicedInputStream.java b/server/src/main/java/org/opensearch/index/snapshots/blobstore/SlicedInputStream.java index f055dbc9b345b..434fb4d2cf4cb 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/blobstore/SlicedInputStream.java +++ b/server/src/main/java/org/opensearch/index/snapshots/blobstore/SlicedInputStream.java @@ -16,9 +16,9 @@ * specific language governing permissions and limitations * under the License. */ -package org.elasticsearch.index.snapshots.blobstore; +package org.opensearch.index.snapshots.blobstore; -import org.elasticsearch.core.internal.io.IOUtils; +import org.opensearch.core.internal.io.IOUtils; import java.io.IOException; import java.io.InputStream; diff --git a/server/src/main/java/org/opensearch/index/snapshots/blobstore/SnapshotFiles.java b/server/src/main/java/org/opensearch/index/snapshots/blobstore/SnapshotFiles.java index 8612d50ff8b20..a72979f04b7b7 100644 --- a/server/src/main/java/org/opensearch/index/snapshots/blobstore/SnapshotFiles.java +++ b/server/src/main/java/org/opensearch/index/snapshots/blobstore/SnapshotFiles.java @@ -16,10 +16,10 @@ * specific language governing permissions and limitations * under the License. */ -package org.elasticsearch.index.snapshots.blobstore; +package org.opensearch.index.snapshots.blobstore; -import org.elasticsearch.common.Nullable; -import org.elasticsearch.index.snapshots.blobstore.BlobStoreIndexShardSnapshot.FileInfo; +import org.opensearch.common.Nullable; +import org.opensearch.index.snapshots.blobstore.BlobStoreIndexShardSnapshot.FileInfo; import java.util.HashMap; import java.util.List; diff --git a/server/src/main/java/org/opensearch/index/stats/IndexingPressureStats.java b/server/src/main/java/org/opensearch/index/stats/IndexingPressureStats.java index 27afc8dfa6fd9..14861dd37b5c4 100644 --- a/server/src/main/java/org/opensearch/index/stats/IndexingPressureStats.java +++ b/server/src/main/java/org/opensearch/index/stats/IndexingPressureStats.java @@ -17,15 +17,15 @@ * under the License. */ -package org.elasticsearch.index.stats; - -import org.elasticsearch.Version; -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; +package org.opensearch.index.stats; + +import org.opensearch.Version; +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; diff --git a/server/src/main/java/org/opensearch/index/store/ByteSizeCachingDirectory.java b/server/src/main/java/org/opensearch/index/store/ByteSizeCachingDirectory.java index eb14d3047a611..525e5965a2daa 100644 --- a/server/src/main/java/org/opensearch/index/store/ByteSizeCachingDirectory.java +++ b/server/src/main/java/org/opensearch/index/store/ByteSizeCachingDirectory.java @@ -17,15 +17,15 @@ * under the License. */ -package org.elasticsearch.index.store; +package org.opensearch.index.store; import org.apache.lucene.store.Directory; import org.apache.lucene.store.FilterDirectory; import org.apache.lucene.store.IOContext; import org.apache.lucene.store.IndexOutput; -import org.elasticsearch.common.lucene.store.FilterIndexOutput; -import org.elasticsearch.common.unit.TimeValue; -import org.elasticsearch.common.util.SingleObjectCache; +import org.opensearch.common.lucene.store.FilterIndexOutput; +import org.opensearch.common.unit.TimeValue; +import org.opensearch.common.util.SingleObjectCache; import java.io.FileNotFoundException; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/store/FsDirectoryFactory.java b/server/src/main/java/org/opensearch/index/store/FsDirectoryFactory.java index 950ddf1d1472e..65ffd01446cc7 100644 --- a/server/src/main/java/org/opensearch/index/store/FsDirectoryFactory.java +++ b/server/src/main/java/org/opensearch/index/store/FsDirectoryFactory.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.store; +package org.opensearch.index.store; import org.apache.lucene.store.Directory; import org.apache.lucene.store.FSDirectory; @@ -31,13 +31,13 @@ import org.apache.lucene.store.NativeFSLockFactory; import org.apache.lucene.store.SimpleFSDirectory; import org.apache.lucene.store.SimpleFSLockFactory; -import org.elasticsearch.common.settings.Setting; -import org.elasticsearch.common.settings.Setting.Property; -import org.elasticsearch.core.internal.io.IOUtils; -import org.elasticsearch.index.IndexModule; -import org.elasticsearch.index.IndexSettings; -import org.elasticsearch.index.shard.ShardPath; -import org.elasticsearch.plugins.IndexStorePlugin; +import org.opensearch.common.settings.Setting; +import org.opensearch.common.settings.Setting.Property; +import org.opensearch.core.internal.io.IOUtils; +import org.opensearch.index.IndexModule; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.shard.ShardPath; +import org.opensearch.plugins.IndexStorePlugin; import java.io.IOException; import java.nio.file.Files; diff --git a/server/src/main/java/org/opensearch/index/store/Store.java b/server/src/main/java/org/opensearch/index/store/Store.java index f60ef2facd9a4..c229e2cd393c0 100644 --- a/server/src/main/java/org/opensearch/index/store/Store.java +++ b/server/src/main/java/org/opensearch/index/store/Store.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.store; +package org.opensearch.index.store; import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.message.ParameterizedMessage; @@ -50,36 +50,36 @@ import org.apache.lucene.util.BytesRef; import org.apache.lucene.util.BytesRefBuilder; import org.apache.lucene.util.Version; -import org.elasticsearch.ExceptionsHelper; -import org.elasticsearch.common.UUIDs; -import org.elasticsearch.common.bytes.BytesReference; -import org.elasticsearch.common.io.Streams; -import org.elasticsearch.common.io.stream.BytesStreamOutput; -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.logging.Loggers; -import org.elasticsearch.common.lucene.Lucene; -import org.elasticsearch.common.lucene.store.ByteArrayIndexInput; -import org.elasticsearch.common.lucene.store.InputStreamIndexInput; -import org.elasticsearch.common.settings.Setting; -import org.elasticsearch.common.settings.Setting.Property; -import org.elasticsearch.common.unit.TimeValue; -import org.elasticsearch.common.util.concurrent.AbstractRefCounted; -import org.elasticsearch.common.util.concurrent.RefCounted; -import org.elasticsearch.common.util.iterable.Iterables; -import org.elasticsearch.core.internal.io.IOUtils; -import org.elasticsearch.env.NodeEnvironment; -import org.elasticsearch.env.ShardLock; -import org.elasticsearch.env.ShardLockObtainFailedException; -import org.elasticsearch.index.IndexSettings; -import org.elasticsearch.index.engine.CombinedDeletionPolicy; -import org.elasticsearch.index.engine.Engine; -import org.elasticsearch.index.seqno.SequenceNumbers; -import org.elasticsearch.index.shard.AbstractIndexShardComponent; -import org.elasticsearch.index.shard.IndexShard; -import org.elasticsearch.index.shard.ShardId; -import org.elasticsearch.index.translog.Translog; +import org.opensearch.ExceptionsHelper; +import org.opensearch.common.UUIDs; +import org.opensearch.common.bytes.BytesReference; +import org.opensearch.common.io.Streams; +import org.opensearch.common.io.stream.BytesStreamOutput; +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.logging.Loggers; +import org.opensearch.common.lucene.Lucene; +import org.opensearch.common.lucene.store.ByteArrayIndexInput; +import org.opensearch.common.lucene.store.InputStreamIndexInput; +import org.opensearch.common.settings.Setting; +import org.opensearch.common.settings.Setting.Property; +import org.opensearch.common.unit.TimeValue; +import org.opensearch.common.util.concurrent.AbstractRefCounted; +import org.opensearch.common.util.concurrent.RefCounted; +import org.opensearch.common.util.iterable.Iterables; +import org.opensearch.core.internal.io.IOUtils; +import org.opensearch.env.NodeEnvironment; +import org.opensearch.env.ShardLock; +import org.opensearch.env.ShardLockObtainFailedException; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.engine.CombinedDeletionPolicy; +import org.opensearch.index.engine.Engine; +import org.opensearch.index.seqno.SequenceNumbers; +import org.opensearch.index.shard.AbstractIndexShardComponent; +import org.opensearch.index.shard.IndexShard; +import org.opensearch.index.shard.ShardId; +import org.opensearch.index.translog.Translog; import java.io.Closeable; import java.io.EOFException; @@ -109,7 +109,7 @@ import static java.util.Collections.unmodifiableMap; /** - * A Store provides plain access to files written by an elasticsearch index shard. Each shard + * A Store provides plain access to files written by an opensearch index shard. Each shard * has a dedicated store that is uses to access Lucene's Directory which represents the lowest level * of file abstraction in Lucene used to read and write Lucene indices. * This class also provides access to metadata information like checksums for committed files. A committed @@ -864,7 +864,7 @@ static LoadedMetadata loadMetadata(IndexCommit commit, Directory directory, Logg } } if (maxVersion == null) { - maxVersion = org.elasticsearch.Version.CURRENT.minimumIndexCompatibilityVersion().luceneVersion; + maxVersion = org.opensearch.Version.CURRENT.minimumIndexCompatibilityVersion().luceneVersion; } final String segmentsFile = segmentCommitInfos.getSegmentsFileName(); checksumFromLuceneFile(directory, segmentsFile, builder, logger, maxVersion, true); @@ -1097,7 +1097,7 @@ public String getSyncId() { /** * A class representing the diff between a recovery source and recovery target * - * @see MetadataSnapshot#recoveryDiff(org.elasticsearch.index.store.Store.MetadataSnapshot) + * @see MetadataSnapshot#recoveryDiff(org.opensearch.index.store.Store.MetadataSnapshot) */ public static final class RecoveryDiff { /** @@ -1400,7 +1400,7 @@ public void markStoreCorrupted(IOException exception) throws IOException { public interface OnClose extends Consumer { OnClose EMPTY = new OnClose() { /** - * This method is called while the provided {@link org.elasticsearch.env.ShardLock} is held. + * This method is called while the provided {@link org.opensearch.env.ShardLock} is held. * This method is only called once after all resources for a store are released. */ @Override @@ -1519,7 +1519,7 @@ public void ensureIndexHasHistoryUUID() throws IOException { * the policy can consider the snapshotted commit as a safe commit for recovery even the commit does not have translog. */ public void trimUnsafeCommits(final long lastSyncedGlobalCheckpoint, final long minRetainedTranslogGen, - final org.elasticsearch.Version indexVersionCreated) throws IOException { + final org.opensearch.Version indexVersionCreated) throws IOException { metadataLock.writeLock().lock(); try { final List existingCommits = DirectoryReader.listCommits(directory); @@ -1532,7 +1532,7 @@ public void trimUnsafeCommits(final long lastSyncedGlobalCheckpoint, final long // We may not have a safe commit if an index was create before v6.2; and if there is a snapshotted commit whose translog // are not retained but max_seqno is at most the global checkpoint, we may mistakenly select it as a starting commit. // To avoid this issue, we only select index commits whose translog are fully retained. - if (indexVersionCreated.before(org.elasticsearch.Version.V_6_2_0)) { + if (indexVersionCreated.before(org.opensearch.Version.V_6_2_0)) { final List recoverableCommits = new ArrayList<>(); for (IndexCommit commit : existingCommits) { final String translogGeneration = commit.getUserData().get("translog_generation"); @@ -1578,7 +1578,7 @@ public void trimUnsafeCommits(final long lastSyncedGlobalCheckpoint, final long } /** - * Returns a {@link org.elasticsearch.index.seqno.SequenceNumbers.CommitInfo} of the safe commit if exists. + * Returns a {@link org.opensearch.index.seqno.SequenceNumbers.CommitInfo} of the safe commit if exists. */ public Optional findSafeIndexCommit(long globalCheckpoint) throws IOException { final List commits = DirectoryReader.listCommits(directory); diff --git a/server/src/main/java/org/opensearch/index/store/StoreFileMetadata.java b/server/src/main/java/org/opensearch/index/store/StoreFileMetadata.java index b9de3090de503..1b756eb8d9879 100644 --- a/server/src/main/java/org/opensearch/index/store/StoreFileMetadata.java +++ b/server/src/main/java/org/opensearch/index/store/StoreFileMetadata.java @@ -17,15 +17,15 @@ * under the License. */ -package org.elasticsearch.index.store; +package org.opensearch.index.store; import org.apache.lucene.codecs.CodecUtil; import org.apache.lucene.util.BytesRef; import org.apache.lucene.util.Version; -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.store.ByteArrayIndexInput; +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.store.ByteArrayIndexInput; import java.io.IOException; import java.text.ParseException; diff --git a/server/src/main/java/org/opensearch/index/store/StoreStats.java b/server/src/main/java/org/opensearch/index/store/StoreStats.java index e1ab5b526f018..8eaea397547a9 100644 --- a/server/src/main/java/org/opensearch/index/store/StoreStats.java +++ b/server/src/main/java/org/opensearch/index/store/StoreStats.java @@ -17,15 +17,15 @@ * under the License. */ -package org.elasticsearch.index.store; - -import org.elasticsearch.Version; -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; +package org.opensearch.index.store; + +import org.opensearch.Version; +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; diff --git a/server/src/main/java/org/opensearch/index/store/VerifyingIndexOutput.java b/server/src/main/java/org/opensearch/index/store/VerifyingIndexOutput.java index a4d5039b1193f..73af8251e12a1 100644 --- a/server/src/main/java/org/opensearch/index/store/VerifyingIndexOutput.java +++ b/server/src/main/java/org/opensearch/index/store/VerifyingIndexOutput.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.store; +package org.opensearch.index.store; import org.apache.lucene.store.IndexOutput; -import org.elasticsearch.common.lucene.store.FilterIndexOutput; +import org.opensearch.common.lucene.store.FilterIndexOutput; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/termvectors/TermVectorsService.java b/server/src/main/java/org/opensearch/index/termvectors/TermVectorsService.java index be0edef594c8c..efe3cbfa32991 100644 --- a/server/src/main/java/org/opensearch/index/termvectors/TermVectorsService.java +++ b/server/src/main/java/org/opensearch/index/termvectors/TermVectorsService.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.termvectors; +package org.opensearch.index.termvectors; import org.apache.lucene.analysis.Analyzer; import org.apache.lucene.index.Fields; @@ -28,32 +28,32 @@ import org.apache.lucene.index.Term; import org.apache.lucene.index.Terms; import org.apache.lucene.index.memory.MemoryIndex; -import org.elasticsearch.OpenSearchException; -import org.elasticsearch.action.termvectors.TermVectorsFilter; -import org.elasticsearch.action.termvectors.TermVectorsRequest; -import org.elasticsearch.action.termvectors.TermVectorsResponse; -import org.elasticsearch.common.Nullable; -import org.elasticsearch.common.Strings; -import org.elasticsearch.common.bytes.BytesReference; -import org.elasticsearch.common.document.DocumentField; -import org.elasticsearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndVersion; -import org.elasticsearch.common.xcontent.XContentHelper; -import org.elasticsearch.common.xcontent.XContentType; -import org.elasticsearch.common.xcontent.support.XContentMapValues; -import org.elasticsearch.index.engine.Engine; -import org.elasticsearch.index.get.GetResult; -import org.elasticsearch.index.mapper.DocumentMapperForType; -import org.elasticsearch.index.mapper.IdFieldMapper; -import org.elasticsearch.index.mapper.MappedFieldType; -import org.elasticsearch.index.mapper.MapperService; -import org.elasticsearch.index.mapper.ParseContext; -import org.elasticsearch.index.mapper.ParsedDocument; -import org.elasticsearch.index.mapper.SourceFieldMapper; -import org.elasticsearch.index.mapper.SourceToParse; -import org.elasticsearch.index.mapper.StringFieldType; -import org.elasticsearch.index.mapper.TextSearchInfo; -import org.elasticsearch.index.mapper.Uid; -import org.elasticsearch.index.shard.IndexShard; +import org.opensearch.OpenSearchException; +import org.opensearch.action.termvectors.TermVectorsFilter; +import org.opensearch.action.termvectors.TermVectorsRequest; +import org.opensearch.action.termvectors.TermVectorsResponse; +import org.opensearch.common.Nullable; +import org.opensearch.common.Strings; +import org.opensearch.common.bytes.BytesReference; +import org.opensearch.common.document.DocumentField; +import org.opensearch.common.lucene.uid.VersionsAndSeqNoResolver.DocIdAndVersion; +import org.opensearch.common.xcontent.XContentHelper; +import org.opensearch.common.xcontent.XContentType; +import org.opensearch.common.xcontent.support.XContentMapValues; +import org.opensearch.index.engine.Engine; +import org.opensearch.index.get.GetResult; +import org.opensearch.index.mapper.DocumentMapperForType; +import org.opensearch.index.mapper.IdFieldMapper; +import org.opensearch.index.mapper.MappedFieldType; +import org.opensearch.index.mapper.MapperService; +import org.opensearch.index.mapper.ParseContext; +import org.opensearch.index.mapper.ParsedDocument; +import org.opensearch.index.mapper.SourceFieldMapper; +import org.opensearch.index.mapper.SourceToParse; +import org.opensearch.index.mapper.StringFieldType; +import org.opensearch.index.mapper.TextSearchInfo; +import org.opensearch.index.mapper.Uid; +import org.opensearch.index.shard.IndexShard; import java.io.IOException; import java.util.ArrayList; diff --git a/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java b/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java index 8f5884d02758e..8ab0fdb5ec049 100644 --- a/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java +++ b/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -import org.elasticsearch.common.io.stream.ByteBufferStreamInput; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.common.io.stream.ByteBufferStreamInput; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.IOException; import java.nio.ByteBuffer; diff --git a/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamInput.java b/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamInput.java index fa37991d82c04..fa8c3c99086eb 100644 --- a/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamInput.java +++ b/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamInput.java @@ -17,11 +17,11 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.store.BufferedChecksum; -import org.elasticsearch.common.io.stream.FilterStreamInput; -import org.elasticsearch.common.io.stream.StreamInput; +import org.opensearch.common.io.stream.FilterStreamInput; +import org.opensearch.common.io.stream.StreamInput; import java.io.IOException; import java.util.zip.CRC32; diff --git a/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamOutput.java b/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamOutput.java index b99a6da5f2255..ac1ffd228b87e 100644 --- a/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamOutput.java +++ b/server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamOutput.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.store.BufferedChecksum; -import org.elasticsearch.common.io.stream.StreamOutput; +import org.opensearch.common.io.stream.StreamOutput; import java.io.IOException; import java.util.zip.CRC32; diff --git a/server/src/main/java/org/opensearch/index/translog/ChannelFactory.java b/server/src/main/java/org/opensearch/index/translog/ChannelFactory.java index ccb362a350772..35f7054e6524f 100644 --- a/server/src/main/java/org/opensearch/index/translog/ChannelFactory.java +++ b/server/src/main/java/org/opensearch/index/translog/ChannelFactory.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import java.io.IOException; import java.nio.channels.FileChannel; diff --git a/server/src/main/java/org/opensearch/index/translog/Checkpoint.java b/server/src/main/java/org/opensearch/index/translog/Checkpoint.java index b0a378c926892..c87de47dfd4e0 100644 --- a/server/src/main/java/org/opensearch/index/translog/Checkpoint.java +++ b/server/src/main/java/org/opensearch/index/translog/Checkpoint.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.codecs.CodecUtil; import org.apache.lucene.index.CorruptIndexException; @@ -30,8 +30,8 @@ import org.apache.lucene.store.IndexInput; import org.apache.lucene.store.OutputStreamIndexOutput; import org.apache.lucene.store.SimpleFSDirectory; -import org.elasticsearch.common.io.Channels; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.common.io.Channels; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.ByteArrayOutputStream; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/MultiSnapshot.java b/server/src/main/java/org/opensearch/index/translog/MultiSnapshot.java index c0969cbc80ec8..d200937e62eab 100644 --- a/server/src/main/java/org/opensearch/index/translog/MultiSnapshot.java +++ b/server/src/main/java/org/opensearch/index/translog/MultiSnapshot.java @@ -17,11 +17,11 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import com.carrotsearch.hppc.LongObjectHashMap; -import org.elasticsearch.index.seqno.CountedBitSet; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.index.seqno.CountedBitSet; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.Closeable; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/TragicExceptionHolder.java b/server/src/main/java/org/opensearch/index/translog/TragicExceptionHolder.java index 2d8b105099b38..184cb77ff7208 100644 --- a/server/src/main/java/org/opensearch/index/translog/TragicExceptionHolder.java +++ b/server/src/main/java/org/opensearch/index/translog/TragicExceptionHolder.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.store.AlreadyClosedException; -import org.elasticsearch.ExceptionsHelper; +import org.opensearch.ExceptionsHelper; import java.util.concurrent.atomic.AtomicReference; diff --git a/server/src/main/java/org/opensearch/index/translog/Translog.java b/server/src/main/java/org/opensearch/index/translog/Translog.java index eba91ab21deda..7a0624e9d4a6d 100644 --- a/server/src/main/java/org/opensearch/index/translog/Translog.java +++ b/server/src/main/java/org/opensearch/index/translog/Translog.java @@ -17,33 +17,33 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.logging.log4j.message.ParameterizedMessage; import org.apache.lucene.index.Term; import org.apache.lucene.store.AlreadyClosedException; -import org.elasticsearch.Version; -import org.elasticsearch.common.Nullable; -import org.elasticsearch.common.Strings; -import org.elasticsearch.common.UUIDs; -import org.elasticsearch.common.bytes.BytesArray; -import org.elasticsearch.common.bytes.BytesReference; -import org.elasticsearch.common.io.stream.ReleasableBytesStreamOutput; -import org.elasticsearch.common.io.stream.StreamInput; -import org.elasticsearch.common.io.stream.StreamOutput; -import org.elasticsearch.common.lease.Releasable; -import org.elasticsearch.common.lease.Releasables; -import org.elasticsearch.common.lucene.uid.Versions; -import org.elasticsearch.common.util.BigArrays; -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.engine.Engine; -import org.elasticsearch.index.seqno.SequenceNumbers; -import org.elasticsearch.index.shard.AbstractIndexShardComponent; -import org.elasticsearch.index.shard.IndexShardComponent; -import org.elasticsearch.index.shard.ShardId; +import org.opensearch.Version; +import org.opensearch.common.Nullable; +import org.opensearch.common.Strings; +import org.opensearch.common.UUIDs; +import org.opensearch.common.bytes.BytesArray; +import org.opensearch.common.bytes.BytesReference; +import org.opensearch.common.io.stream.ReleasableBytesStreamOutput; +import org.opensearch.common.io.stream.StreamInput; +import org.opensearch.common.io.stream.StreamOutput; +import org.opensearch.common.lease.Releasable; +import org.opensearch.common.lease.Releasables; +import org.opensearch.common.lucene.uid.Versions; +import org.opensearch.common.util.BigArrays; +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.engine.Engine; +import org.opensearch.index.seqno.SequenceNumbers; +import org.opensearch.index.shard.AbstractIndexShardComponent; +import org.opensearch.index.shard.IndexShardComponent; +import org.opensearch.index.shard.ShardId; import java.io.Closeable; import java.io.EOFException; @@ -71,11 +71,11 @@ import java.util.stream.Collectors; import java.util.stream.Stream; -import static org.elasticsearch.index.translog.TranslogConfig.EMPTY_TRANSLOG_BUFFER_SIZE; +import static org.opensearch.index.translog.TranslogConfig.EMPTY_TRANSLOG_BUFFER_SIZE; /** * A Translog is a per index shard component that records all non-committed index operations in a durable manner. - * In Elasticsearch there is one Translog instance per {@link org.elasticsearch.index.engine.InternalEngine}. + * In OpenSearch there is one Translog instance per {@link org.opensearch.index.engine.InternalEngine}. * Additionally, since Elasticsearch 2.0 the engine also records a {@link #TRANSLOG_UUID_KEY} with each commit to ensure a strong * association between the lucene index an the transaction log file. This UUID is used to prevent accidental recovery from a transaction * log that belongs to a diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogConfig.java b/server/src/main/java/org/opensearch/index/translog/TranslogConfig.java index ba9547ec6e352..85ee38f1667bf 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogConfig.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogConfig.java @@ -17,13 +17,13 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -import org.elasticsearch.common.unit.ByteSizeUnit; -import org.elasticsearch.common.unit.ByteSizeValue; -import org.elasticsearch.common.util.BigArrays; -import org.elasticsearch.index.IndexSettings; -import org.elasticsearch.index.shard.ShardId; +import org.opensearch.common.unit.ByteSizeUnit; +import org.opensearch.common.unit.ByteSizeValue; +import org.opensearch.common.util.BigArrays; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.shard.ShardId; import java.nio.file.Path; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogCorruptedException.java b/server/src/main/java/org/opensearch/index/translog/TranslogCorruptedException.java index e75ce4bfaa074..65b5ecda362a3 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogCorruptedException.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogCorruptedException.java @@ -17,10 +17,10 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -import org.elasticsearch.OpenSearchException; -import org.elasticsearch.common.io.stream.StreamInput; +import org.opensearch.OpenSearchException; +import org.opensearch.common.io.stream.StreamInput; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogDeletionPolicy.java b/server/src/main/java/org/opensearch/index/translog/TranslogDeletionPolicy.java index a26b2dc15e9ad..b8e31dd7cce01 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogDeletionPolicy.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogDeletionPolicy.java @@ -17,12 +17,12 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.util.Counter; -import org.elasticsearch.Assertions; -import org.elasticsearch.common.lease.Releasable; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.Assertions; +import org.opensearch.common.lease.Releasable; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.IOException; import java.util.HashMap; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogException.java b/server/src/main/java/org/opensearch/index/translog/TranslogException.java index 3f8a2dad25ff2..dc794e496e000 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogException.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogException.java @@ -17,11 +17,11 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -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; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java b/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java index d405ab463cd45..b7f139ce551d1 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.codecs.CodecUtil; import org.apache.lucene.index.CorruptIndexException; @@ -26,17 +26,17 @@ import org.apache.lucene.store.InputStreamDataInput; import org.apache.lucene.store.OutputStreamDataOutput; import org.apache.lucene.util.BytesRef; -import org.elasticsearch.common.io.Channels; -import org.elasticsearch.common.io.stream.InputStreamStreamInput; -import org.elasticsearch.common.io.stream.OutputStreamStreamOutput; -import org.elasticsearch.common.io.stream.StreamInput; +import org.opensearch.common.io.Channels; +import org.opensearch.common.io.stream.InputStreamStreamInput; +import org.opensearch.common.io.stream.OutputStreamStreamOutput; +import org.opensearch.common.io.stream.StreamInput; import java.io.EOFException; import java.io.IOException; import java.nio.channels.FileChannel; import java.nio.file.Path; -import static org.elasticsearch.index.seqno.SequenceNumbers.UNASSIGNED_PRIMARY_TERM; +import static org.opensearch.index.seqno.SequenceNumbers.UNASSIGNED_PRIMARY_TERM; /** * Each translog file is started with a translog header then followed by translog operations. diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogReader.java b/server/src/main/java/org/opensearch/index/translog/TranslogReader.java index a75f49972a5d2..013ce8603e098 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogReader.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogReader.java @@ -17,12 +17,12 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.lucene.store.AlreadyClosedException; -import org.elasticsearch.common.io.Channels; -import org.elasticsearch.core.internal.io.IOUtils; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.common.io.Channels; +import org.opensearch.core.internal.io.IOUtils; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.Closeable; import java.io.EOFException; @@ -33,7 +33,7 @@ import java.nio.file.StandardOpenOption; import java.util.concurrent.atomic.AtomicBoolean; -import static org.elasticsearch.index.translog.Translog.getCommitCheckpointFileName; +import static org.opensearch.index.translog.Translog.getCommitCheckpointFileName; /** * an immutable translog filereader diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java b/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java index 4cfc886219f60..ce735cace31c2 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java @@ -16,10 +16,10 @@ * specific language governing permissions and limitations * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -import org.elasticsearch.common.io.Channels; -import org.elasticsearch.index.seqno.SequenceNumbers; +import org.opensearch.common.io.Channels; +import org.opensearch.index.seqno.SequenceNumbers; import java.io.EOFException; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogStats.java b/server/src/main/java/org/opensearch/index/translog/TranslogStats.java index 37c671a6c222c..e4f3d305a5ba6 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogStats.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogStats.java @@ -16,16 +16,16 @@ * specific language governing permissions and limitations * under the License. */ -package org.elasticsearch.index.translog; - -import org.elasticsearch.Version; -import org.elasticsearch.common.Strings; -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; +package org.opensearch.index.translog; + +import org.opensearch.Version; +import org.opensearch.common.Strings; +import org.opensearch.common.io.stream.StreamInput; +import org.opensearch.common.io.stream.StreamOutput; +import org.opensearch.common.io.stream.Writeable; +import org.opensearch.common.unit.ByteSizeValue; +import org.opensearch.common.xcontent.ToXContentFragment; +import org.opensearch.common.xcontent.XContentBuilder; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java b/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java index 7a58b2a0ace51..7a98dc3d39a0a 100644 --- a/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java +++ b/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java @@ -17,29 +17,29 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import com.carrotsearch.hppc.LongArrayList; import com.carrotsearch.hppc.procedures.LongProcedure; import org.apache.lucene.store.AlreadyClosedException; import org.apache.lucene.util.BytesRef; import org.apache.lucene.util.BytesRefIterator; -import org.elasticsearch.Assertions; -import org.elasticsearch.common.SuppressForbidden; -import org.elasticsearch.common.bytes.BytesArray; -import org.elasticsearch.common.bytes.BytesReference; -import org.elasticsearch.common.bytes.ReleasableBytesReference; -import org.elasticsearch.common.collect.Tuple; -import org.elasticsearch.common.io.Channels; -import org.elasticsearch.common.io.DiskIoBufferPool; -import org.elasticsearch.common.io.stream.ReleasableBytesStreamOutput; -import org.elasticsearch.common.lease.Releasables; -import org.elasticsearch.common.unit.ByteSizeValue; -import org.elasticsearch.common.util.BigArrays; -import org.elasticsearch.common.util.concurrent.ReleasableLock; -import org.elasticsearch.core.internal.io.IOUtils; -import org.elasticsearch.index.seqno.SequenceNumbers; -import org.elasticsearch.index.shard.ShardId; +import org.opensearch.Assertions; +import org.opensearch.common.SuppressForbidden; +import org.opensearch.common.bytes.BytesArray; +import org.opensearch.common.bytes.BytesReference; +import org.opensearch.common.bytes.ReleasableBytesReference; +import org.opensearch.common.collect.Tuple; +import org.opensearch.common.io.Channels; +import org.opensearch.common.io.DiskIoBufferPool; +import org.opensearch.common.io.stream.ReleasableBytesStreamOutput; +import org.opensearch.common.lease.Releasables; +import org.opensearch.common.unit.ByteSizeValue; +import org.opensearch.common.util.BigArrays; +import org.opensearch.common.util.concurrent.ReleasableLock; +import org.opensearch.core.internal.io.IOUtils; +import org.opensearch.index.seqno.SequenceNumbers; +import org.opensearch.index.shard.ShardId; import java.io.Closeable; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/translog/TruncateTranslogAction.java b/server/src/main/java/org/opensearch/index/translog/TruncateTranslogAction.java index 0bacc0304e11d..63b388fb87276 100644 --- a/server/src/main/java/org/opensearch/index/translog/TruncateTranslogAction.java +++ b/server/src/main/java/org/opensearch/index/translog/TruncateTranslogAction.java @@ -17,28 +17,28 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.apache.lucene.index.DirectoryReader; import org.apache.lucene.index.IndexCommit; import org.apache.lucene.store.Directory; -import org.elasticsearch.OpenSearchException; +import org.opensearch.OpenSearchException; import org.opensearch.cli.Terminal; import org.opensearch.cluster.ClusterState; import org.opensearch.cluster.metadata.IndexMetadata; -import org.elasticsearch.common.UUIDs; -import org.elasticsearch.common.collect.Tuple; -import org.elasticsearch.common.settings.Settings; -import org.elasticsearch.common.util.BigArrays; -import org.elasticsearch.common.xcontent.NamedXContentRegistry; -import org.elasticsearch.core.internal.io.IOUtils; -import org.elasticsearch.index.IndexNotFoundException; -import org.elasticsearch.index.IndexSettings; -import org.elasticsearch.index.seqno.SequenceNumbers; -import org.elasticsearch.index.shard.RemoveCorruptedShardDataCommand; -import org.elasticsearch.index.shard.ShardPath; +import org.opensearch.common.UUIDs; +import org.opensearch.common.collect.Tuple; +import org.opensearch.common.settings.Settings; +import org.opensearch.common.util.BigArrays; +import org.opensearch.common.xcontent.NamedXContentRegistry; +import org.opensearch.core.internal.io.IOUtils; +import org.opensearch.index.IndexNotFoundException; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.seqno.SequenceNumbers; +import org.opensearch.index.shard.RemoveCorruptedShardDataCommand; +import org.opensearch.index.shard.ShardPath; import java.io.IOException; import java.nio.channels.FileChannel; diff --git a/server/src/main/java/org/opensearch/index/translog/TruncatedTranslogException.java b/server/src/main/java/org/opensearch/index/translog/TruncatedTranslogException.java index 5e0be02b7fcfc..25e24f24e6f6f 100644 --- a/server/src/main/java/org/opensearch/index/translog/TruncatedTranslogException.java +++ b/server/src/main/java/org/opensearch/index/translog/TruncatedTranslogException.java @@ -17,9 +17,9 @@ * under the License. */ -package org.elasticsearch.index.translog; +package org.opensearch.index.translog; -import org.elasticsearch.common.io.stream.StreamInput; +import org.opensearch.common.io.stream.StreamInput; import java.io.IOException; diff --git a/server/src/main/java/org/opensearch/index/warmer/ShardIndexWarmerService.java b/server/src/main/java/org/opensearch/index/warmer/ShardIndexWarmerService.java index d10a951937ead..07e856a9c2efe 100644 --- a/server/src/main/java/org/opensearch/index/warmer/ShardIndexWarmerService.java +++ b/server/src/main/java/org/opensearch/index/warmer/ShardIndexWarmerService.java @@ -17,14 +17,14 @@ * under the License. */ -package org.elasticsearch.index.warmer; +package org.opensearch.index.warmer; import org.apache.logging.log4j.Logger; -import org.elasticsearch.common.metrics.CounterMetric; -import org.elasticsearch.common.metrics.MeanMetric; -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.common.metrics.MeanMetric; +import org.opensearch.index.IndexSettings; +import org.opensearch.index.shard.AbstractIndexShardComponent; +import org.opensearch.index.shard.ShardId; import java.util.concurrent.TimeUnit; diff --git a/server/src/main/java/org/opensearch/index/warmer/WarmerStats.java b/server/src/main/java/org/opensearch/index/warmer/WarmerStats.java index 6544d4447bfe9..9e32ca11c6b61 100644 --- a/server/src/main/java/org/opensearch/index/warmer/WarmerStats.java +++ b/server/src/main/java/org/opensearch/index/warmer/WarmerStats.java @@ -17,14 +17,14 @@ * under the License. */ -package org.elasticsearch.index.warmer; - -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.TimeValue; -import org.elasticsearch.common.xcontent.ToXContentFragment; -import org.elasticsearch.common.xcontent.XContentBuilder; +package org.opensearch.index.warmer; + +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.TimeValue; +import org.opensearch.common.xcontent.ToXContentFragment; +import org.opensearch.common.xcontent.XContentBuilder; import java.io.IOException;