test_class.declarator: metaStore
test_class.modifier: private
test_class.original_string: private MetaStore metaStore;
test_class.type: MetaStore
test_class.var_name: metaStore
test_class.declarator: cluster
test_class.modifier: protected
test_class.original_string: protected MiniDFSCluster cluster;
test_class.type: MiniDFSCluster
test_class.var_name: cluster
test_class.declarator: dfs
test_class.modifier: protected
test_class.original_string: protected DistributedFileSystem dfs;
test_class.type: DistributedFileSystem
test_class.var_name: dfs
test_class.declarator: dfsClient
test_class.modifier: protected
test_class.original_string: protected DFSClient dfsClient;
test_class.type: DFSClient
test_class.var_name: dfsClient
test_class.declarator: conf
test_class.modifier: private
test_class.original_string: private Configuration conf;
test_class.type: Configuration
test_class.var_name: conf
test_class.declarator: scheduledExecutorService
test_class.original_string: ScheduledExecutorService scheduledExecutorService;
test_class.type: ScheduledExecutorService
test_class.var_name: scheduledExecutorService
test_class.declarator: fetcher
test_class.original_string: DataNodeInfoFetcher fetcher;
test_class.type: DataNodeInfoFetcher
test_class.var_name: fetcher
test_class.file: smart-hadoop-support/smart-hadoop/src/test/java/org/smartdata/hdfs/metric/fetcher/TestDataNodeInfoFetcher.java
test_class.identifier: TestDataNodeInfoFetcher
test_class.superclass: extends TestDaoUtil
test_case.body: @Test
    public void testDataNodeInfoFetcher() throws IOException, InterruptedException,
        MissingEventsException, MetaStoreException {
      fetcher.start();
      while (!fetcher.isFetchFinished()) {
        Thread.sleep(1000);
      }
      Assert.assertEquals(2,metaStore.getAllDataNodeInfo().size());
    }
test_case.class_method_signature: TestDataNodeInfoFetcher.testDataNodeInfoFetcher()
test_case.full_signature: @Test public void testDataNodeInfoFetcher()
test_case.identifier: testDataNodeInfoFetcher
test_case.invocations: start isFetchFinished sleep assertEquals size getAllDataNodeInfo
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testDataNodeInfoFetcher()
focal_class.declarator: updateInterval
focal_class.modifier: private
focal_class.original_string: private long updateInterval;
focal_class.type: long
focal_class.var_name: updateInterval
focal_class.declarator: client
focal_class.modifier: private final
focal_class.original_string: private final DFSClient client;
focal_class.type: DFSClient
focal_class.var_name: client
focal_class.declarator: metaStore
focal_class.modifier: private final
focal_class.original_string: private final MetaStore metaStore;
focal_class.type: MetaStore
focal_class.var_name: metaStore
focal_class.declarator: scheduledExecutorService
focal_class.modifier: private final
focal_class.original_string: private final ScheduledExecutorService scheduledExecutorService;
focal_class.type: ScheduledExecutorService
focal_class.var_name: scheduledExecutorService
focal_class.declarator: dnStorageReportProcTaskFuture
focal_class.modifier: private
focal_class.original_string: private ScheduledFuture dnStorageReportProcTaskFuture;
focal_class.type: ScheduledFuture
focal_class.var_name: dnStorageReportProcTaskFuture
focal_class.declarator: conf
focal_class.modifier: private
focal_class.original_string: private Configuration conf;
focal_class.type: Configuration
focal_class.var_name: conf
focal_class.declarator: procTask
focal_class.modifier: private
focal_class.original_string: private DataNodeInfoFetchTask procTask;
focal_class.type: DataNodeInfoFetchTask
focal_class.var_name: procTask
focal_class.declarator: LOG =
        LoggerFactory.getLogger(DataNodeInfoFetcher.class)
focal_class.modifier: public static final
focal_class.original_string: public static final Logger LOG =
        LoggerFactory.getLogger(DataNodeInfoFetcher.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.file: smart-hadoop-support/smart-hadoop/src/main/java/org/smartdata/hdfs/metric/fetcher/DataNodeInfoFetcher.java
focal_class.identifier: DataNodeInfoFetcher
focal_class.class_method_signature: DataNodeInfoFetcher.DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_class.full_signature: public  DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_class.identifier: DataNodeInfoFetcher
focal_class.modifiers: public
focal_class.parameters: (DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_class.signature:  DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_class.class_method_signature: DataNodeInfoFetcher.start()
focal_class.full_signature: public void start()
focal_class.identifier: start
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void start()
focal_class.class_method_signature: DataNodeInfoFetcher.isFetchFinished()
focal_class.full_signature: public boolean isFetchFinished()
focal_class.identifier: isFetchFinished
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isFetchFinished()
focal_class.class_method_signature: DataNodeInfoFetcher.stop()
focal_class.full_signature: public void stop()
focal_class.identifier: stop
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stop()
focal_method.body: 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;
    }
focal_method.class_method_signature: DataNodeInfoFetcher.DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_method.full_signature: public  DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_method.identifier: DataNodeInfoFetcher
focal_method.modifiers: public
focal_method.parameters: (DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)
focal_method.signature:  DataNodeInfoFetcher(DFSClient client, MetaStore metaStore,
                               ScheduledExecutorService service, Configuration conf)