Package org.apache.cassandra.notifications

Class SSTableAddedNotification

java.lang.Object

org.apache.cassandra.notifications.SSTableAddedNotification

All Implemented Interfaces:

INotification

public class SSTableAddedNotification
extends Object
implements INotification

Notification sent after SSTables are added to their ColumnFamilyStore.

Field Summary

Fields

Modifier and Type	Field	Description
final Iterable<SSTableReader>	added	The added SSTables

Constructor Summary

Constructors

Constructor	Description
SSTableAddedNotification(Iterable<SSTableReader> added, Memtable memtable)	Creates a new SSTableAddedNotification for the specified SSTables and optional memtable.

Method Summary

Modifier and Type	Method	Description
Optional<Memtable>	memtable()	Returns the memtable from which the tables come when they have been added due to a memtable flush.

Methods inherited from class java.lang.Object

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

Field Details

added

public final Iterable<SSTableReader> added

The added SSTables

Constructor Details

SSTableAddedNotification

public SSTableAddedNotification(Iterable<SSTableReader> added,
 @Nullable
 Memtable memtable)

Creates a new SSTableAddedNotification for the specified SSTables and optional memtable.

Parameters:

added - the added SSTables

memtable - the memtable from which the tables come when they have been added due to a memtable flush, or null if they don't come from a flush

Method Details

memtable

public Optional<Memtable> memtable()

Returns the memtable from which the tables come when they have been added due to a memtable flush. If not, an empty Optional should be returned.

Returns:

the origin memtable in case of a flush, Optional.empty() otherwise