From ab313005132783be84fe65942ea2ce24652a6a29 Mon Sep 17 00:00:00 2001 From: nishantmonu51 Date: Thu, 5 Jun 2014 23:16:38 +0530 Subject: [PATCH] remove duplicate code --- .../druid/server/coordinator/DruidCoordinator.java | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java index 97c1a3eab61..7cbd3bbcafa 100644 --- a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java +++ b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java @@ -426,19 +426,7 @@ public class DruidCoordinator { Set availableSegments = Sets.newTreeSet(Comparators.inverse(DataSegment.bucketMonthComparator())); - Iterable dataSegments = Iterables.concat( - Iterables.transform( - databaseSegmentManager.getInventory(), - new Function>() - { - @Override - public Iterable apply(DruidDataSource input) - { - return input.getSegments(); - } - } - ) - ); + Iterable dataSegments = getAvailableDataSegments(); for (DataSegment dataSegment : dataSegments) { if (dataSegment.getSize() < 0) {