public class HBaseKeyColumnValueStore extends Object implements KeyColumnValueStore
- batching? (consider HTable#batch, HTable#setAutoFlush(false) - tuning HTable#setWriteBufferSize (?) - writing a server-side filter to replace ColumnCountGetFilter, which drops all columns on the row where it reaches its limit. This requires getSlice, currently, to impose its limit on the client side. That obviously won't scale. - RowMutations for combining Puts+Deletes (need a newer HBase than 0.92 for this) - (maybe) fiddle with HTable#setRegionCachePrefetch and/or #prewarmRegionCache
There may be other problem areas. These are just the ones of which I'm aware.
NO_ADDITIONS, NO_DELETIONS
Modifier and Type | Method and Description |
---|---|
void |
acquireLock(StaticBuffer key,
StaticBuffer column,
StaticBuffer expectedValue,
StoreTransaction txh) |
void |
close() |
static org.apache.hadoop.hbase.filter.Filter |
getFilter(SliceQuery query) |
KeyIterator |
getKeys(KeyRangeQuery query,
StoreTransaction txh) |
KeyIterator |
getKeys(SliceQuery query,
StoreTransaction txh) |
String |
getName() |
EntryList |
getSlice(KeySliceQuery query,
StoreTransaction txh) |
Map<StaticBuffer,EntryList> |
getSlice(List<StaticBuffer> keys,
SliceQuery query,
StoreTransaction txh) |
void |
mutate(StaticBuffer key,
List<Entry> additions,
List<StaticBuffer> deletions,
StoreTransaction txh) |
public void close() throws BackendException
close
in interface KeyColumnValueStore
BackendException
public EntryList getSlice(KeySliceQuery query, StoreTransaction txh) throws BackendException
getSlice
in interface KeyColumnValueStore
BackendException
public Map<StaticBuffer,EntryList> getSlice(List<StaticBuffer> keys, SliceQuery query, StoreTransaction txh) throws BackendException
getSlice
in interface KeyColumnValueStore
BackendException
public void mutate(StaticBuffer key, List<Entry> additions, List<StaticBuffer> deletions, StoreTransaction txh) throws BackendException
mutate
in interface KeyColumnValueStore
BackendException
public void acquireLock(StaticBuffer key, StaticBuffer column, StaticBuffer expectedValue, StoreTransaction txh) throws BackendException
acquireLock
in interface KeyColumnValueStore
BackendException
public KeyIterator getKeys(KeyRangeQuery query, StoreTransaction txh) throws BackendException
getKeys
in interface KeyColumnValueStore
BackendException
public String getName()
getName
in interface KeyColumnValueStore
public KeyIterator getKeys(SliceQuery query, StoreTransaction txh) throws BackendException
getKeys
in interface KeyColumnValueStore
BackendException
public static org.apache.hadoop.hbase.filter.Filter getFilter(SliceQuery query)
Copyright © 2012–2020. All rights reserved.