@InterfaceAudience.Private public class MemStoreWrapper extends java.lang.Object
Constructor and Description |
---|
MemStoreWrapper(Context context,
FileSystem fs,
BufferedMutator table,
HColumnDescriptor hcd,
MemStore memstore,
CacheConfig cacheConfig) |
Modifier and Type | Method and Description |
---|---|
void |
addToMemstore(KeyValue kv)
Adds a KeyValue into the memstore.
|
void |
flushMemStore()
Flushes the memstore anyway.
|
void |
setPartitionId(PartitionedMobCompactionRequest.CompactionPartitionId partitionId) |
public MemStoreWrapper(Context context, FileSystem fs, BufferedMutator table, HColumnDescriptor hcd, MemStore memstore, CacheConfig cacheConfig) throws java.io.IOException
java.io.IOException
public void setPartitionId(PartitionedMobCompactionRequest.CompactionPartitionId partitionId)
public void flushMemStore() throws java.io.IOException
java.io.IOException
public void addToMemstore(KeyValue kv) throws java.io.IOException
kv
- The KeyValue to be added.java.io.IOException