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 KeyColumnValueStoreBackendExceptionpublic EntryList getSlice(KeySliceQuery query, StoreTransaction txh) throws BackendException
getSlice in interface KeyColumnValueStoreBackendExceptionpublic Map<StaticBuffer,EntryList> getSlice(List<StaticBuffer> keys, SliceQuery query, StoreTransaction txh) throws BackendException
getSlice in interface KeyColumnValueStoreBackendExceptionpublic void mutate(StaticBuffer key, List<Entry> additions, List<StaticBuffer> deletions, StoreTransaction txh) throws BackendException
mutate in interface KeyColumnValueStoreBackendExceptionpublic void acquireLock(StaticBuffer key, StaticBuffer column, StaticBuffer expectedValue, StoreTransaction txh) throws BackendException
acquireLock in interface KeyColumnValueStoreBackendExceptionpublic KeyIterator getKeys(KeyRangeQuery query, StoreTransaction txh) throws BackendException
getKeys in interface KeyColumnValueStoreBackendExceptionpublic String getName()
getName in interface KeyColumnValueStorepublic KeyIterator getKeys(SliceQuery query, StoreTransaction txh) throws BackendException
getKeys in interface KeyColumnValueStoreBackendExceptionpublic static org.apache.hadoop.hbase.filter.Filter getFilter(SliceQuery query)
Copyright © 2012–2020. All rights reserved.