@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, performFlush
private 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
StoreFlusher
flushSnapshot
in class StoreFlusher
snapshot
- Memstore snapshot.cacheFlushSeqNum
- Log cache flush sequence number.status
- Task that represents the flush operation and may be updated with status.IOException
private StripeMultiFileWriter.WriterFactory createWriterFactory(TimeRangeTracker tracker, long kvCount)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.