@Test public void testDataNodeInfoFetcher() throws IOException, InterruptedException, MissingEventsException, MetaStoreException { fetcher.start(); while (!fetcher.isFetchFinished()) { Thread.sleep(1000); } Assert.assertEquals(2,metaStore.getAllDataNodeInfo().size()); }
public DataNodeInfoFetcher(DFSClient client, MetaStore metaStore, ScheduledExecutorService service, Configuration conf) { this.client = client; this.metaStore = metaStore; this.scheduledExecutorService = service; this.conf = conf; updateInterval = conf.getInt(SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_KEY, SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_DEFAULT) * 1000; }
DataNodeInfoFetcher { public DataNodeInfoFetcher(DFSClient client, MetaStore metaStore, ScheduledExecutorService service, Configuration conf) { this.client = client; this.metaStore = metaStore; this.scheduledExecutorService = service; this.conf = conf; updateInterval = conf.getInt(SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_KEY, SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_DEFAULT) * 1000; } }
DataNodeInfoFetcher { public DataNodeInfoFetcher(DFSClient client, MetaStore metaStore, ScheduledExecutorService service, Configuration conf) { this.client = client; this.metaStore = metaStore; this.scheduledExecutorService = service; this.conf = conf; updateInterval = conf.getInt(SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_KEY, SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_DEFAULT) * 1000; } DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                             ScheduledExecutorService service, Configuration conf); }
DataNodeInfoFetcher { public DataNodeInfoFetcher(DFSClient client, MetaStore metaStore, ScheduledExecutorService service, Configuration conf) { this.client = client; this.metaStore = metaStore; this.scheduledExecutorService = service; this.conf = conf; updateInterval = conf.getInt(SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_KEY, SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_DEFAULT) * 1000; } DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                             ScheduledExecutorService service, Configuration conf); void start(); boolean isFetchFinished(); void stop(); }
DataNodeInfoFetcher { public DataNodeInfoFetcher(DFSClient client, MetaStore metaStore, ScheduledExecutorService service, Configuration conf) { this.client = client; this.metaStore = metaStore; this.scheduledExecutorService = service; this.conf = conf; updateInterval = conf.getInt(SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_KEY, SmartConfKeys.SMART_STORAGE_INFO_UPDATE_INTERVAL_DEFAULT) * 1000; } DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                             ScheduledExecutorService service, Configuration conf); void start(); boolean isFetchFinished(); void stop(); static final Logger LOG; }