Move to v2 package

airlift · Jun 29, 2024 · 3d47864 · 3d47864
1 parent 62ef599
commit 3d47864
Show file tree

Hide file tree

Showing 187 changed files with 726 additions and 726 deletions.
diff --git a/.../java/io/airlift/compress/Compressor.java → ...va/io/airlift/compress/v2/Compressor.java b/.../java/io/airlift/compress/Compressor.java → ...va/io/airlift/compress/v2/Compressor.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress;
+package io.airlift.compress.v2;
 
 import java.lang.foreign.MemorySegment;
 

diff --git a/...ava/io/airlift/compress/Decompressor.java → .../io/airlift/compress/v2/Decompressor.java b/...ava/io/airlift/compress/Decompressor.java → .../io/airlift/compress/v2/Decompressor.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress;
+package io.airlift.compress.v2;
 
 import java.lang.foreign.MemorySegment;
 

diff --git a/...ft/compress/IncompatibleJvmException.java → ...compress/v2/IncompatibleJvmException.java b/...ft/compress/IncompatibleJvmException.java → ...compress/v2/IncompatibleJvmException.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress;
+package io.airlift.compress.v2;
 
 public class IncompatibleJvmException
         extends RuntimeException

diff --git a/...ift/compress/MalformedInputException.java → .../compress/v2/MalformedInputException.java b/...ift/compress/MalformedInputException.java → .../compress/v2/MalformedInputException.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress;
+package io.airlift.compress.v2;
 
 public class MalformedInputException
         extends RuntimeException

diff --git a/...io/airlift/compress/bzip2/BZip2Codec.java → ...airlift/compress/v2/bzip2/BZip2Codec.java b/...io/airlift/compress/bzip2/BZip2Codec.java → ...airlift/compress/v2/bzip2/BZip2Codec.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
-import io.airlift.compress.hadoop.CodecAdapter;
+import io.airlift.compress.v2.hadoop.CodecAdapter;
 
 public class BZip2Codec
         extends CodecAdapter

diff --git a/...irlift/compress/bzip2/BZip2Constants.java → ...ift/compress/v2/bzip2/BZip2Constants.java b/...irlift/compress/bzip2/BZip2Constants.java → ...ift/compress/v2/bzip2/BZip2Constants.java
@@ -16,7 +16,7 @@
  * <[email protected]> to whom the Ant project is very grateful for his
  * great code.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
 /**
  * Base class for both the compress and decompress classes. Holds common arrays,

diff --git a/...ompress/bzip2/BZip2HadoopInputStream.java → ...ress/v2/bzip2/BZip2HadoopInputStream.java b/...ompress/bzip2/BZip2HadoopInputStream.java → ...ress/v2/bzip2/BZip2HadoopInputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;

diff --git a/...mpress/bzip2/BZip2HadoopOutputStream.java → ...ess/v2/bzip2/BZip2HadoopOutputStream.java b/...mpress/bzip2/BZip2HadoopOutputStream.java → ...ess/v2/bzip2/BZip2HadoopOutputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
-import io.airlift.compress.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
 
 import java.io.IOException;
 import java.io.OutputStream;

diff --git a/...ft/compress/bzip2/BZip2HadoopStreams.java → ...compress/v2/bzip2/BZip2HadoopStreams.java b/...ft/compress/bzip2/BZip2HadoopStreams.java → ...compress/v2/bzip2/BZip2HadoopStreams.java
@@ -11,11 +11,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
-import io.airlift.compress.hadoop.HadoopOutputStream;
-import io.airlift.compress.hadoop.HadoopStreams;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopStreams;
 
 import java.io.InputStream;
 import java.io.OutputStream;

diff --git a/...ift/compress/bzip2/CBZip2InputStream.java → .../compress/v2/bzip2/CBZip2InputStream.java b/...ift/compress/bzip2/CBZip2InputStream.java → .../compress/v2/bzip2/CBZip2InputStream.java
@@ -16,18 +16,18 @@
  * <[email protected]> to whom the Ant project is very grateful for his
  * great code.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
-import static io.airlift.compress.bzip2.BZip2Constants.G_SIZE;
-import static io.airlift.compress.bzip2.BZip2Constants.MAX_ALPHA_SIZE;
-import static io.airlift.compress.bzip2.BZip2Constants.MAX_SELECTORS;
-import static io.airlift.compress.bzip2.BZip2Constants.N_GROUPS;
-import static io.airlift.compress.bzip2.BZip2Constants.RUN_A;
-import static io.airlift.compress.bzip2.BZip2Constants.RUN_B;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.G_SIZE;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.MAX_ALPHA_SIZE;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.MAX_SELECTORS;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.N_GROUPS;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.RUN_A;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.RUN_B;
 
 /**
  * An input stream that decompresses from the BZip2 format (without the file

diff --git a/...ft/compress/bzip2/CBZip2OutputStream.java → ...compress/v2/bzip2/CBZip2OutputStream.java b/...ft/compress/bzip2/CBZip2OutputStream.java → ...compress/v2/bzip2/CBZip2OutputStream.java
@@ -11,17 +11,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
 import java.io.IOException;
 import java.io.OutputStream;
 
-import static io.airlift.compress.bzip2.BZip2Constants.G_SIZE;
-import static io.airlift.compress.bzip2.BZip2Constants.MAX_ALPHA_SIZE;
-import static io.airlift.compress.bzip2.BZip2Constants.MAX_SELECTORS;
-import static io.airlift.compress.bzip2.BZip2Constants.N_GROUPS;
-import static io.airlift.compress.bzip2.BZip2Constants.RUN_A;
-import static io.airlift.compress.bzip2.BZip2Constants.RUN_B;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.G_SIZE;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.MAX_ALPHA_SIZE;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.MAX_SELECTORS;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.N_GROUPS;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.RUN_A;
+import static io.airlift.compress.v2.bzip2.BZip2Constants.RUN_B;
 
 /**
  * An output stream that compresses into the BZip2 format (without the file

diff --git a/...java/io/airlift/compress/bzip2/Crc32.java → ...a/io/airlift/compress/v2/bzip2/Crc32.java b/...java/io/airlift/compress/bzip2/Crc32.java → ...a/io/airlift/compress/v2/bzip2/Crc32.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.bzip2;
+package io.airlift.compress.v2.bzip2;
 
 // forked from Apache Hadoop
 final class Crc32

diff --git a/...t/compress/deflate/DeflateCompressor.java → ...ompress/v2/deflate/DeflateCompressor.java b/...t/compress/deflate/DeflateCompressor.java → ...ompress/v2/deflate/DeflateCompressor.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.Compressor;
+import io.airlift.compress.v2.Compressor;
 
 import java.lang.foreign.MemorySegment;
 import java.util.zip.Deflater;

diff --git a/...compress/deflate/DeflateDecompressor.java → ...press/v2/deflate/DeflateDecompressor.java b/...compress/deflate/DeflateDecompressor.java → ...press/v2/deflate/DeflateDecompressor.java
@@ -11,10 +11,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.Decompressor;
-import io.airlift.compress.MalformedInputException;
+import io.airlift.compress.v2.Decompressor;
+import io.airlift.compress.v2.MalformedInputException;
 
 import java.lang.foreign.MemorySegment;
 import java.nio.ByteBuffer;

diff --git a/...ift/compress/deflate/JdkDeflateCodec.java → .../compress/v2/deflate/JdkDeflateCodec.java b/...ift/compress/deflate/JdkDeflateCodec.java → .../compress/v2/deflate/JdkDeflateCodec.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.hadoop.CodecAdapter;
+import io.airlift.compress.v2.hadoop.CodecAdapter;
 
 public class JdkDeflateCodec
         extends CodecAdapter

diff --git a/.../deflate/JdkDeflateHadoopInputStream.java → .../deflate/JdkDeflateHadoopInputStream.java b/.../deflate/JdkDeflateHadoopInputStream.java → .../deflate/JdkDeflateHadoopInputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
 
 import java.io.EOFException;
 import java.io.IOException;

diff --git a/...deflate/JdkDeflateHadoopOutputStream.java → ...deflate/JdkDeflateHadoopOutputStream.java b/...deflate/JdkDeflateHadoopOutputStream.java → ...deflate/JdkDeflateHadoopOutputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
 
 import java.io.IOException;
 import java.io.OutputStream;

diff --git a/...ress/deflate/JdkDeflateHadoopStreams.java → ...s/v2/deflate/JdkDeflateHadoopStreams.java b/...ress/deflate/JdkDeflateHadoopStreams.java → ...s/v2/deflate/JdkDeflateHadoopStreams.java
@@ -11,11 +11,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.deflate;
+package io.airlift.compress.v2.deflate;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
-import io.airlift.compress.hadoop.HadoopOutputStream;
-import io.airlift.compress.hadoop.HadoopStreams;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopStreams;
 
 import java.io.IOException;
 import java.io.InputStream;

diff --git a/...o/airlift/compress/gzip/JdkGzipCodec.java → ...irlift/compress/v2/gzip/JdkGzipCodec.java b/...o/airlift/compress/gzip/JdkGzipCodec.java → ...irlift/compress/v2/gzip/JdkGzipCodec.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.gzip;
+package io.airlift.compress.v2.gzip;
 
-import io.airlift.compress.hadoop.CodecAdapter;
+import io.airlift.compress.v2.hadoop.CodecAdapter;
 
 public class JdkGzipCodec
         extends CodecAdapter

diff --git a/...rlift/compress/gzip/JdkGzipConstants.java → ...ft/compress/v2/gzip/JdkGzipConstants.java b/...rlift/compress/gzip/JdkGzipConstants.java → ...ft/compress/v2/gzip/JdkGzipConstants.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.gzip;
+package io.airlift.compress.v2.gzip;
 
 final class JdkGzipConstants
 {

diff --git a/...mpress/gzip/JdkGzipHadoopInputStream.java → ...ess/v2/gzip/JdkGzipHadoopInputStream.java b/...mpress/gzip/JdkGzipHadoopInputStream.java → ...ess/v2/gzip/JdkGzipHadoopInputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.gzip;
+package io.airlift.compress.v2.gzip;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;

diff --git a/...press/gzip/JdkGzipHadoopOutputStream.java → ...ss/v2/gzip/JdkGzipHadoopOutputStream.java b/...press/gzip/JdkGzipHadoopOutputStream.java → ...ss/v2/gzip/JdkGzipHadoopOutputStream.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.gzip;
+package io.airlift.compress.v2.gzip;
 
-import io.airlift.compress.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
 
 import java.io.IOException;
 import java.io.OutputStream;

diff --git a/...t/compress/gzip/JdkGzipHadoopStreams.java → ...ompress/v2/gzip/JdkGzipHadoopStreams.java b/...t/compress/gzip/JdkGzipHadoopStreams.java → ...ompress/v2/gzip/JdkGzipHadoopStreams.java
@@ -11,11 +11,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.gzip;
+package io.airlift.compress.v2.gzip;
 
-import io.airlift.compress.hadoop.HadoopInputStream;
-import io.airlift.compress.hadoop.HadoopOutputStream;
-import io.airlift.compress.hadoop.HadoopStreams;
+import io.airlift.compress.v2.hadoop.HadoopInputStream;
+import io.airlift.compress.v2.hadoop.HadoopOutputStream;
+import io.airlift.compress.v2.hadoop.HadoopStreams;
 
 import java.io.IOException;
 import java.io.InputStream;

diff --git a/...airlift/compress/hadoop/CodecAdapter.java → ...lift/compress/v2/hadoop/CodecAdapter.java b/...airlift/compress/hadoop/CodecAdapter.java → ...lift/compress/v2/hadoop/CodecAdapter.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
-import io.airlift.compress.hadoop.CompressionInputStreamAdapter.PositionSupplier;
+import io.airlift.compress.v2.hadoop.CompressionInputStreamAdapter.PositionSupplier;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Seekable;

diff --git a/...hadoop/CompressionInputStreamAdapter.java → ...hadoop/CompressionInputStreamAdapter.java b/...hadoop/CompressionInputStreamAdapter.java → ...hadoop/CompressionInputStreamAdapter.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
 import org.apache.hadoop.io.compress.CompressionInputStream;
 

diff --git a/...adoop/CompressionOutputStreamAdapter.java → ...adoop/CompressionOutputStreamAdapter.java b/...adoop/CompressionOutputStreamAdapter.java → ...adoop/CompressionOutputStreamAdapter.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
 import org.apache.hadoop.io.compress.CompressionOutputStream;
 

diff --git a/...ft/compress/hadoop/HadoopInputStream.java → ...compress/v2/hadoop/HadoopInputStream.java b/...ft/compress/hadoop/HadoopInputStream.java → ...compress/v2/hadoop/HadoopInputStream.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
 import java.io.IOException;
 import java.io.InputStream;

diff --git a/...t/compress/hadoop/HadoopOutputStream.java → ...ompress/v2/hadoop/HadoopOutputStream.java b/...t/compress/hadoop/HadoopOutputStream.java → ...ompress/v2/hadoop/HadoopOutputStream.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
 import java.io.IOException;
 import java.io.OutputStream;

diff --git a/...irlift/compress/hadoop/HadoopStreams.java → ...ift/compress/v2/hadoop/HadoopStreams.java b/...irlift/compress/hadoop/HadoopStreams.java → ...ift/compress/v2/hadoop/HadoopStreams.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.hadoop;
+package io.airlift.compress.v2.hadoop;
 
 import java.io.IOException;
 import java.io.InputStream;

diff --git a/...rlift/compress/internal/NativeLoader.java → ...ft/compress/v2/internal/NativeLoader.java b/...rlift/compress/internal/NativeLoader.java → ...ft/compress/v2/internal/NativeLoader.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.internal;
+package io.airlift.compress.v2.internal;
 
 import java.io.File;
 import java.io.IOException;
@@ -155,7 +155,7 @@ private static ValueLayout getMemoryLayout(Class<?> type)
     public static SymbolLookup loadLibrary(String name)
             throws LinkageError
     {
-        if (System.getProperty("io.airlift.compress.disable-native") != null) {
+        if (System.getProperty("io.airlift.compress.v2.disable-native") != null) {
             throw new LinkageError("Native library loading is disabled");
         }
 

diff --git a/...ft/compress/internal/NativeSignature.java → ...compress/v2/internal/NativeSignature.java b/...ft/compress/internal/NativeSignature.java → ...compress/v2/internal/NativeSignature.java
@@ -11,7 +11,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.internal;
+package io.airlift.compress.v2.internal;
 
 import java.lang.annotation.Retention;
 import java.lang.annotation.Target;

diff --git a/...ava/io/airlift/compress/lz4/Lz4Codec.java → .../io/airlift/compress/v2/lz4/Lz4Codec.java b/...ava/io/airlift/compress/lz4/Lz4Codec.java → .../io/airlift/compress/v2/lz4/Lz4Codec.java
@@ -11,9 +11,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.airlift.compress.lz4;
+package io.airlift.compress.v2.lz4;
 
-import io.airlift.compress.hadoop.CodecAdapter;
+import io.airlift.compress.v2.hadoop.CodecAdapter;
 import org.apache.hadoop.conf.Configuration;
 
 import java.util.Optional;