@Test public void testStartRefresherWithBadZNRecord() throws Exception { writeToHelix("BAD ZNRECORD"); storageUsageRefresher = new HelixStorageUsageRefresher(mockHelixStore, null, storageQuotaConfig); Map<String, Map<String, Long>> emptyMap = storageUsageRefresher.getContainerStorageUsage(); assertTrue(emptyMap.equals(Collections.EMPTY_MAP)); }
@Override public Map<String, Map<String, Long>> getContainerStorageUsage() { return Collections.unmodifiableMap(containerStorageUsageRef.get()); }
HelixStorageUsageRefresher implements StorageUsageRefresher { @Override public Map<String, Map<String, Long>> getContainerStorageUsage() { return Collections.unmodifiableMap(containerStorageUsageRef.get()); } }
HelixStorageUsageRefresher implements StorageUsageRefresher { @Override public Map<String, Map<String, Long>> getContainerStorageUsage() { return Collections.unmodifiableMap(containerStorageUsageRef.get()); } HelixStorageUsageRefresher(HelixPropertyStore<ZNRecord> helixStore, ScheduledExecutorService scheduler,
      StorageQuotaConfig config); }
HelixStorageUsageRefresher implements StorageUsageRefresher { @Override public Map<String, Map<String, Long>> getContainerStorageUsage() { return Collections.unmodifiableMap(containerStorageUsageRef.get()); } HelixStorageUsageRefresher(HelixPropertyStore<ZNRecord> helixStore, ScheduledExecutorService scheduler,
      StorageQuotaConfig config); @Override Map<String, Map<String, Long>> getContainerStorageUsage(); @Override void registerListener(Listener cb); }
HelixStorageUsageRefresher implements StorageUsageRefresher { @Override public Map<String, Map<String, Long>> getContainerStorageUsage() { return Collections.unmodifiableMap(containerStorageUsageRef.get()); } HelixStorageUsageRefresher(HelixPropertyStore<ZNRecord> helixStore, ScheduledExecutorService scheduler,
      StorageQuotaConfig config); @Override Map<String, Map<String, Long>> getContainerStorageUsage(); @Override void registerListener(Listener cb); static final String AGGREGATED_CONTAINER_STORAGE_USAGE_PATH; static final String VALID_SIZE_FILED_NAME; }