|
31 | 31 | import org.apache.paimon.types.DataTypes; |
32 | 32 | import org.apache.paimon.types.RowType; |
33 | 33 |
|
| 34 | +import org.junit.jupiter.api.Disabled; |
34 | 35 | import org.junit.jupiter.api.Test; |
35 | 36 | import org.junit.jupiter.api.io.TempDir; |
| 37 | +import org.junit.jupiter.params.ParameterizedTest; |
| 38 | +import org.junit.jupiter.params.provider.EnumSource; |
36 | 39 |
|
37 | 40 | import java.io.IOException; |
38 | 41 | import java.util.ArrayList; |
@@ -63,28 +66,23 @@ public abstract class TextCompressionTest { |
63 | 66 | /** Returns the file extension for the format. */ |
64 | 67 | protected abstract String getFormatExtension(); |
65 | 68 |
|
66 | | - // TODO fix dependencies |
67 | | - // @ParameterizedTest(name = "compression = {0}") |
68 | | - // @EnumSource(TextCompressionType.class) |
69 | | - // void testCompression(TextCompressionType compression) throws IOException { |
70 | | - // testCompressionRoundTrip( |
71 | | - // compression.value(), |
72 | | - // String.format( |
73 | | - // "test_compress.%s.%s", |
74 | | - // getFormatExtension(), compression.fileExtension())); |
75 | | - // } |
76 | | - |
77 | | - // TODO fix dependencies |
78 | | - // @ParameterizedTest(name = "compression = {0}") |
79 | | - // @EnumSource(TextCompressionType.class) |
80 | | - // void testCompressionDetectionFromFileName(TextCompressionType type) throws IOException { |
81 | | - // testAutoCompressionDetection( |
82 | | - // "test_auto." |
83 | | - // + getFormatExtension() |
84 | | - // + "." |
85 | | - // + type.fileExtension(), |
86 | | - // type.value()); |
87 | | - // } |
| 69 | + @Disabled // TODO fix dependencies |
| 70 | + @ParameterizedTest(name = "compression = {0}") |
| 71 | + @EnumSource(TextCompressionType.class) |
| 72 | + void testCompression(TextCompressionType compression) throws IOException { |
| 73 | + testCompressionRoundTrip( |
| 74 | + compression.value(), |
| 75 | + String.format( |
| 76 | + "test_compress.%s.%s", getFormatExtension(), compression.fileExtension())); |
| 77 | + } |
| 78 | + |
| 79 | + @Disabled // TODO fix dependencies |
| 80 | + @ParameterizedTest(name = "compression = {0}") |
| 81 | + @EnumSource(TextCompressionType.class) |
| 82 | + void testCompressionDetectionFromFileName(TextCompressionType type) throws IOException { |
| 83 | + testAutoCompressionDetection( |
| 84 | + "test_auto." + getFormatExtension() + "." + type.fileExtension(), type.value()); |
| 85 | + } |
88 | 86 |
|
89 | 87 | @Test |
90 | 88 | void testUnsupportedCompressionFormat() throws IOException { |
|
0 commit comments