Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix predicates

This commit is contained in:
fjy 2013-05-12 15:26:19 -07:00
parent bcfeac2d8c
commit 1a978fe525
1 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/main/java/com/metamx/druid/coordination/ServerManager.java
View File

@ -20,7 +20,7 @@
package com.metamx.druid.coordination; package com.metamx.druid.coordination;
import com.google.common.base.Function; import com.google.common.base.Function;
import com.google.common.base.Predicate; import com.google.common.base.Predicates;
import com.google.common.collect.Ordering; import com.google.common.collect.Ordering;
import com.metamx.common.ISE; import com.metamx.common.ISE;
import com.metamx.common.guava.FunctionalIterable; import com.metamx.common.guava.FunctionalIterable;
@ -260,14 +260,7 @@ public class ServerManager implements QuerySegmentWalker
} }
) )
.filter( .filter(
new Predicate<QueryRunner<T>>() Predicates.<QueryRunner<T>>notNull()
{
@Override
public boolean apply(@Nullable QueryRunner<T> input)
{
return (input != null);
}
}
); );
return new FinalizeResultsQueryRunner<T>(toolChest.mergeResults(factory.mergeRunners(exec, adapters)), toolChest); return new FinalizeResultsQueryRunner<T>(toolChest.mergeResults(factory.mergeRunners(exec, adapters)), toolChest);