@DataProvider(name="test-hdfs-extractor")
public static Object[][] data() {
List<Object[]> parameters = new ArrayList<Object[]>();
for (Class<?> compressionClass : new Class<?>[]{null, DefaultCodec.class, BZip2Codec.class}) {
for (Object outputFileType : new Object[]{TEXT_FILE, SEQUENCE_FILE}) {
parameters.add(new Object[]{outputFileType, compressionClass});
}
}
return parameters.toArray(new Object[0][]);
}
TestExtractor.java 文件源码
java
阅读 24
收藏 0
点赞 0
评论 0
项目:sqoop-on-spark
作者:
评论列表
文章目录