@Test public void testDeleteTablesForSweepSchema() { Set<TableReference> allTableNames = Sets.newHashSet(); allTableNames.add(TableReference.createFromFullyQualifiedName("sweep.priority")); mockery.checking(new Expectations(){{ oneOf(kvs).getAllTableNames(); will(returnValue(allTableNames)); oneOf(kvs).dropTables(allTableNames); oneOf(kvs).getAllTableNames(); }}); Schemas.deleteTablesAndIndexes(SweepSchema.INSTANCE.getLatestSchema(), kvs); }
public static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs) { schema.validate(); kvs.dropTables(getExistingTablesAlsoPresentInSchema(schema, kvs)); }
Schemas { public static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs) { schema.validate(); kvs.dropTables(getExistingTablesAlsoPresentInSchema(schema, kvs)); } }
Schemas { public static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs) { schema.validate(); kvs.dropTables(getExistingTablesAlsoPresentInSchema(schema, kvs)); } private  Schemas(); }
Schemas { public static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs) { schema.validate(); kvs.dropTables(getExistingTablesAlsoPresentInSchema(schema, kvs)); } private  Schemas(); static TableReference appendIndexSuffix(String indexName, IndexDefinition definition); static void createIndices(KeyValueService kvs,
            Map<TableReference, IndexDefinition> fullIndexNameToDefinition); static void createTable(KeyValueService kvs, TableReference tableRef, TableDefinition definition); static void createTable(Schema schema, KeyValueService kvs, TableReference tableRef); static void createTables(KeyValueService kvs, Map<TableReference, TableDefinition>  tableRefToDefinition); static String getTableReferenceString(String tableName, Namespace namespace); static boolean isTableNameValid(String tableName); static void createTablesAndIndexes(Schema schema, KeyValueService kvs); static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs); static void truncateTablesAndIndexes(Schema schema, KeyValueService kvs); }
Schemas { public static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs) { schema.validate(); kvs.dropTables(getExistingTablesAlsoPresentInSchema(schema, kvs)); } private  Schemas(); static TableReference appendIndexSuffix(String indexName, IndexDefinition definition); static void createIndices(KeyValueService kvs,
            Map<TableReference, IndexDefinition> fullIndexNameToDefinition); static void createTable(KeyValueService kvs, TableReference tableRef, TableDefinition definition); static void createTable(Schema schema, KeyValueService kvs, TableReference tableRef); static void createTables(KeyValueService kvs, Map<TableReference, TableDefinition>  tableRefToDefinition); static String getTableReferenceString(String tableName, Namespace namespace); static boolean isTableNameValid(String tableName); static void createTablesAndIndexes(Schema schema, KeyValueService kvs); static void deleteTablesAndIndexes(Schema schema, KeyValueService kvs); static void truncateTablesAndIndexes(Schema schema, KeyValueService kvs);  }