@Test public void testDestroyForSuccessfulJob() { DestroyerContext context = new DestroyerContext(null, true, null); when(KiteDatasetExecutor.listTemporaryDatasetUris(toJobConfig.toJobConfig.uri)) .thenReturn(expectedUris); destroyer.destroy(context, linkConfig, toJobConfig); for (String uri : expectedUris) { verify(executorMock, times(1)).mergeDataset(uri); } }
@Override public void destroy(DestroyerContext context, LinkConfiguration linkConfig, ToJobConfiguration toJobConfig) { LOG.info("Running Kite connector destroyer"); String uri = ConfigUtil.buildDatasetUri( linkConfig.linkConfig, toJobConfig.toJobConfig); if (ConfigUtil.isHBaseJob(toJobConfig.toJobConfig)) { destroyHBaseJob(context, uri, toJobConfig); } else { destroyHdfsJob(context, uri, toJobConfig); } }
KiteToDestroyer extends Destroyer<LinkConfiguration,
    ToJobConfiguration> { @Override public void destroy(DestroyerContext context, LinkConfiguration linkConfig, ToJobConfiguration toJobConfig) { LOG.info("Running Kite connector destroyer"); String uri = ConfigUtil.buildDatasetUri( linkConfig.linkConfig, toJobConfig.toJobConfig); if (ConfigUtil.isHBaseJob(toJobConfig.toJobConfig)) { destroyHBaseJob(context, uri, toJobConfig); } else { destroyHdfsJob(context, uri, toJobConfig); } } }
KiteToDestroyer extends Destroyer<LinkConfiguration,
    ToJobConfiguration> { @Override public void destroy(DestroyerContext context, LinkConfiguration linkConfig, ToJobConfiguration toJobConfig) { LOG.info("Running Kite connector destroyer"); String uri = ConfigUtil.buildDatasetUri( linkConfig.linkConfig, toJobConfig.toJobConfig); if (ConfigUtil.isHBaseJob(toJobConfig.toJobConfig)) { destroyHBaseJob(context, uri, toJobConfig); } else { destroyHdfsJob(context, uri, toJobConfig); } }  }
KiteToDestroyer extends Destroyer<LinkConfiguration,
    ToJobConfiguration> { @Override public void destroy(DestroyerContext context, LinkConfiguration linkConfig, ToJobConfiguration toJobConfig) { LOG.info("Running Kite connector destroyer"); String uri = ConfigUtil.buildDatasetUri( linkConfig.linkConfig, toJobConfig.toJobConfig); if (ConfigUtil.isHBaseJob(toJobConfig.toJobConfig)) { destroyHBaseJob(context, uri, toJobConfig); } else { destroyHdfsJob(context, uri, toJobConfig); } }  @Override void destroy(DestroyerContext context,
      LinkConfiguration linkConfig, ToJobConfiguration toJobConfig); }
KiteToDestroyer extends Destroyer<LinkConfiguration,
    ToJobConfiguration> { @Override public void destroy(DestroyerContext context, LinkConfiguration linkConfig, ToJobConfiguration toJobConfig) { LOG.info("Running Kite connector destroyer"); String uri = ConfigUtil.buildDatasetUri( linkConfig.linkConfig, toJobConfig.toJobConfig); if (ConfigUtil.isHBaseJob(toJobConfig.toJobConfig)) { destroyHBaseJob(context, uri, toJobConfig); } else { destroyHdfsJob(context, uri, toJobConfig); } }  @Override void destroy(DestroyerContext context,
      LinkConfiguration linkConfig, ToJobConfiguration toJobConfig);  }