blueflood-core/src/main/java/com/rackspacecloud/blueflood/inputs/processors/TokenDiscoveryWriter.java
static List<Locator> getLocators(final List<List<IMetric>> input) {

        //converting list of lists of metrics to flat list of locators that are not current.
        return input.stream()
                    .flatMap(List::stream)
                    .map(IMetric::getLocator)
                    .filter(locator -> !LocatorCache.getInstance().isLocatorCurrentInTokenDiscoveryLayer(locator))
                    .collect(toList());
    }
static List<Locator> getLocators(final List<List<IMetric>> input) {

        //converting list of lists of metrics to flat list of locators that are not current.
        return input.stream()
                    .flatMap(List::stream)
                    .map(IMetric::getLocator)
                    .filter(locator -> !LocatorCache.getInstance().isLocatorCurrentInTokenDiscoveryLayer(locator))
                    .collect(toList());
    }
static List < Locator > getLocators ( final List < List < IMetric > > input ) { //converting list of lists of metrics to flat list of locators that are not current. return input . stream ( ) . flatMap ( List :: stream ) . map ( IMetric :: getLocator ) . filter ( locator -> ! LocatorCache . getInstance ( ) . isLocatorCurrentInTokenDiscoveryLayer ( locator ) ) . collect ( toList ( ) ) ; }
Get all {@link Locator}'s corresponding to the metrics which are not current.

@param input
@return
Get all { @link Locator } s corresponding to the metrics which are not current .