Move BufferedChecksum streams to libs/core

Signed-off-by: Himshikha Gupta <himshikh@amazon.com>
opensearch-project · May 29, 2024 · 7f33ba2 · 7f33ba2
1 parent 0400f40
commit 7f33ba2
Show file tree

Hide file tree

Showing 10 changed files with 12 additions and 14 deletions.
diff --git a/...o/stream/BufferedChecksumStreamInput.java → ...o/stream/BufferedChecksumStreamInput.java b/...o/stream/BufferedChecksumStreamInput.java → ...o/stream/BufferedChecksumStreamInput.java
@@ -30,12 +30,10 @@
  * GitHub history for details.
  */
 
-package org.opensearch.common.io.stream;
+package org.opensearch.core.common.io.stream;
 
 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;

diff --git a/.../stream/BufferedChecksumStreamOutput.java → .../stream/BufferedChecksumStreamOutput.java b/.../stream/BufferedChecksumStreamOutput.java → .../stream/BufferedChecksumStreamOutput.java
@@ -30,7 +30,7 @@
  * GitHub history for details.
  */
 
-package org.opensearch.common.io.stream;
+package org.opensearch.core.common.io.stream;
 
 import org.apache.lucene.store.BufferedChecksum;
 import org.opensearch.common.annotation.PublicApi;

diff --git a/server/src/main/java/org/opensearch/gateway/remote/routingtable/IndexRoutingTableInput.java b/server/src/main/java/org/opensearch/gateway/remote/routingtable/IndexRoutingTableInput.java
@@ -10,7 +10,7 @@
 
 import org.opensearch.cluster.routing.IndexRoutingTable;
 import org.opensearch.cluster.routing.IndexShardRoutingTable;
-import org.opensearch.common.io.stream.BufferedChecksumStreamOutput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.common.io.stream.BytesStreamOutput;
 import org.opensearch.core.common.bytes.BytesReference;
 

diff --git a/...n/java/org/opensearch/gateway/remote/routingtable/IndexRoutingTableInputStreamReader.java b/...n/java/org/opensearch/gateway/remote/routingtable/IndexRoutingTableInputStreamReader.java
@@ -12,7 +12,7 @@
 import org.apache.logging.log4j.Logger;
 import org.opensearch.cluster.routing.IndexRoutingTable;
 import org.opensearch.cluster.routing.IndexShardRoutingTable;
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.core.common.io.stream.InputStreamStreamInput;
 import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.index.Index;

diff --git a/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java b/server/src/main/java/org/opensearch/index/translog/BaseTranslogReader.java
@@ -32,7 +32,7 @@
 
 package org.opensearch.index.translog;
 
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.core.common.io.stream.ByteBufferStreamInput;
 import org.opensearch.index.seqno.SequenceNumbers;
 

diff --git a/server/src/main/java/org/opensearch/index/translog/Translog.java b/server/src/main/java/org/opensearch/index/translog/Translog.java
@@ -38,8 +38,8 @@
 import org.opensearch.common.Nullable;
 import org.opensearch.common.UUIDs;
 import org.opensearch.common.annotation.PublicApi;
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
-import org.opensearch.common.io.stream.BufferedChecksumStreamOutput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.common.io.stream.ReleasableBytesStreamOutput;
 import org.opensearch.common.lease.Releasable;
 import org.opensearch.common.lease.Releasables;

diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java b/server/src/main/java/org/opensearch/index/translog/TranslogHeader.java
@@ -40,8 +40,8 @@
 import org.apache.lucene.store.OutputStreamDataOutput;
 import org.apache.lucene.util.BytesRef;
 import org.opensearch.common.io.Channels;
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
-import org.opensearch.common.io.stream.BufferedChecksumStreamOutput;
+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;

diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java b/server/src/main/java/org/opensearch/index/translog/TranslogSnapshot.java
@@ -32,7 +32,7 @@
 package org.opensearch.index.translog;
 
 import org.opensearch.common.io.Channels;
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.index.seqno.SequenceNumbers;
 
 import java.io.EOFException;

diff --git a/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java b/server/src/main/java/org/opensearch/index/translog/TranslogWriter.java
@@ -42,7 +42,7 @@
 import org.opensearch.common.collect.Tuple;
 import org.opensearch.common.io.Channels;
 import org.opensearch.common.io.DiskIoBufferPool;
-import org.opensearch.common.io.stream.BufferedChecksumStreamInput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamInput;
 import org.opensearch.common.io.stream.ReleasableBytesStreamOutput;
 import org.opensearch.common.lease.Releasables;
 import org.opensearch.common.util.BigArrays;

diff --git a/server/src/test/java/org/opensearch/snapshots/BlobStoreFormatTests.java b/server/src/test/java/org/opensearch/snapshots/BlobStoreFormatTests.java
@@ -46,7 +46,7 @@
 import org.opensearch.common.blobstore.stream.write.WritePriority;
 import org.opensearch.common.compress.DeflateCompressor;
 import org.opensearch.common.io.Streams;
-import org.opensearch.common.io.stream.BufferedChecksumStreamOutput;
+import org.opensearch.core.common.io.stream.BufferedChecksumStreamOutput;
 import org.opensearch.common.io.stream.BytesStreamOutput;
 import org.opensearch.core.action.ActionListener;
 import org.opensearch.core.common.bytes.BytesArray;