Moving BufferedChecksum classes back to main

Signed-off-by: Himshikha Gupta <[email protected]>

Author: Himshikha Gupta

server/src/main/java/org/opensearch/gateway/remote/routingtable/RemoteIndexRoutingTable.java

@@ -10,12 +10,12 @@
 
 import org.opensearch.cluster.routing.IndexRoutingTable;
 import org.opensearch.cluster.routing.IndexShardRoutingTable;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.core.common.io.stream.InputStreamStreamInput;
 import org.opensearch.core.common.io.stream.StreamOutput;
 import org.opensearch.core.common.io.stream.Writeable;
 import org.opensearch.core.index.Index;
+import org.opensearch.index.translog.BufferedChecksumStreamInput;
+import org.opensearch.index.translog.BufferedChecksumStreamOutput;
 
 import java.io.EOFException;
 import java.io.IOException;

server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java

@@ -32,7 +32,6 @@
 
 package org.opensearch.index.translog;
 
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.core.common.io.stream.ByteBufferStreamInput;
 import org.opensearch.index.seqno.SequenceNumbers;
 

libs/core/src/main/java/org/opensearch/core/common/io/stream/BufferedChecksumStreamInput.java renamed to server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamInput.java

@@ -30,10 +30,12 @@
  * GitHub history for details.
  */
 
-package org.opensearch.core.common.io.stream;
+package org.opensearch.index.translog;
 
 import org.apache.lucene.store.BufferedChecksum;
 import org.apache.lucene.util.BitUtil;
+import org.opensearch.core.common.io.stream.FilterStreamInput;
+import org.opensearch.core.common.io.stream.StreamInput;
 
 import java.io.EOFException;
 import java.io.IOException;

libs/core/src/main/java/org/opensearch/core/common/io/stream/BufferedChecksumStreamOutput.java renamed to server/src/main/java/org/opensearch/index/translog/BufferedChecksumStreamOutput.java

@@ -30,10 +30,11 @@
  * GitHub history for details.
  */
 
-package org.opensearch.core.common.io.stream;
+package org.opensearch.index.translog;
 
 import org.apache.lucene.store.BufferedChecksum;
 import org.opensearch.common.annotation.PublicApi;
+import org.opensearch.core.common.io.stream.StreamOutput;
 
 import java.io.IOException;
 import java.util.zip.CRC32;

server/src/main/java/org/opensearch/index/translog/Translog.java

@@ -48,8 +48,6 @@
 import org.opensearch.core.common.Strings;
 import org.opensearch.core.common.bytes.BytesArray;
 import org.opensearch.core.common.bytes.BytesReference;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.common.io.stream.StreamOutput;
 import org.opensearch.core.index.shard.ShardId;

server/src/main/java/org/opensearch/index/translog/TranslogHeader.java

@@ -40,8 +40,6 @@
 import org.apache.lucene.store.OutputStreamDataOutput;
 import org.apache.lucene.util.BytesRef;
 import org.opensearch.common.io.Channels;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.core.common.io.stream.InputStreamStreamInput;
 import org.opensearch.core.common.io.stream.OutputStreamStreamOutput;
 import org.opensearch.core.common.io.stream.StreamInput;

server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java

@@ -32,7 +32,6 @@
 package org.opensearch.index.translog;
 
 import org.opensearch.common.io.Channels;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.index.seqno.SequenceNumbers;
 
 import java.io.EOFException;

server/src/main/java/org/opensearch/index/translog/TranslogWriter.java

@@ -50,7 +50,6 @@
 import org.opensearch.core.Assertions;
 import org.opensearch.core.common.bytes.BytesArray;
 import org.opensearch.core.common.bytes.BytesReference;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.core.common.unit.ByteSizeValue;
 import org.opensearch.core.index.shard.ShardId;
 import org.opensearch.index.seqno.SequenceNumbers;

server/src/test/java/org/opensearch/snapshots/BlobStoreFormatTests.java

@@ -49,13 +49,13 @@
 import org.opensearch.common.io.stream.BytesStreamOutput;
 import org.opensearch.core.action.ActionListener;
 import org.opensearch.core.common.bytes.BytesArray;
-import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.compress.CompressorRegistry;
 import org.opensearch.core.xcontent.ToXContent;
 import org.opensearch.core.xcontent.ToXContentFragment;
 import org.opensearch.core.xcontent.XContentBuilder;
 import org.opensearch.core.xcontent.XContentParser;
+import org.opensearch.index.translog.BufferedChecksumStreamOutput;
 import org.opensearch.repositories.blobstore.ChecksumBlobStoreFormat;
 import org.opensearch.test.OpenSearchTestCase;