Package org.apache.hadoop.hbase.regionserver

Class DefaultStoreFlusher

java.lang.Object

org.apache.hadoop.hbase.regionserver.StoreFlusher

org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

Direct Known Subclasses:

DefaultMobStoreFlusher

@Private
public class DefaultStoreFlusher
extends StoreFlusher

Default implementation of StoreFlusher.

Field Summary

Fields

Modifier and Type	Field	Description
private final Object	flushLock
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreFlusher

conf, store

Constructor Summary

Constructors

Constructor	Description
DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)

Method Summary

Modifier and Type	Method	Description
List<org.apache.hadoop.fs.Path>	flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)	Turns a snapshot of memstore into a set of store files.

Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreFlusher

createScanner, createWriter, finalizeWriter, performFlush

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

flushLock

private final Object flushLock

Constructor Details

DefaultStoreFlusher

public DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf,
 HStore store)

Method Details

flushSnapshot

public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot,
 long cacheFlushId,
 MonitoredTask status,
 ThroughputController throughputController,
 FlushLifeCycleTracker tracker,
 Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
                                              throws IOException

Description copied from class: StoreFlusher

Turns a snapshot of memstore into a set of store files.

Specified by:

flushSnapshot in class StoreFlusher

Parameters:

snapshot - Memstore snapshot.

cacheFlushId - Log cache flush sequence number.

status - Task that represents the flush operation and may be updated with status.

throughputController - A controller to avoid flush too fast

Returns:

List of files written. Can be empty; must not be null.

Throws:

IOException