Move to v2 package

README.md

@@ -8,8 +8,8 @@ to interact directly with native libraries without the need for JNI.
 
 # Usage
 
-Each algorithm provides a simple block compression API using the `io.airlift.compress.Compressor` 
-and `io.airlift.compress.Decompressor` classes. Block compression is the simplest form of
+Each algorithm provides a simple block compression API using the `io.airlift.compress.v2.Compressor` 
+and `io.airlift.compress.v2.Decompressor` classes. Block compression is the simplest form of
 which simply compresses a small block of data provided as a `byte[]`, or more generally a
 `java.lang.foreign.MemorySegment`. Each algorithm may have one or more streaming format
 which typically produces a sequence of block compressed chunks.

src/main/java/io/airlift/compress/Compressor.java → src/main/java/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;
 

src/main/java/io/airlift/compress/Decompressor.java → src/main/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;
 

src/main/java/io/airlift/compress/IncompatibleJvmException.java → src/main/java/io/airlift/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

src/main/java/io/airlift/compress/MalformedInputException.java → src/main/java/io/airlift/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

src/main/java/io/airlift/compress/bzip2/BZip2Codec.java → src/main/java/io/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

src/main/java/io/airlift/compress/bzip2/BZip2Constants.java → src/main/java/io/airlift/compress/v2/bzip2/BZip2Constants.java

@@ -16,7 +16,7 @@
  * <keiron@aftexsw.com> 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,

src/main/java/io/airlift/compress/bzip2/BZip2HadoopInputStream.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/bzip2/BZip2HadoopOutputStream.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/bzip2/BZip2HadoopStreams.java → src/main/java/io/airlift/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;

src/main/java/io/airlift/compress/bzip2/CBZip2InputStream.java → src/main/java/io/airlift/compress/v2/bzip2/CBZip2InputStream.java

@@ -16,18 +16,18 @@
  * <keiron@aftexsw.com> 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

src/main/java/io/airlift/compress/bzip2/CBZip2OutputStream.java → src/main/java/io/airlift/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

src/main/java/io/airlift/compress/bzip2/Crc32.java → src/main/java/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

src/main/java/io/airlift/compress/deflate/DeflateCompressor.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/deflate/DeflateDecompressor.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/deflate/JdkDeflateCodec.java → src/main/java/io/airlift/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

src/main/java/io/airlift/compress/deflate/JdkDeflateHadoopInputStream.java → src/main/java/io/airlift/compress/v2/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;

src/main/java/io/airlift/compress/deflate/JdkDeflateHadoopOutputStream.java → src/main/java/io/airlift/compress/v2/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;

src/main/java/io/airlift/compress/deflate/JdkDeflateHadoopStreams.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/gzip/JdkGzipCodec.java → src/main/java/io/airlift/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

src/main/java/io/airlift/compress/gzip/JdkGzipConstants.java → src/main/java/io/airlift/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
 {

src/main/java/io/airlift/compress/gzip/JdkGzipHadoopInputStream.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/gzip/JdkGzipHadoopOutputStream.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/gzip/JdkGzipHadoopStreams.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/hadoop/CodecAdapter.java → src/main/java/io/airlift/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;

src/main/java/io/airlift/compress/hadoop/CompressionInputStreamAdapter.java → src/main/java/io/airlift/compress/v2/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;
 

src/main/java/io/airlift/compress/hadoop/CompressionOutputStreamAdapter.java → src/main/java/io/airlift/compress/v2/hadoop/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;
 

src/main/java/io/airlift/compress/hadoop/HadoopInputStream.java → src/main/java/io/airlift/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;

src/main/java/io/airlift/compress/hadoop/HadoopOutputStream.java → src/main/java/io/airlift/compress/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;

src/main/java/io/airlift/compress/hadoop/HadoopStreams.java → src/main/java/io/airlift/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;

src/main/java/io/airlift/compress/internal/NativeLoader.java → src/main/java/io/airlift/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");
         }
 

src/main/java/io/airlift/compress/internal/NativeSignature.java → src/main/java/io/airlift/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;