@Override
public Boolean call(MapWritable dataElement) throws Exception
{
accum.incNumRecordsReceived(1);
// Perform the filter
boolean passFilter = ((DataFilter) filter).filterDataElement(dataElement, dSchema);
if (passFilter)
{
accum.incNumRecordsAfterFilter(1);
}
else
// false, then we filter out the record
{
accum.incNumRecordsFiltered(1);
}
return passFilter;
}
FilterData.java 文件源码
java
阅读 29
收藏 0
点赞 0
评论 0
项目:incubator-pirk
作者:
评论列表
文章目录