Flex
0.17.9
|
This is the complete list of members for gs::ODPSFragmentLoader, including all inherited members.
_append_edges(std::shared_ptr< arrow::Array > src_col, std::shared_ptr< arrow::Array > dst_col, const IndexerType &src_indexer, const IndexerType &dst_indexer, std::shared_ptr< arrow::Array > &property_cols, const PropertyType &edge_property, VECTOR_T &parsed_edges, std::vector< std::atomic< int32_t >> &ie_degree, std::vector< std::atomic< int32_t >> &oe_degree, size_t offset) | gs::AbstractArrowFragmentLoader | inlineprotected |
AbstractArrowFragmentLoader(const std::string &work_dir, const Schema &schema, const LoadingConfig &loading_config) | gs::AbstractArrowFragmentLoader | inline |
addEdges(label_t src_label_id, label_t dst_label_id, label_t e_label_id, const std::vector< std::string > &e_files) | gs::ODPSFragmentLoader | private |
AddEdgesRecordBatch(label_t src_label_id, label_t dst_label_id, label_t edge_label_id, const std::vector< std::string > &input_paths, std::function< std::vector< std::shared_ptr< IRecordBatchSupplier >>(label_t, label_t, label_t, const std::string &, const LoadingConfig &, int)> supplier_creator) | gs::AbstractArrowFragmentLoader | |
addEdgesRecordBatchImpl(label_t src_label_id, label_t dst_label_id, label_t e_label_id, const std::vector< std::string > &e_files, std::function< std::vector< std::shared_ptr< IRecordBatchSupplier >>(label_t, label_t, label_t, const std::string &, const LoadingConfig &, int)> supplier_creator) | gs::AbstractArrowFragmentLoader | inlineprotected |
addEdgesRecordBatchImplHelper(label_t src_label_id, label_t dst_label_id, label_t e_label_id, const std::vector< std::string > &e_files, std::function< std::vector< std::shared_ptr< IRecordBatchSupplier >>(label_t, label_t, label_t, const std::string &, const LoadingConfig &, int)> supplier_creator) | gs::AbstractArrowFragmentLoader | inlineprotected |
addVertexBatchFromArray(label_t v_label_id, IdIndexer< KEY_T, vid_t > &indexer, std::shared_ptr< arrow::Array > &primary_key_col, const std::vector< std::shared_ptr< arrow::Array >> &property_cols) | gs::AbstractArrowFragmentLoader | inlineprotected |
addVertexRecordBatchImpl(label_t v_label_id, const std::vector< std::string > &v_files, std::function< std::vector< std::shared_ptr< IRecordBatchSupplier >>(label_t, const std::string &, const LoadingConfig &, int)> supplier_creator) | gs::AbstractArrowFragmentLoader | inlineprotected |
addVertices(label_t v_label_id, const std::vector< std::string > &v_files) | gs::ODPSFragmentLoader | private |
AddVerticesRecordBatch(label_t v_label_id, const std::vector< std::string > &input_paths, std::function< std::vector< std::shared_ptr< IRecordBatchSupplier >>(label_t, const std::string &, const LoadingConfig &, int)> supplier_creator) | gs::AbstractArrowFragmentLoader | |
basic_fragment_loader_ | gs::AbstractArrowFragmentLoader | mutableprotected |
build_csr_in_mem_ | gs::AbstractArrowFragmentLoader | protected |
columnMappingsToSelectedCols(const std::vector< std::tuple< size_t, std::string, std::string >> &column_mappings) | gs::ODPSFragmentLoader | private |
edge_label_num_ | gs::AbstractArrowFragmentLoader | protected |
init() | gs::ODPSFragmentLoader | private |
loadEdges() | gs::ODPSFragmentLoader | private |
LoadFragment() override | gs::ODPSFragmentLoader | virtual |
loading_config_ | gs::AbstractArrowFragmentLoader | protected |
loadVertices() | gs::ODPSFragmentLoader | private |
Make(const std::string &work_dir, const Schema &schema, const LoadingConfig &loading_config) | gs::ODPSFragmentLoader | static |
mtxs_ | gs::AbstractArrowFragmentLoader | protected |
odps_read_client_ | gs::ODPSFragmentLoader | private |
ODPSFragmentLoader(const std::string &work_dir, const Schema &schema, const LoadingConfig &loading_config) | gs::ODPSFragmentLoader | inline |
parseLocation(const std::string &odps_table_path, TableIdentifier &table_identifier, std::vector< std::string > &partition_names, std::vector< std::string > &selected_partitions) | gs::ODPSFragmentLoader | private |
registered_ | gs::ODPSFragmentLoader | privatestatic |
schema_ | gs::AbstractArrowFragmentLoader | protected |
thread_num_ | gs::AbstractArrowFragmentLoader | protected |
use_mmap_vector_ | gs::AbstractArrowFragmentLoader | protected |
vertex_label_num_ | gs::AbstractArrowFragmentLoader | protected |
~AbstractArrowFragmentLoader() | gs::AbstractArrowFragmentLoader | inline |
~IFragmentLoader()=default | gs::IFragmentLoader | virtual |
~ODPSFragmentLoader() | gs::ODPSFragmentLoader | inline |