基于apache pig中的条件加载数据

nx7onnlm  于 2021-06-03  发布在  Hadoop
关注(0)|答案(1)|浏览(307)

问题陈述-我想检查xyz相关列的值是否为偶数,然后加载文件的前10个字段(1-10),如果不是,则加载另10个字段(11-20)。
关系xyz 123
关系 a b c d e f g h i j k l m n o p r s t
如果123是偶数,那么关系pqr应该有a-j或其他明智的k-t
有人能帮忙吗。

r1zhe5dt

r1zhe5dt1#

您应该编写一个存储函数来实现这一点。
参见csvexcelstorage的实现http://svn.apache.org/repos/asf/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/csvexcelstorage.java 例如。

相关问题