OmniSciDB
a5dc49c757
|
#include <Execute.h>
Public Types | |
using | FragmentInfoType = Fragmenter_Namespace::FragmentInfo |
using | Callback = std::function< void(const UpdateLogForFragment &, TableUpdateMetadata &)> |
Public Member Functions | |
UpdateLogForFragment (FragmentInfoType const &fragment_info, size_t const, const std::shared_ptr< ResultSet > &rs) | |
std::vector< TargetValue > | getEntryAt (const size_t index) const override |
std::vector< TargetValue > | getTranslatedEntryAt (const size_t index) const override |
size_t const | getRowCount () const override |
StringDictionaryProxy * | getLiteralDictionary () const override |
size_t const | getEntryCount () const override |
size_t const | getFragmentIndex () const |
FragmentInfoType const & | getFragmentInfo () const |
decltype(FragmentInfoType::physicalTableId) const | getPhysicalTableId () const |
decltype(FragmentInfoType::fragmentId) const | getFragmentId () const |
SQLTypeInfo | getColumnType (const size_t col_idx) const |
auto | getResultSet () const |
Private Attributes | |
FragmentInfoType const & | fragment_info_ |
size_t | fragment_index_ |
std::shared_ptr< ResultSet > | rs_ |
using UpdateLogForFragment::Callback = std::function<void(const UpdateLogForFragment&, TableUpdateMetadata&)> |
UpdateLogForFragment::UpdateLogForFragment | ( | FragmentInfoType const & | fragment_info, |
size_t const | fragment_index, | ||
const std::shared_ptr< ResultSet > & | rs | ||
) |
Definition at line 28 of file ExecuteUpdate.cpp.
References ResultSet::GeoTargetValue.
SQLTypeInfo UpdateLogForFragment::getColumnType | ( | const size_t | col_idx | ) | const |
Definition at line 61 of file ExecuteUpdate.cpp.
References rs_.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
|
overridevirtual |
Implements Fragmenter_Namespace::RowDataProvider.
Definition at line 35 of file ExecuteUpdate.cpp.
References rs_.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
|
overridevirtual |
Implements Fragmenter_Namespace::RowDataProvider.
Definition at line 53 of file ExecuteUpdate.cpp.
References rs_.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
|
inline |
Definition at line 364 of file Execute.h.
References fragment_info_, and Fragmenter_Namespace::FragmentInfo::fragmentId.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
size_t const UpdateLogForFragment::getFragmentIndex | ( | ) | const |
UpdateLogForFragment::FragmentInfoType const & UpdateLogForFragment::getFragmentInfo | ( | ) | const |
Definition at line 48 of file ExecuteUpdate.cpp.
References fragment_info_.
Referenced by StorageIOFacility::yieldUpdateCallback().
|
inlineoverridevirtual |
Implements Fragmenter_Namespace::RowDataProvider.
Definition at line 355 of file Execute.h.
References rs_.
|
inline |
Definition at line 361 of file Execute.h.
References fragment_info_, and Fragmenter_Namespace::FragmentInfo::physicalTableId.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
|
inline |
Definition at line 372 of file Execute.h.
References rs_.
Referenced by StorageIOFacility::yieldUpdateCallback().
|
overridevirtual |
Implements Fragmenter_Namespace::RowDataProvider.
Definition at line 44 of file ExecuteUpdate.cpp.
References rs_.
Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().
|
overridevirtual |
Implements Fragmenter_Namespace::RowDataProvider.
Definition at line 39 of file ExecuteUpdate.cpp.
References rs_.
Referenced by StorageIOFacility::yieldUpdateCallback().
|
private |
Definition at line 376 of file Execute.h.
Referenced by getFragmentIndex().
|
private |
Definition at line 375 of file Execute.h.
Referenced by getFragmentId(), getFragmentInfo(), and getPhysicalTableId().
|
private |
Definition at line 377 of file Execute.h.
Referenced by getColumnType(), getEntryAt(), getEntryCount(), getLiteralDictionary(), getResultSet(), getRowCount(), and getTranslatedEntryAt().