org.apache.hadoop.hbase.regionserver

Class StripeStoreFlusher

java.lang.Object

org.apache.hadoop.hbase.regionserver.StoreFlusher

org.apache.hadoop.hbase.regionserver.StripeStoreFlusher

@InterfaceAudience.Private
public class StripeStoreFlusher
extends StoreFlusher

Stripe implementation of StoreFlusher. Flushes files either into L0 file w/o metadata, or into separate striped files, avoiding L0.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StripeStoreFlusher.BoundaryStripeFlushRequest Stripe flush request wrapper based on boundaries.
static class	StripeStoreFlusher.SizeStripeFlushRequest Stripe flush request wrapper based on size.
static class	StripeStoreFlusher.StripeFlushRequest Stripe flush request wrapper that writes a non-striped file.

Field Summary

Fields

Modifier and Type	Field and Description
private Object	flushLock
private static org.slf4j.Logger	LOG
private StripeCompactionPolicy	policy
private StripeCompactionPolicy.StripeInformationProvider	stripes

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

conf, store

Constructor Summary

Constructors

Constructor and Description
StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store, StripeCompactionPolicy policy, StripeStoreFileManager stripes)

Method Summary

Modifier and Type	Method and Description
private AbstractMultiFileWriter.WriterFactory	createWriterFactory(MemStoreSnapshot snapshot, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
List<org.apache.hadoop.fs.Path>	flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, 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 Detail

LOG

private static final org.slf4j.Logger LOG

flushLock

private final Object flushLock

policy

private final StripeCompactionPolicy policy

stripes

private final StripeCompactionPolicy.StripeInformationProvider stripes

Constructor Detail

StripeStoreFlusher

public StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf,
                          HStore store,
                          StripeCompactionPolicy policy,
                          StripeStoreFileManager stripes)

Method Detail

flushSnapshot

public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot,
                                                     long cacheFlushSeqNum,
                                                     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.

cacheFlushSeqNum - 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

createWriterFactory

private AbstractMultiFileWriter.WriterFactory createWriterFactory(MemStoreSnapshot snapshot,
                                                                  Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)