Add Hive file format test for TextFile
@@ -122,6 +122,20 @@ public class TestHiveFileFormats
"Timezone not configured correctly. Add -Duser.timezone=Asia/Katmandu to your JVM arguments");
}
+ @Test(dataProvider = "rowCount")
+ public void testTextFile(int rowCount)
+ throws Exception
+ {
+ List<TestColumn> testColumns = TEST_COLUMNS.stream()
+ .filter(column -> !column.getName().equals("t_map_null_key_complex_key_value"))
+ .collect(toList());
+
+ assertThatFileFormat(TEXTFILE)
+ .withColumns(testColumns)
+ .withRowsCount(rowCount)
+ .isReadableByRecordCursor(new GenericHiveRecordCursorProvider(HDFS_ENVIRONMENT));
+ }
+
@Test(dataProvider = "rowCount")
public void testRCText(int rowCount)
throws Exception
