src/java/org/apache/cassandra/service/StorageService.java
/**
     * Flush all memtables for a table and column families.
     * @param tableName
     * @param columnFamilies
     * @throws IOException
     */
Flush all memtables for a table and column families.
@param tableName
@param columnFamilies
@throws IOException
Flush all memtables for a table and column families . @param tableName @param columnFamilies @throws IOException
@Override
    public void forceTableFlush(final String tableName, final String... columnFamilies)
                throws IOException, ExecutionException, InterruptedException
    {
        for (ColumnFamilyStore cfStore : getValidColumnFamilies(tableName, columnFamilies))
        {
            logger_.debug("Forcing flush on keyspace " + tableName + ", CF " + cfStore.getColumnFamilyName());
            cfStore.forceBlockingFlush();
        }
    }
@ Override public void forceTableFlush ( final String tableName , final String ... columnFamilies ) throws IOException , ExecutionException , InterruptedException { for ( ColumnFamilyStore cfStore : getValidColumnFamilies ( tableName , columnFamilies ) ) { logger_ . debug ( "Forcing flush on keyspace " + tableName + ", CF " + cfStore . getColumnFamilyName ( ) ) ; cfStore . forceBlockingFlush ( ) ; } }
Flush all memtables for a table and column families.
Flush all memtables for a table and column families .