#include <update_transaction.h>
|
| UpdateTransaction (MutablePropertyFragment &graph, Allocator &alloc, const std::string &work_dir, WalWriter &logger, VersionManager &vm, timestamp_t timestamp) |
|
| ~UpdateTransaction () |
|
timestamp_t | timestamp () const |
|
void | Commit () |
|
void | Abort () |
|
bool | AddVertex (label_t label, const Any &oid, const std::vector< Any > &props) |
|
bool | AddEdge (label_t src_label, const Any &src, label_t dst_label, const Any &dst, label_t edge_label, const Any &value) |
|
vertex_iterator | GetVertexIterator (label_t label) |
|
edge_iterator | GetOutEdgeIterator (label_t label, vid_t u, label_t neighbor_label, label_t edge_label) |
|
edge_iterator | GetInEdgeIterator (label_t label, vid_t u, label_t neighbor_label, label_t edge_label) |
|
Any | GetVertexField (label_t label, vid_t lid, int col_id) const |
|
bool | SetVertexField (label_t label, vid_t lid, int col_id, const Any &value) |
|
void | SetEdgeData (bool dir, label_t label, vid_t v, label_t neighbor_label, vid_t nbr, label_t edge_label, const Any &value) |
|
bool | GetUpdatedEdgeData (bool dir, label_t label, vid_t v, label_t neighbor_label, vid_t nbr, label_t edge_label, Any &ret) const |
|
|
void | batch_commit (UpdateBatch &batch) |
|
void | set_edge_data_with_offset (bool dir, label_t label, vid_t v, label_t neighbor_label, vid_t nbr, label_t edge_label, const Any &value, size_t offset) |
|
size_t | get_in_csr_index (label_t src_label, label_t dst_label, label_t edge_label) const |
|
size_t | get_out_csr_index (label_t src_label, label_t dst_label, label_t edge_label) const |
|
bool | oid_to_lid (label_t label, const Any &oid, vid_t &lid) const |
|
Any | lid_to_oid (label_t label, vid_t lid) const |
|
void | release () |
|
void | applyVerticesUpdates () |
|
void | applyEdgesUpdates () |
|
◆ UpdateTransaction()
◆ ~UpdateTransaction()
gs::UpdateTransaction::~UpdateTransaction |
( |
| ) |
|
◆ Abort()
void gs::UpdateTransaction::Abort |
( |
| ) |
|
◆ AddEdge()
◆ AddVertex()
bool gs::UpdateTransaction::AddVertex |
( |
label_t |
label, |
|
|
const Any & |
oid, |
|
|
const std::vector< Any > & |
props |
|
) |
| |
◆ applyEdgesUpdates()
void gs::UpdateTransaction::applyEdgesUpdates |
( |
| ) |
|
|
private |
◆ applyVerticesUpdates()
void gs::UpdateTransaction::applyVerticesUpdates |
( |
| ) |
|
|
private |
◆ batch_commit()
void gs::UpdateTransaction::batch_commit |
( |
UpdateBatch & |
batch | ) |
|
|
private |
◆ Commit()
void gs::UpdateTransaction::Commit |
( |
| ) |
|
◆ get_in_csr_index()
size_t gs::UpdateTransaction::get_in_csr_index |
( |
label_t |
src_label, |
|
|
label_t |
dst_label, |
|
|
label_t |
edge_label |
|
) |
| const |
|
private |
◆ get_out_csr_index()
size_t gs::UpdateTransaction::get_out_csr_index |
( |
label_t |
src_label, |
|
|
label_t |
dst_label, |
|
|
label_t |
edge_label |
|
) |
| const |
|
private |
◆ GetInEdgeIterator()
◆ GetOutEdgeIterator()
◆ GetUpdatedEdgeData()
◆ GetVertexField()
Any gs::UpdateTransaction::GetVertexField |
( |
label_t |
label, |
|
|
vid_t |
lid, |
|
|
int |
col_id |
|
) |
| const |
◆ GetVertexIterator()
◆ IngestWal()
void gs::UpdateTransaction::IngestWal |
( |
MutablePropertyFragment & |
graph, |
|
|
const std::string & |
work_dir, |
|
|
uint32_t |
timestamp, |
|
|
char * |
data, |
|
|
size_t |
length, |
|
|
Allocator & |
alloc |
|
) |
| |
|
static |
◆ lid_to_oid()
◆ oid_to_lid()
bool gs::UpdateTransaction::oid_to_lid |
( |
label_t |
label, |
|
|
const Any & |
oid, |
|
|
vid_t & |
lid |
|
) |
| const |
|
private |
◆ release()
void gs::UpdateTransaction::release |
( |
| ) |
|
|
private |
◆ set_edge_data_with_offset()
void gs::UpdateTransaction::set_edge_data_with_offset |
( |
bool |
dir, |
|
|
label_t |
label, |
|
|
vid_t |
v, |
|
|
label_t |
neighbor_label, |
|
|
vid_t |
nbr, |
|
|
label_t |
edge_label, |
|
|
const Any & |
value, |
|
|
size_t |
offset |
|
) |
| |
|
private |
◆ SetEdgeData()
◆ SetVertexField()
bool gs::UpdateTransaction::SetVertexField |
( |
label_t |
label, |
|
|
vid_t |
lid, |
|
|
int |
col_id, |
|
|
const Any & |
value |
|
) |
| |
◆ timestamp()
◆ GraphDBSession
◆ added_edges_
std::vector<ska::flat_hash_map<vid_t, std::vector<vid_t> > > gs::UpdateTransaction::added_edges_ |
|
private |
◆ added_vertices_
std::vector<std::shared_ptr<IdIndexerBase<vid_t> > > gs::UpdateTransaction::added_vertices_ |
|
private |
◆ added_vertices_base_
std::vector<vid_t> gs::UpdateTransaction::added_vertices_base_ |
|
private |
◆ alloc_
◆ arc_
grape::InArchive gs::UpdateTransaction::arc_ |
|
private |
◆ edge_label_num_
size_t gs::UpdateTransaction::edge_label_num_ |
|
private |
◆ extra_vertex_properties_
std::vector<Table> gs::UpdateTransaction::extra_vertex_properties_ |
|
private |
◆ graph_
◆ logger_
◆ op_num_
int gs::UpdateTransaction::op_num_ |
|
private |
◆ sv_vec_
std::vector<std::string> gs::UpdateTransaction::sv_vec_ |
|
private |
◆ timestamp_
◆ updated_edge_data_
std::vector<ska::flat_hash_map< vid_t, ska::flat_hash_map<vid_t, std::pair<Any, size_t> > > > gs::UpdateTransaction::updated_edge_data_ |
|
private |
◆ vertex_label_num_
size_t gs::UpdateTransaction::vertex_label_num_ |
|
private |
◆ vertex_nums_
std::vector<vid_t> gs::UpdateTransaction::vertex_nums_ |
|
private |
◆ vertex_offsets_
std::vector<ska::flat_hash_map<vid_t, vid_t> > gs::UpdateTransaction::vertex_offsets_ |
|
private |
◆ vm_
The documentation for this class was generated from the following files: