@InterfaceAudience.Private public class StripeStoreFlusher extends StoreFlusher
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
private Object |
flushLock |
private static org.apache.commons.logging.Log |
LOG |
private StripeCompactionPolicy |
policy |
private StripeCompactionPolicy.StripeInformationProvider |
stripes |
conf, store| Constructor and Description |
|---|
StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf,
Store store,
StripeCompactionPolicy policy,
StripeStoreFileManager stripes) |
| Modifier and Type | Method and Description |
|---|---|
private StripeMultiFileWriter.WriterFactory |
createWriterFactory(TimeRangeTracker tracker,
long kvCount) |
List<org.apache.hadoop.fs.Path> |
flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushSeqNum,
MonitoredTask status)
Turns a snapshot of memstore into a set of store files.
|
createScanner, finalizeWriter, performFlushprivate static final org.apache.commons.logging.Log LOG
private final Object flushLock
private final StripeCompactionPolicy policy
private final StripeCompactionPolicy.StripeInformationProvider stripes
public StripeStoreFlusher(org.apache.hadoop.conf.Configuration conf,
Store store,
StripeCompactionPolicy policy,
StripeStoreFileManager stripes)
public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, MonitoredTask status) throws IOException
StoreFlusherflushSnapshot in class StoreFlushersnapshot - Memstore snapshot.cacheFlushSeqNum - Log cache flush sequence number.status - Task that represents the flush operation and may be updated with status.IOExceptionprivate StripeMultiFileWriter.WriterFactory createWriterFactory(TimeRangeTracker tracker, long kvCount)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.