diff --git a/planetiler-core/pom.xml b/planetiler-core/pom.xml index c2b88c0946..92c66b0805 100644 --- a/planetiler-core/pom.xml +++ b/planetiler-core/pom.xml @@ -169,7 +169,7 @@ blue.strategic.parquet parquet-floor - 1.41 + 1.43 diff --git a/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressionCodec.java b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressionCodec.java new file mode 100644 index 0000000000..ebcd842b36 --- /dev/null +++ b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressionCodec.java @@ -0,0 +1,6 @@ +package org.apache.hadoop.io.compress; + +/** Add missing interface from compression libraries in hadoop common. */ +public interface DirectDecompressionCodec extends CompressionCodec { + DirectDecompressor createDirectDecompressor(); +} diff --git a/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressor.java b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressor.java new file mode 100644 index 0000000000..bb06cd4766 --- /dev/null +++ b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/DirectDecompressor.java @@ -0,0 +1,9 @@ +package org.apache.hadoop.io.compress; + +import java.io.IOException; +import java.nio.ByteBuffer; + +/** Add missing interface from compression libraries in hadoop common. */ +public interface DirectDecompressor { + void decompress(ByteBuffer src, ByteBuffer dst) throws IOException; +} diff --git a/planetiler-core/src/main/java/org/apache/hadoop/io/compress/GzipCodec.java b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/GzipCodec.java index 287ded26b9..65a31af91d 100644 --- a/planetiler-core/src/main/java/org/apache/hadoop/io/compress/GzipCodec.java +++ b/planetiler-core/src/main/java/org/apache/hadoop/io/compress/GzipCodec.java @@ -8,3 +8,4 @@ * compression. */ public class GzipCodec extends JdkGzipCodec {} +