Package org.apache.cassandra.db.memtable

Class Flushing

java.lang.Object

org.apache.cassandra.db.memtable.Flushing

public class Flushing
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Flushing.FlushRunnable

Method Summary

Modifier and Type	Method	Description
static Throwable	abortRunnables(List<Flushing.FlushRunnable> runnables, Throwable t)
static SSTableMultiWriter	createFlushWriter(ColumnFamilyStore cfs, Memtable.FlushablePartitionSet<?> flushSet, LifecycleTransaction txn, Descriptor descriptor, long partitionCount)
static List<Flushing.FlushRunnable>	flushRunnables(ColumnFamilyStore cfs, Memtable memtable, LifecycleTransaction txn)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

flushRunnables

public static List<Flushing.FlushRunnable> flushRunnables(ColumnFamilyStore cfs,
 Memtable memtable,
 LifecycleTransaction txn)

abortRunnables

public static Throwable abortRunnables(List<Flushing.FlushRunnable> runnables,
 Throwable t)

createFlushWriter

public static SSTableMultiWriter createFlushWriter(ColumnFamilyStore cfs,
 Memtable.FlushablePartitionSet<?> flushSet,
 LifecycleTransaction txn,
 Descriptor descriptor,
 long partitionCount)