From 1a978fe5252d1b2b61f045da7c06d847ad4ca41a Mon Sep 17 00:00:00 2001 From: fjy Date: Sun, 12 May 2013 15:26:19 -0700 Subject: [PATCH] fix predicates --- .../com/metamx/druid/coordination/ServerManager.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/server/src/main/java/com/metamx/druid/coordination/ServerManager.java b/server/src/main/java/com/metamx/druid/coordination/ServerManager.java index 00721d042ad..dceb3b9fafa 100644 --- a/server/src/main/java/com/metamx/druid/coordination/ServerManager.java +++ b/server/src/main/java/com/metamx/druid/coordination/ServerManager.java @@ -20,7 +20,7 @@ package com.metamx.druid.coordination; 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.metamx.common.ISE; import com.metamx.common.guava.FunctionalIterable; @@ -260,14 +260,7 @@ public class ServerManager implements QuerySegmentWalker } ) .filter( - new Predicate>() - { - @Override - public boolean apply(@Nullable QueryRunner input) - { - return (input != null); - } - } + Predicates.>notNull() ); return new FinalizeResultsQueryRunner(toolChest.mergeResults(factory.mergeRunners(exec, adapters)), toolChest);