FilterData.java 文件源码

java
阅读 29 收藏 0 点赞 0 评论 0

项目:incubator-pirk 作者:
@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;
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号