From 304293a46e66ba27b6b38bbc2fef63743f78d598 Mon Sep 17 00:00:00 2001 From: Paul Rogers Date: Mon, 28 Jan 2019 22:04:31 -0800 Subject: DRILL-7024: Refactor ColumnWriter to simplify type-conversion shim DRILL-7006 added a type conversion "shim" within the row set framework. Basically, we insert a "shim" column writer that takes data in one form (String, say), and does reader-specific conversions to a target format (INT, say). The code works fine, but the shim class ends up needing to override a bunch of methods which it then passes along to the base writer. This PR refactors the code so that the conversion shim is simpler. closes #1633 --- .../drill/exec/physical/impl/scan/project/TestNullColumnLoader.java | 3 +++ 1 file changed, 3 insertions(+) (limited to 'exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/project/TestNullColumnLoader.java') diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/project/TestNullColumnLoader.java b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/project/TestNullColumnLoader.java index 90b9f7182..a825fad36 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/project/TestNullColumnLoader.java +++ b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/scan/project/TestNullColumnLoader.java @@ -25,6 +25,7 @@ import java.util.List; import org.apache.drill.common.types.TypeProtos.DataMode; import org.apache.drill.common.types.TypeProtos.MajorType; import org.apache.drill.common.types.TypeProtos.MinorType; +import org.apache.drill.categories.RowSetTests; import org.apache.drill.common.types.Types; import org.apache.drill.exec.physical.rowSet.ResultVectorCache; import org.apache.drill.exec.physical.rowSet.impl.NullResultVectorCacheImpl; @@ -37,6 +38,7 @@ import org.apache.drill.test.SubOperatorTest; import org.apache.drill.test.rowSet.RowSet.SingleRowSet; import org.apache.drill.test.rowSet.RowSetComparison; import org.junit.Test; +import org.junit.experimental.categories.Category; /** * Test the mechanism that handles all-null columns during projection. @@ -49,6 +51,7 @@ import org.junit.Test; * any other type and mode. */ +@Category(RowSetTests.class) public class TestNullColumnLoader extends SubOperatorTest { private ResolvedNullColumn makeNullCol(String name, MajorType nullType) { -- cgit v1.2.3