22 #ifndef Hypertable_RangeServer_CellStoreV0_h
23 #define Hypertable_RangeServer_CellStoreV0_h
66 const String &end_row, int32_t fd, int64_t file_length,
97 std::lock_guard<std::mutex> lock(
m_mutex);
102 std::lock_guard<std::mutex> lock(
m_mutex);
118 typedef std::map<SerializedKey, uint32_t>
IndexMap;
153 #endif // Hypertable_RangeServer_CellStoreV0_h
Abstract base class for cell store trailer.
virtual void close(int fd, DispatchHandler *handler)=0
Closes a file asynchronously.
bool restricted_range() override
Returns true if the cellstore was opened with a restricted range.
Abstract base class for persistent cell lists (ones that are stored on disk).
uint32_t m_outstanding_appends
Abstract base class for a filesystem.
std::string String
A String is simply a typedef to std::string.
CellStoreTrailer * get_trailer() override
Return a pointer to the trailer object for this cell store.
float compression_ratio() override
Returns block compression ratio of this cell store.
A Bloom Filter implementation.
BlockCompressionCodec * create_block_compression_codec() override
Creates a block compression codec suitable for decompressing the cell store's blocks.
size_t bloom_filter_size() override
Return Bloom filter size.
CellStoreV0(Filesystem *filesys)
int get_file_id() override
Returns a unique identifier which identifies the underlying file for caching purposes.
void add_index_entry(const SerializedKey key, uint32_t offset)
uint32_t m_uncompressed_blocksize
CellStoreBlockIndexArray< uint32_t > m_index_map32
Scan context information.
Declarations for BlockCompressionCodec.
DispatchHandlerSynchronizer m_sync_handler
void create(const char *fname, size_t max_entries, PropertiesPtr &props, const TableIdentifier *table_id=0) override
Creates a new cell store.
A dynamic, resizable and reference counted memory buffer.
std::vector< String > Args
Compression codec argument vector.
int64_t get_blocksize() override
Returns the block size used for this cell store.
A class managing one or more serializable ByteStrings.
bool may_contain(const void *ptr, size_t len)
Declarations for CellStore.
A dynamic, resizable memory buffer.
uint64_t disk_usage() override
Returns the disk used by this cell store.
BloomFilterItems * m_bloom_filter_items
CellStoreTrailerV0 m_trailer
size_t size()
Getter for the bloom filter size.
std::shared_ptr< Properties > PropertiesPtr
BloomFilterMode
Enumeration for bloom filter modes.
void display_block_info() override
Displays block information to stdout.
uint32_t m_max_approx_items
BlockCompressionCodec::Args m_compressor_args
A HashSet optimized for blobs.
uint64_t purge_indexes() override
Purges bloom filter and block indexes.
DispatchHandler class used to synchronize with response messages.
int64_t bloom_filter_memory_used() override
Returns the amount of memory consumed by the bloom filter.
std::map< SerializedKey, uint32_t > IndexMap
BloomFilterMode m_bloom_filter_mode
void finalize(TableIdentifier *table_identifier) override
Finalizes the creation of a cell store, by writing block index and metadata trailer.
A HashSet for storing and looking up blobs efficiently.
uint32_t fix_index_offset
BlockCompressionCodec * m_compressor
uint16_t block_header_format() override
std::string & get_filename() override
Pathname of cell store file.
Abstract base class for server protocol drivers.
Provides access to internal components of opaque key.
void open(const String &fname, const String &start_row, const String &end_row, int32_t fd, int64_t file_length, CellStoreTrailer *trailer) override
Opens a cell store with possibly a restricted view.
CellListScannerPtr create_scanner(ScanContext *scan_ctx) override
Creates a scanner on this cell list.
void add(const Key &key, const ByteString value) override
Inserts a key/value pair into the cell list.
int32_t get_fd() override
Returns the open file descriptor for the CellStore file.
int64_t block_index_memory_used() override
Returns the amount of memory consumed by the block index.
void create_bloom_filter(bool is_approx=false)
bool may_contain(const String &key)
BloomFilter * m_bloom_filter
DynamicBuffer m_fix_index_buffer
std::shared_ptr< CellListScanner > CellListScannerPtr
DynamicBuffer m_var_index_buffer
virtual void open(const String &name, uint32_t flags, DispatchHandler *handler)=0
Opens a file asynchronously.
int64_t get_total_entries() override
Returns the number of key/value pairs in the cell store.
A space-efficent probabilistic set for membership test, false postives are possible, but false negatives are not.
uint32_t m_memory_consumed
int32_t reopen_fd() override
Closes and reopens the underlying CellStore file.
int64_t end_of_last_block() override
Returns the offset of the end of the last block in the cell store.
BlobHashSet BloomFilterItems
float m_uncompressed_data
Declarations for DispatchHandlerSynchronizer.
Abstract base class for block compression codecs.
Abstract base class for a filesystem.
Declarations for CellStoreBlockIndexArray.