@Test(expected = IllegalStateException.class) public void testAttributesMissing() { expect(attributeStore.getHostAttributes("a")).andReturn(Optional.absent()); control.replay(); aggregate(task("1", "a")).getAggregates(); }
@VisibleForTesting Multiset<Pair<String, String>> getAggregates() { return aggregate.get(); }
AttributeAggregate { @VisibleForTesting Multiset<Pair<String, String>> getAggregates() { return aggregate.get(); } }
AttributeAggregate { @VisibleForTesting Multiset<Pair<String, String>> getAggregates() { return aggregate.get(); } private  AttributeAggregate(Supplier<Multiset<Pair<String, String>>> aggregate); }
AttributeAggregate { @VisibleForTesting Multiset<Pair<String, String>> getAggregates() { return aggregate.get(); } private  AttributeAggregate(Supplier<Multiset<Pair<String, String>>> aggregate); static AttributeAggregate getJobActiveState(
      final StoreProvider storeProvider,
      final IJobKey jobKey); long getNumTasksWithAttribute(String name, String value); @Override boolean equals(Object o); @Override int hashCode(); }
AttributeAggregate { @VisibleForTesting Multiset<Pair<String, String>> getAggregates() { return aggregate.get(); } private  AttributeAggregate(Supplier<Multiset<Pair<String, String>>> aggregate); static AttributeAggregate getJobActiveState(
      final StoreProvider storeProvider,
      final IJobKey jobKey); long getNumTasksWithAttribute(String name, String value); @Override boolean equals(Object o); @Override int hashCode(); @VisibleForTesting
  static final AttributeAggregate EMPTY; }