Flex
0.17.9
|
This is the complete list of members for gs::ODPSReadClient, including all inherited members.
access_id_ | gs::ODPSReadClient | private |
access_key_ | gs::ODPSReadClient | private |
arrow_client_ptr_ | gs::ODPSReadClient | private |
CONNECTION_TIMEOUT | gs::ODPSReadClient | static |
CreateReadSession(std::string *session_id, int *split_count, const TableIdentifier &table_identifier, const std::vector< std::string > &selected_cols, const std::vector< std::string > &partition_cols, const std::vector< std::string > &selected_partitions) | gs::ODPSReadClient | |
createReadSession(const TableIdentifier &table_identifier, const std::vector< std::string > &selected_cols, const std::vector< std::string > &partition_cols, const std::vector< std::string > &selected_partitions) | gs::ODPSReadClient | private |
GetArrowClient() const | gs::ODPSReadClient | |
getReadSession(std::string session_id, const TableIdentifier &table_identifier) | gs::ODPSReadClient | private |
getReadSessionStatus(const std::string &session_id, int *split_count, const TableIdentifier &table_identifier) | gs::ODPSReadClient | private |
init() | gs::ODPSReadClient | |
MAX_PRODUCER_NUM | gs::ODPSReadClient | private |
MAX_RETRY | gs::ODPSReadClient | static |
odps_endpoint_ | gs::ODPSReadClient | private |
ODPSReadClient() | gs::ODPSReadClient | |
output_directory_ | gs::ODPSReadClient | private |
producerRoutine(const std::string &session_id, const TableIdentifier &table_identifier, std::vector< std::vector< std::shared_ptr< arrow::RecordBatch >>> &all_batches_, std::vector< int > &&indices) const | gs::ODPSReadClient | private |
READ_WRITE_TIMEOUT | gs::ODPSReadClient | static |
readRows(std::string session_id, const TableIdentifier &table_identifier, std::vector< std::shared_ptr< arrow::RecordBatch >> &res_batches, int split_index) const | gs::ODPSReadClient | private |
ReadTable(const std::string &session_id, int split_count, const TableIdentifier &table_id, int thread_num) const | gs::ODPSReadClient | |
tunnel_endpoint_ | gs::ODPSReadClient | private |
~ODPSReadClient() | gs::ODPSReadClient |