import cascading.operation.Filter; //导入依赖的package包/类
private void applyFilter(Filter<?> filter) {
    switch (filterType) {
    case IN:
        eachHelper.filterIn(filter);
        break;
    case OUT:
        eachHelper.filterOut(filter);
        break;
    }
}
 

import cascading.operation.Filter; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public void filterOut(Filter filter) {
    pipeWrapper.set(new Each(pipeWrapper.get(), argumentSelector, filter));
}
 

import cascading.operation.Filter; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
@Override
public void filterIn(Filter filter) {
    filterOut(new Not(filter));
}