[addax-storage] Add support for reading lzop compress file

DO NOT support lzop version 1.0.4 or later
wgzhao · Nov 29, 2021 · 0d955e0 · 0d955e0
1 parent 08691e3
commit 0d955e0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/addax-storage/src/main/java/com/wgzhao/addax/storage/reader/StorageReaderUtil.java b/lib/addax-storage/src/main/java/com/wgzhao/addax/storage/reader/StorageReaderUtil.java
@@ -27,6 +27,7 @@
 import com.csvreader.CsvReader;
 import com.wgzhao.addax.common.base.Constant;
 import com.wgzhao.addax.common.base.Key;
+import com.wgzhao.addax.common.compress.ExpandLzopInputStream;
 import com.wgzhao.addax.common.compress.ZipCycleInputStream;
 import com.wgzhao.addax.common.constant.Type;
 import com.wgzhao.addax.common.element.BoolColumn;
@@ -127,6 +128,10 @@ else if ("zip".equalsIgnoreCase(compress)) {
                     ZipCycleInputStream zipCycleInputStream = new ZipCycleInputStream(inputStream);
                     reader = new BufferedReader(new InputStreamReader(zipCycleInputStream, encoding), bufferSize);
                 }
+                else if("lzo".equalsIgnoreCase(compress)) {
+                    ExpandLzopInputStream expandLzopInputStream = new ExpandLzopInputStream(inputStream);
+                    reader = new BufferedReader(new InputStreamReader(expandLzopInputStream, encoding), bufferSize);
+                }
                 else {
                     // common-compress supports almost compress alg
                     CompressorInputStream input = new CompressorStreamFactory().createCompressorInputStream(compress, inputStream, true);