@Test public void shouldTruncateSystemTables() throws Exception { atlasDbService.truncateTable("_locks"); TableReference tableToTruncate = TableReference.createWithEmptyNamespace("_locks"); verify(kvs, atLeastOnce()).truncateTable(tableToTruncate); }
@Override public void truncateTable(final String fullyQualifiedTableName) { kvs.truncateTable(getTableRef(fullyQualifiedTableName)); }
AtlasDbServiceImpl implements AtlasDbService { @Override public void truncateTable(final String fullyQualifiedTableName) { kvs.truncateTable(getTableRef(fullyQualifiedTableName)); } }
AtlasDbServiceImpl implements AtlasDbService { @Override public void truncateTable(final String fullyQualifiedTableName) { kvs.truncateTable(getTableRef(fullyQualifiedTableName)); } @Inject  AtlasDbServiceImpl(KeyValueService kvs,
            TransactionManager txManager,
            TableMetadataCache metadataCache); }
AtlasDbServiceImpl implements AtlasDbService { @Override public void truncateTable(final String fullyQualifiedTableName) { kvs.truncateTable(getTableRef(fullyQualifiedTableName)); } @Inject  AtlasDbServiceImpl(KeyValueService kvs,
            TransactionManager txManager,
            TableMetadataCache metadataCache); @Override Set<String> getAllTableNames(); @Override TableMetadata getTableMetadata(String tableName); @Override void createTable(String tableName); @Override TableRowResult getRows(TransactionToken token,
            final TableRowSelection rows); @Override TableCellVal getCells(TransactionToken token,
            final TableCell cells); @Override RangeToken getRange(TransactionToken token,
            final TableRange range); @Override void put(TransactionToken token,
            final TableCellVal data); @Override void delete(TransactionToken token,
            final TableCell cells); @Override void truncateTable(final String fullyQualifiedTableName); @Override TransactionToken startTransaction(); @Override void commit(TransactionToken token); @Override void abort(TransactionToken token); }
AtlasDbServiceImpl implements AtlasDbService { @Override public void truncateTable(final String fullyQualifiedTableName) { kvs.truncateTable(getTableRef(fullyQualifiedTableName)); } @Inject  AtlasDbServiceImpl(KeyValueService kvs,
            TransactionManager txManager,
            TableMetadataCache metadataCache); @Override Set<String> getAllTableNames(); @Override TableMetadata getTableMetadata(String tableName); @Override void createTable(String tableName); @Override TableRowResult getRows(TransactionToken token,
            final TableRowSelection rows); @Override TableCellVal getCells(TransactionToken token,
            final TableCell cells); @Override RangeToken getRange(TransactionToken token,
            final TableRange range); @Override void put(TransactionToken token,
            final TableCellVal data); @Override void delete(TransactionToken token,
            final TableCell cells); @Override void truncateTable(final String fullyQualifiedTableName); @Override TransactionToken startTransaction(); @Override void commit(TransactionToken token); @Override void abort(TransactionToken token);  }