#include <swcdb/ranger/callbacks/RangeQuerySelectUpdating_Serial.h>
Public Types | |
typedef std::shared_ptr< RangeQuerySelectUpdating_Serial > | Ptr |
Public Types inherited from SWC::Ranger::Callback::RangeQuerySelectUpdating | |
typedef std::shared_ptr< RangeQuerySelectUpdating > | Ptr |
Public Types inherited from SWC::Ranger::Callback::RangeQuerySelect | |
typedef std::shared_ptr< RangeQuerySelect > | Ptr |
Public Types inherited from SWC::Ranger::ReqScan | |
enum | Type : uint8_t { QUERY, BLK_PRELOAD, COMPACTION } |
typedef std::shared_ptr< ReqScan > | Ptr |
Public Types inherited from SWC::DB::Cells::ReqScan | |
typedef std::shared_ptr< ReqScan > | Ptr |
Public Types inherited from SWC::Comm::ResponseCallback | |
typedef std::shared_ptr< ResponseCallback > | Ptr |
Private Attributes | |
const DB::Cell::Serial::Value::FieldsUpdaterMap | u_fields |
DB::Cell::Serial::Value::FieldUpdateOpPtrs | opfields_found |
DB::Cell::Serial::Value::FieldUpdateOpPtrs | opfields_missing |
Additional Inherited Members | |
Public Attributes inherited from SWC::Ranger::Callback::RangeQuerySelect | |
RangePtr | range |
DynamicBuffer | cells |
Public Attributes inherited from SWC::Ranger::ReqScan | |
Type | type |
bool | release_block |
uint8_t | readahead |
const uint32_t | blk_size |
void * | block |
Public Attributes inherited from SWC::DB::Cells::ReqScan | |
DB::Specs::Interval | spec |
bool | only_keys |
uint64_t | offset |
Profile | profile |
Protected Attributes inherited from SWC::Comm::ResponseCallback | |
ConnHandlerPtr | m_conn |
Event::Ptr | m_ev |
Definition at line 16 of file RangeQuerySelectUpdating_Serial.h.
typedef std::shared_ptr<RangeQuerySelectUpdating_Serial> SWC::Ranger::Callback::RangeQuerySelectUpdating_Serial::Ptr |
Definition at line 20 of file RangeQuerySelectUpdating_Serial.h.
|
inline |
Definition at line 23 of file RangeQuerySelectUpdating_Serial.h.
References SWC::DB::Cell::Serial::Value::FieldsUpdaterMap::count, SWC::DB::Cells::ReqScan::only_keys, opfields_found, opfields_missing, SWC::Core::Vector< T, SizeT, GROW_SZ >::reserve(), and u_fields.
|
inlinevirtualnoexcept |
Definition at line 44 of file RangeQuerySelectUpdating_Serial.h.
|
inlineoverridevirtual |
Reimplemented from SWC::Ranger::Callback::RangeQuerySelectUpdating.
Definition at line 46 of file RangeQuerySelectUpdating_Serial.h.
References SWC::DB::Cell::Serial::Value::FieldsWriter::add(), SWC::Core::Buffer< T >::base, SWC::DB::Cell::Serial::Value::BYTES, SWC::Core::Vector< T, SizeT, GROW_SZ >::clear(), SWC::Core::Encoder::DEFAULT, SWC::DB::Cell::Serial::Value::DOUBLE, encoder, SWC::Core::BufferDyn< BufferT >::ensure(), SWC::Core::BufferDyn< BufferT >::fill(), SWC::DB::Cell::Serial::Value::FieldsUpdaterMap::find_matching_type_and_id(), SWC::DB::Cell::Serial::Value::FieldsUpdaterMap::get_not_in(), SWC::DB::Cells::Cell::get_value(), SWC::DB::Cell::Serial::Value::INT64, SWC::DB::Cell::Serial::Value::KEY, SWC::DB::Cell::Serial::Value::LIST_BYTES, SWC::DB::Cell::Serial::Value::LIST_INT64, opfields_found, opfields_missing, SWC::Core::Vector< T, SizeT, GROW_SZ >::push_back(), SWC::DB::Cell::Serial::Value::read_type(), SWC::DB::Cells::Cell::set_value(), SWC::Core::Buffer< T >::size, SWC::DB::Cells::ReqScan::spec, u_fields, and SWC::DB::Specs::Interval::updating.
|
private |
Definition at line 158 of file RangeQuerySelectUpdating_Serial.h.
Referenced by RangeQuerySelectUpdating_Serial(), and update_cell_value().
|
private |
Definition at line 159 of file RangeQuerySelectUpdating_Serial.h.
Referenced by RangeQuerySelectUpdating_Serial(), and update_cell_value().
|
private |
Definition at line 157 of file RangeQuerySelectUpdating_Serial.h.
Referenced by RangeQuerySelectUpdating_Serial(), and update_cell_value().