Add polyfill for Parquet compression codecs

composer.json

@@ -69,6 +69,7 @@
             "src/core/etl/src/Flow/ETL/DSL/functions.php",
             "src/lib/array-dot/src/Flow/ArrayDot/array_dot.php",
             "src/lib/parquet/src/Flow/Parquet/functions.php",
+            "src/lib/parquet/src/Flow/Parquet/polyfill.php",
             "src/lib/snappy/polifil.php"
         ],
         "psr-4": {

src/lib/parquet/composer.json

@@ -31,7 +31,8 @@
             ]
         },
         "files": [
-            "src/Flow/Parquet/functions.php"
+            "src/Flow/Parquet/functions.php",
+            "src/Flow/Parquet/polyfill.php"
         ]
     },
     "autoload-dev": {

src/lib/parquet/src/Flow/Parquet/ParquetFile/Codec.php

@@ -25,6 +25,9 @@ public function compress(string $data, Compressions $compression) : string
             Compressions::SNAPPY => \snappy_compress($data),
             /** @phpstan-ignore-next-line */
             Compressions::GZIP => \gzencode($data, $this->options->get(Option::GZIP_COMPRESSION_LEVEL)),
+            Compressions::BROTLI => \brotli_compress($data),
+            Compressions::LZ4 => \lz4_compress($data),
+            Compressions::ZSTD => \zstd_compress($data),
             default => throw new RuntimeException('Compression ' . $compression->name . ' is not supported yet')
         };
 
@@ -42,6 +45,9 @@ public function decompress(string $data, Compressions $compression) : string
             Compressions::UNCOMPRESSED => $data,
             Compressions::SNAPPY => \snappy_uncompress($data),
             Compressions::GZIP => \gzdecode($data),
+            Compressions::BROTLI => \brotli_uncompress($data),
+            Compressions::LZ4 => \lz4_uncompress($data),
+            Compressions::ZSTD => \zstd_uncompress($data),
             default => throw new RuntimeException('Compression ' . $compression->name . ' is not supported yet')
         };
 

src/lib/parquet/src/Flow/Parquet/Writer.php

@@ -38,6 +38,9 @@ public function __construct(
             case Compressions::UNCOMPRESSED:
             case Compressions::SNAPPY:
             case Compressions::GZIP:
+            case Compressions::BROTLI:
+            case Compressions::LZ4:
+            case Compressions::ZSTD:
                 break;
 
             default:

src/lib/parquet/src/Flow/Parquet/polyfill.php

@@ -0,0 +1,47 @@
+<?php
+
+declare(strict_types=1);
+
+use Flow\ETL\Exception\RuntimeException;
+
+if (!\function_exists('brotli_compress')) {
+    function brotli_compress(string $plainText) : string|false
+    {
+        throw new RuntimeException('Brotli PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-brotli');
+    }
+}
+
+if (!\function_exists('brotli_uncompress')) {
+    function brotli_uncompress(string $compressedText) : string|false
+    {
+        throw new RuntimeException('Brotli PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-brotli');
+    }
+}
+
+if (!\function_exists('lz4_compress')) {
+    function lz4_compress(string $plainText) : string|false
+    {
+        throw new RuntimeException('LZ4 PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-lz4');
+    }
+}
+
+if (!\function_exists('lz4_uncompress')) {
+    function lz4_uncompress(string $compressedText) : string|false
+    {
+        throw new RuntimeException('Zstd PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-zstd');
+    }
+}
+
+if (!\function_exists('zstd_compress')) {
+    function zstd_compress(string $plainText) : string|false
+    {
+        throw new RuntimeException('Zstd PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-zstd');
+    }
+}
+
+if (!\function_exists('zstd_uncompress')) {
+    function zstd_uncompress(string $compressedText) : string|false
+    {
+        throw new RuntimeException('LZ4 PHP extension is not installed, please follow instructions from: https://github.com/kjdev/php-ext-zstd');
+    }
+}