|
RDFS
The Rice Comp413 2017 class' continuation on the work of the 2016 RDFS.
|
This is the complete list of members for zkclient::ZkNnClient, including all inherited members.
| abandon_block(AbandonBlockRequestProto &req, AbandonBlockResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| add_block(AddBlockRequestProto &req, AddBlockResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| add_block(const std::string &fileName, u_int64_t &block_id, std::vector< std::string > &dataNodes, uint32_t replication_factor) | zkclient::ZkNnClient | |
| add_block_group(const std::string &filePath, u_int64_t &block_group_id, std::vector< std::string > &dataNodes, std::vector< char > &blockIndices, uint32_t total_num_storage_blocks) | zkclient::ZkNnClient | |
| append_file(AppendRequestProto &req, AppendResponseProto &res) | zkclient::ZkNnClient | |
| BLOCK_GROUP_LOCATIONS (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| BLOCK_LOCATIONS (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| BLOCKS (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| BLOCKS_TREE (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| cache_contains(const std::string &path) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| cache_size() (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| check_acks() | zkclient::ZkNnClient | |
| check_lease(std::string client_name, std::string file_path) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| CLASS_NAME (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | static |
| CLIENTS (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| complete(CompleteRequestProto &req, CompleteResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| create_file(CreateRequestProto &request, CreateResponseProto &response) | zkclient::ZkNnClient | |
| CreateResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| current_time_ms() | zkclient::ZkNnClient | |
| DEFAULT_DATA_UNITS (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_EC_CELLSIZE (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_EC_CODEC_NAME (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_EC_ID (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_EC_POLICY (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_EC_SCHEMA (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_PARITY_UNITS (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DEFAULT_STORAGE_ID (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| DELETE_QUEUES (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| DELETE_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| DeleteResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| destroy(DeleteRequestProto &req, DeleteResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| EC_RECOVER_QUEUES (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| EC_RECOVER_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| EC_REPLICATION (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| ErasureCodingPoliciesResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| ErasureCodingPolicyResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| file_exists(const std::string &path) | zkclient::ZkNnClient | |
| find_all_datanodes_with_block(const uint64_t &block_uuid, std::vector< std::string > &rdatanodes, int &error_code) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| find_datanode_for_block(std::vector< std::string > &datanodes, std::vector< std::string > &excluded_dns, const u_int64_t blockId, uint32_t replication_factor, uint64_t blocksize) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| find_live_datanodes(const uint64_t blockId, int error_code, std::vector< std::string > &live_data_nodes) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| find_parent(const std::string &path) | zkclient::ZkNnClient | |
| generate_block_group_id() | zkclient::ZkNnClient | |
| generate_storage_block_id(uint64_t block_group_id, uint64_t index_within_group) | zkclient::ZkNnClient | |
| get_block_group_id(u_int64_t storage_block_id) | zkclient::ZkNnClient | |
| get_block_locations(GetBlockLocationsRequestProto &req, GetBlockLocationsResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| get_block_locations(const std::string &src, google::protobuf::uint64 offset, google::protobuf::uint64 length, LocatedBlocksProto *blocks, std::string client_name="default") (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| get_block_metadata_path(u_int64_t block_or_block_group_id) | zkclient::ZkClientCommon | |
| get_block_size(const u_int64_t &block_id, uint64_t &blocksize) | zkclient::ZkNnClient | |
| get_client_lease_timestamp(std::string client_name) | zkclient::ZkNnClient | |
| get_content(GetContentSummaryRequestProto &req, GetContentSummaryResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| get_erasure_coding_policies(GetErasureCodingPoliciesRequestProto &req, GetErasureCodingPoliciesResponseProto &res) | zkclient::ZkNnClient | |
| get_erasure_coding_policy_of_path(GetErasureCodingPolicyRequestProto &req, GetErasureCodingPolicyResponseProto &res) | zkclient::ZkNnClient | |
| get_index_within_block_group(u_int64_t storage_block_id) | zkclient::ZkNnClient | |
| get_info(GetFileInfoRequestProto &req, GetFileInfoResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| get_listing(GetListingRequestProto &req, GetListingResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| get_node_policy() (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| get_primary_block_info(std::string file_path, AppendRequestProto &req, AppendResponseProto &res) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| get_total_num_storage_blocks(const std::string &fileName, u_int64_t &block_group_id) | zkclient::ZkNnClient | |
| GetFileInfoResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| HEALTH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| HEALTH_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| HEARTBEAT (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| init() (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | |
| is_ec_block(u_int64_t block_id) | zkclient::ZkClientCommon | static |
| LEASES (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| ListingResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| mkdir(MkdirsRequestProto &req, MkdirsResponseProto &res) | zkclient::ZkNnClient | |
| MkdirResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| NAMESPACE_PATH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| policy (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| previousBlockComplete(uint64_t prev_id) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| process_request(std::string client_name, std::string file_path, AppendRequestProto &req) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| read_file_znode(FileZNode &znode_data, const std::string &path) | zkclient::ZkNnClient | |
| recover_lease(RecoverLeaseRequestProto &req, RecoverLeaseResponseProto &res) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| register_watches() (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| rename(RenameRequestProto &req, RenameResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| rename_ops_for_dir(const std::string &src, const std::string &dst, std::vector< std::shared_ptr< ZooOp >> &ops) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| rename_ops_for_file(const std::string &src, const std::string &dst, std::vector< std::shared_ptr< ZooOp >> &ops) | zkclient::ZkNnClient | |
| RenameResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| renew_lease(RenewLeaseRequestProto &req, RenewLeaseResponseProto &res) | zkclient::ZkNnClient | |
| REPLICATE_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| REPLICATE_QUEUES (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| REPLICATE_QUEUES_NO_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| REPLICATION_1_2_SCHEMA (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| REPLICATION_EC_ID (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| REPLICATION_PROTO (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| REPLICATION_STORAGE_ID (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| RS_SOLOMON_PROTO (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| set_erasure_coding_policy_of_path(SetErasureCodingPolicyRequestProto &req, SetErasureCodingPolicyResponseProto &res) | zkclient::ZkNnClient | |
| set_file_info_content(ContentSummaryProto *status, const std::string &path, FileZNode &znode_data) | zkclient::ZkNnClient | |
| set_node_policy(char policy) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| set_owner(SetOwnerRequestProto &req, SetOwnerResponseProto &res, std::string client_name="default") | zkclient::ZkNnClient | |
| set_owner(SetOwnerRequestProto &req, SetOwnerResponseProto &res) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| set_permission(SetPermissionRequestProto &req, SetPermissionResponseProto &res) | zkclient::ZkNnClient | |
| SetErasureCodingPolicyResponse enum name (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| STATS (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| update_block_for_pipeline(UpdateBlockForPipelineRequestProto &req, UpdateBlockForPipelineResponseProto &res) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | |
| WAIT_FOR_ACK (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| WAIT_FOR_ACK_BACKSLASH (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| WORK_QUEUES (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | static |
| zk (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | |
| ZkClientCommon(std::string hostAndIp) (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | explicit |
| ZkClientCommon(std::shared_ptr< ZKWrapper > zk) (defined in zkclient::ZkClientCommon) | zkclient::ZkClientCommon | explicit |
| ZkNnClient(std::string zkIpAndAddress) (defined in zkclient::ZkNnClient) | zkclient::ZkNnClient | inlineexplicit |
| ZkNnClient(std::shared_ptr< ZKWrapper > zk_in, bool secureMode=false) | zkclient::ZkNnClient | inlineexplicit |
1.8.6