diff --git a/src/main/java/org/apache/cassandra/service/StorageService.java b/src/main/java/org/apache/cassandra/service/StorageService.java index 0477de3..747bb98 100644 --- a/src/main/java/org/apache/cassandra/service/StorageService.java +++ b/src/main/java/org/apache/cassandra/service/StorageService.java @@ -549,6 +549,15 @@ public class StorageService extends NotificationBroadcasterSupport String keyspaceName, String... columnFamilies) throws IOException, ExecutionException, InterruptedException { log(" scrub(boolean disableSnapshot, boolean skipCorrupted, String keyspaceName, String... columnFamilies) throws IOException, ExecutionException, InterruptedException"); + return scrub(disableSnapshot, skipCorrupted, true, keyspaceName, columnFamilies); + } + + @Override + public int scrub(boolean disableSnapshot, boolean skipCorrupted, + boolean checkData, String keyspaceName, String... columnFamilies) + throws IOException, ExecutionException, + InterruptedException { + log(" scrub(boolean disableSnapshot, boolean skipCorrupted, bool checkData, String keyspaceName, String... columnFamilies) throws IOException, ExecutionException, InterruptedException"); MultivaluedMap queryParams = new MultivaluedHashMap(); APIClient.set_bool_query_param(queryParams, "disable_snapshot", disableSnapshot); @@ -1281,16 +1290,6 @@ public class StorageService extends NotificationBroadcasterSupport log(" takeMultipleColumnFamilySnapshot"); } - @Override - public int scrub(boolean disableSnapshot, boolean skipCorrupted, - boolean checkData, String keyspaceName, String... columnFamilies) - throws IOException, ExecutionException, - InterruptedException { - // TODO Auto-generated method stub - log(" scrub()"); - return c.getIntValue(""); - } - @Override public int forceRepairAsync(String keyspace, int parallelismDegree, Collection dataCenters, Collection hosts,