@Test public void testRun() throws IOException { tableService.start(); verify(mockSchedulerService).scheduleTask(tableService); tableService.run(); assertTrue(tableService.completionFuture().isDone()); verify(mockDataStore).createTable("table1"); verify(mockDataStore).createTable("table2"); verify(mockDataStore).createTable("table3"); verifyNoMoreInteractions(mockDataStore, mockSchedulerService); }
@Override public void run() { String oldName = Thread.currentThread().getName(); Thread.currentThread().setName("TSDR HBase Data Store CreateTableTask"); try { createTables(); } finally { Thread.currentThread().setName(oldName); } }
CreateTableTask implements Runnable { @Override public void run() { String oldName = Thread.currentThread().getName(); Thread.currentThread().setName("TSDR HBase Data Store CreateTableTask"); try { createTables(); } finally { Thread.currentThread().setName(oldName); } } }
CreateTableTask implements Runnable { @Override public void run() { String oldName = Thread.currentThread().getName(); Thread.currentThread().setName("TSDR HBase Data Store CreateTableTask"); try { createTables(); } finally { Thread.currentThread().setName(oldName); } } CreateTableTask(HBaseDataStore dataStore, List<String> pendingTableNames, SchedulerService schedulerService,
            long retryInterval); }
CreateTableTask implements Runnable { @Override public void run() { String oldName = Thread.currentThread().getName(); Thread.currentThread().setName("TSDR HBase Data Store CreateTableTask"); try { createTables(); } finally { Thread.currentThread().setName(oldName); } } CreateTableTask(HBaseDataStore dataStore, List<String> pendingTableNames, SchedulerService schedulerService,
            long retryInterval); @Override void run(); }
CreateTableTask implements Runnable { @Override public void run() { String oldName = Thread.currentThread().getName(); Thread.currentThread().setName("TSDR HBase Data Store CreateTableTask"); try { createTables(); } finally { Thread.currentThread().setName(oldName); } } CreateTableTask(HBaseDataStore dataStore, List<String> pendingTableNames, SchedulerService schedulerService,
            long retryInterval); @Override void run();  }