OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
UpdateLogForFragment Class Reference

#include <Execute.h>

+ Inheritance diagram for UpdateLogForFragment:
+ Collaboration diagram for UpdateLogForFragment:

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< TargetValuegetEntryAt (const size_t index) const override
 
std::vector< TargetValuegetTranslatedEntryAt (const size_t index) const override
 
size_t const getRowCount () const override
 
StringDictionaryProxygetLiteralDictionary () 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< ResultSetrs_
 

Detailed Description

Definition at line 343 of file Execute.h.

Member Typedef Documentation

Definition at line 370 of file Execute.h.

Constructor & Destructor Documentation

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.

31  : fragment_info_(fragment_info), fragment_index_(fragment_index), rs_(rs) {
32  rs->setGeoReturnType(ResultSet::GeoReturnType::GeoTargetValue);
33 }
size_t fragment_index_
Definition: Execute.h:376
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377
FragmentInfoType const & fragment_info_
Definition: Execute.h:375

Member Function Documentation

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().

61  {
62  return rs_->getColType(col_idx);
63 }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

std::vector< TargetValue > UpdateLogForFragment::getEntryAt ( const size_t  index) const
overridevirtual

Implements Fragmenter_Namespace::RowDataProvider.

Definition at line 35 of file ExecuteUpdate.cpp.

References rs_.

Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().

35  {
36  return rs_->getRowAtNoTranslations(index);
37 }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

size_t const UpdateLogForFragment::getEntryCount ( ) const
overridevirtual

Implements Fragmenter_Namespace::RowDataProvider.

Definition at line 53 of file ExecuteUpdate.cpp.

References rs_.

Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().

53  {
54  return rs_->entryCount();
55 }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

decltype(FragmentInfoType::fragmentId) const UpdateLogForFragment::getFragmentId ( ) const
inline

Definition at line 364 of file Execute.h.

References fragment_info_, and Fragmenter_Namespace::FragmentInfo::fragmentId.

Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().

364  {
365  return fragment_info_.fragmentId;
366  }
FragmentInfoType const & fragment_info_
Definition: Execute.h:375

+ Here is the caller graph for this function:

size_t const UpdateLogForFragment::getFragmentIndex ( ) const

Definition at line 57 of file ExecuteUpdate.cpp.

References fragment_index_.

57  {
58  return fragment_index_;
59 }
size_t fragment_index_
Definition: Execute.h:376
UpdateLogForFragment::FragmentInfoType const & UpdateLogForFragment::getFragmentInfo ( ) const

Definition at line 48 of file ExecuteUpdate.cpp.

References fragment_info_.

Referenced by StorageIOFacility::yieldUpdateCallback().

49  {
50  return fragment_info_;
51 }
FragmentInfoType const & fragment_info_
Definition: Execute.h:375

+ Here is the caller graph for this function:

StringDictionaryProxy* UpdateLogForFragment::getLiteralDictionary ( ) const
inlineoverridevirtual

Implements Fragmenter_Namespace::RowDataProvider.

Definition at line 355 of file Execute.h.

References rs_.

355  {
356  return rs_->getRowSetMemOwner()->getLiteralStringDictProxy();
357  }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377
decltype(FragmentInfoType::physicalTableId) const UpdateLogForFragment::getPhysicalTableId ( ) const
inline

Definition at line 361 of file Execute.h.

References fragment_info_, and Fragmenter_Namespace::FragmentInfo::physicalTableId.

Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().

361  {
363  }
FragmentInfoType const & fragment_info_
Definition: Execute.h:375

+ Here is the caller graph for this function:

auto UpdateLogForFragment::getResultSet ( ) const
inline

Definition at line 372 of file Execute.h.

References rs_.

Referenced by StorageIOFacility::yieldUpdateCallback().

372 { return rs_; }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

size_t const UpdateLogForFragment::getRowCount ( ) const
overridevirtual

Implements Fragmenter_Namespace::RowDataProvider.

Definition at line 44 of file ExecuteUpdate.cpp.

References rs_.

Referenced by StorageIOFacility::yieldDeleteCallback(), and StorageIOFacility::yieldUpdateCallback().

44  {
45  return rs_->rowCount();
46 }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

std::vector< TargetValue > UpdateLogForFragment::getTranslatedEntryAt ( const size_t  index) const
overridevirtual

Implements Fragmenter_Namespace::RowDataProvider.

Definition at line 39 of file ExecuteUpdate.cpp.

References rs_.

Referenced by StorageIOFacility::yieldUpdateCallback().

40  {
41  return rs_->getRowAt(index);
42 }
std::shared_ptr< ResultSet > rs_
Definition: Execute.h:377

+ Here is the caller graph for this function:

Member Data Documentation

size_t UpdateLogForFragment::fragment_index_
private

Definition at line 376 of file Execute.h.

Referenced by getFragmentIndex().

FragmentInfoType const& UpdateLogForFragment::fragment_info_
private

Definition at line 375 of file Execute.h.

Referenced by getFragmentId(), getFragmentInfo(), and getPhysicalTableId().

std::shared_ptr<ResultSet> UpdateLogForFragment::rs_
private

The documentation for this class was generated from the following files: