Index

_

__init__() (hops.dataset.HTTPDownload method), [1] (hops.dataset.HTTPUpload method), [1] (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.mirrored_reservation.Reservations method) (hops.experiment_impl.distribute.mirrored_reservation.Server method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.Server method) (hops.experiment_impl.distribute.parameter_server_reservation.WorkerFinished method) (hops.experiment_impl.parallel.differential_evolution.DifferentialEvolution method) (hops.kafka.KafkaTopicDTO method), [1] (hops.serving.Serving method), [1]

A

abs_path() (in module hops.hdfs), [1] access() (in module hops.hdfs), [1] add() (hops.experiment_impl.distribute.mirrored_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.WorkerFinished method) add_module() (in module hops.hdfs), [1] APIKeyFileNotFound

assume_role() (in module hops.credentials_provider), [1] attach_jupyter_configuration_to_notebook() (in module hops.util), [1] await_all_workers_finished() (hops.experiment_impl.distribute.parameter_server_reservation.Client method) await_reservations() (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.mirrored_reservation.Server method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Server method)

B

build_parameters() (in module hops.experiment_impl.util.experiment_utils)

C

capacity() (in module hops.hdfs), [1] chmod() (in module hops.hdfs), [1] chown() (in module hops.hdfs), [1] Client (class in hops.experiment_impl.distribute.mirrored_reservation) (class in hops.experiment_impl.distribute.parameter_server_reservation) close() (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) (in module hops.hdfs), [1] compress() (in module hops.dataset), [1] CompressTimeout, [1] connect() (in module hops.project), [1] (in module hops.util), [1]

construct_service_fqdn() (hops.service_discovery.ServiceDiscovery static method) convert_json_schema_to_avro() (in module hops.kafka), [1] copy_to_hdfs() (in module hops.hdfs), [1] copy_to_local() (in module hops.hdfs), [1] cp() (in module hops.hdfs), [1] create() (in module hops.project), [1] create_job() (in module hops.jobs), [1] create_or_update() (in module hops.serving), [1] create_secret() (in module hops.secret), [1] create_user() (in module hops.user), [1]

D

DEFAULT_DOWNLOAD_CHUNK_SIZE (hops.dataset.HTTPDownload attribute), [1] DEFAULT_FLOW_STANDARD_CHUNK_SIZE (hops.dataset.HTTPUpload attribute), [1] delete() (in module hops.dataset), [1] (in module hops.hdfs), [1] (in module hops.serving), [1] delete_secret() (in module hops.secret), [1] DeletionTimeout, [1] describe() (in module hops.serving), [1] differential_evolution() (in module hops.experiment), [1] DifferentialEvolution (class in hops.experiment_impl.parallel.differential_evolution)

Direction (class in hops.experiment), [1] done (hops.experiment_impl.distribute.mirrored_reservation.Server attribute) (hops.experiment_impl.distribute.parameter_server_reservation.Server attribute) done() (hops.experiment_impl.distribute.mirrored_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.WorkerFinished method) download() (hops.dataset.HTTPDownload method), [1] (in module hops.dataset), [1] download_model() (in module hops.model), [1] dump() (in module hops.hdfs), [1] dumps() (in module hops.experiment_impl.util.experiment_utils)

E

exists() (in module hops.hdfs), [1] (in module hops.serving), [1]

export() (in module hops.model), [1] extract() (in module hops.dataset), [1]

F

f (hops.dataset.HTTPUpload attribute), [1] file (hops.dataset.HTTPUpload attribute), [1]

flow_standard_chunk_size (hops.dataset.HTTPUpload attribute), [1] fromfile() (in module hops.numpy_helper), [1] fromregex() (in module hops.numpy_helper), [1]

G

genfromtxt() (in module hops.numpy_helper), [1] get() (hops.experiment_impl.distribute.mirrored_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.Reservations method) (in module hops.hdfs), [1] (in module hops.serving), [1] get_all() (in module hops.serving), [1] get_any_service() (hops.service_discovery.ServiceDiscovery static method) get_artifact_version() (in module hops.serving), [1] get_authorization_token() (in module hops.elasticsearch) get_available_instances() (in module hops.serving), [1] get_best_model() (in module hops.model), [1] get_broker_endpoints() (in module hops.kafka), [1] get_broker_endpoints_list() (in module hops.kafka), [1] get_ca_chain_location() (in module hops.tls), [1] get_client_certificate_location() (in module hops.tls), [1] get_client_key_location() (in module hops.tls), [1] get_dict() (hops.experiment_impl.parallel.differential_evolution.DifferentialEvolution method) get_elasticsearch_config() (in module hops.elasticsearch) get_elasticsearch_index() (in module hops.elasticsearch) get_executions() (in module hops.jobs), [1] get_flink_conf_dir() (in module hops.util), [1] get_flink_lib_dir() (in module hops.util), [1] get_fs() (in module hops.hdfs), [1] get_hadoop_classpath_glob() (in module hops.util), [1] get_hadoop_home() (in module hops.util), [1] get_id() (in module hops.serving), [1] get_internal_endpoints() (in module hops.serving), [1] get_job_name() (in module hops.util), [1] get_jwt() (in module hops.util), [1] get_kafka_default_config() (in module hops.kafka), [1] get_kafka_topic() (in module hops.serving), [1] get_key_store() (in module hops.tls), [1] get_key_store_cert() (in module hops.tls), [1] get_key_store_pwd() (in module hops.tls), [1]

get_model() (in module hops.model), [1] get_model_name() (in module hops.serving), [1] get_model_path() (in module hops.serving), [1] get_model_registry_id() (in module hops.experiment_impl.util.experiment_utils) get_model_server() (in module hops.serving), [1] get_model_version() (in module hops.serving), [1] get_num_gpus() (in module hops.devices), [1] get_path_info() (in module hops.dataset), [1] get_plain_path() (in module hops.hdfs), [1] get_predictor() (in module hops.serving), [1] get_predictor_resource_config() (in module hops.serving), [1] get_project_info() (in module hops.project), [1] get_project_info_as_shared() (in module hops.project), [1] get_redshift_username_password() (in module hops.util), [1] get_requests_verify() (in module hops.util), [1] get_reservations() (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) get_role() (in module hops.credentials_provider), [1] get_roles() (in module hops.credentials_provider), [1] get_schema() (in module hops.kafka), [1] get_secret() (in module hops.secret), [1] (in module hops.util), [1] get_security_protocol() (in module hops.kafka), [1] get_service() (hops.service_discovery.ServiceDiscovery static method) get_serving_tool() (in module hops.serving), [1] get_status() (in module hops.serving), [1] get_transformer() (in module hops.serving), [1] get_trust_store() (in module hops.tls), [1] get_trust_store_pwd() (in module hops.tls), [1] get_webhdfs_host() (in module hops.hdfs), [1] get_webhdfs_port() (in module hops.hdfs), [1] get_xattr() (in module hops.xattr) glob() (in module hops.hdfs), [1] grid_params() (in module hops.experiment_impl.util.experiment_utils) grid_search() (in module hops.experiment), [1]

H

hops module, [1] hops.credentials_provider module, [1] hops.dataset module, [1] hops.devices module, [1] hops.elasticsearch module hops.exceptions module hops.experiment module, [1] hops.experiment_impl module hops.experiment_impl.distribute module hops.experiment_impl.distribute.mirrored module hops.experiment_impl.distribute.mirrored_reservation module hops.experiment_impl.distribute.mirrored_reservation_client module hops.experiment_impl.distribute.parameter_server module hops.experiment_impl.distribute.parameter_server_client module hops.experiment_impl.distribute.parameter_server_reservation module hops.experiment_impl.launcher module hops.experiment_impl.parallel module hops.experiment_impl.parallel.differential_evolution module hops.experiment_impl.parallel.grid_search module hops.experiment_impl.parallel.random_search module

hops.experiment_impl.util module hops.experiment_impl.util.experiment_utils module hops.hdfs module, [1] hops.hive module hops.jobs module, [1] hops.kafka module, [1] hops.model module, [1] hops.numpy_helper module, [1] hops.pandas_helper module, [1] hops.project module, [1] hops.secret module, [1] hops.service_discovery module hops.serving module, [1] hops.tensorboard module, [1] hops.tls module, [1] hops.user module, [1] hops.util module, [1] hops.xattr module http() (in module hops.util), [1] HTTPDownload (class in hops.dataset), [1] HTTPUpload (class in hops.dataset), [1]

I

interactive_debugger() (in module hops.tensorboard), [1] is_tls_enabled() (in module hops.hdfs), [1]

isdir() (in module hops.hdfs), [1] isfile() (in module hops.hdfs), [1]

J

json_default_numpy() (in module hops.experiment_impl.util.experiment_utils)

K

KafkaTopicDTO (class in hops.kafka), [1]

L

launch() (in module hops.experiment), [1] load() (in module hops.hdfs), [1] (in module hops.numpy_helper), [1] loadtxt() (in module hops.numpy_helper), [1]

log() (in module hops.experiment_impl.util.experiment_utils) logdir() (in module hops.tensorboard), [1] ls() (in module hops.hdfs), [1] lsl() (in module hops.hdfs), [1]

M

make_inference_request() (in module hops.serving), [1] MAX (hops.experiment.Direction attribute), [1] (hops.model.Metric attribute), [1] memmap() (in module hops.numpy_helper), [1] MessageSocket (class in hops.experiment_impl.distribute.mirrored_reservation) (class in hops.experiment_impl.distribute.parameter_server_reservation) Metric (class in hops.model), [1] MIN (hops.experiment.Direction attribute), [1] (hops.model.Metric attribute), [1] mirrored() (in module hops.experiment), [1] mkdir() (in module hops.hdfs), [1] ModelArchiveExists, [1] ModelNotFound, [1] module hops, [1] hops.credentials_provider, [1] hops.dataset, [1] hops.devices, [1] hops.elasticsearch hops.exceptions hops.experiment, [1] hops.experiment_impl hops.experiment_impl.distribute hops.experiment_impl.distribute.mirrored hops.experiment_impl.distribute.mirrored_reservation hops.experiment_impl.distribute.mirrored_reservation_client hops.experiment_impl.distribute.parameter_server hops.experiment_impl.distribute.parameter_server_client hops.experiment_impl.distribute.parameter_server_reservation hops.experiment_impl.launcher hops.experiment_impl.parallel hops.experiment_impl.parallel.differential_evolution hops.experiment_impl.parallel.grid_search hops.experiment_impl.parallel.random_search hops.experiment_impl.util hops.experiment_impl.util.experiment_utils hops.hdfs, [1] hops.hive hops.jobs, [1] hops.kafka, [1] hops.model, [1] hops.numpy_helper, [1] hops.pandas_helper, [1] hops.project, [1] hops.secret, [1] hops.service_discovery hops.serving, [1] hops.tensorboard, [1] hops.tls, [1] hops.user, [1] hops.util, [1] hops.xattr

move() (in module hops.hdfs), [1]

N

non_interactive_debugger() (in module hops.tensorboard), [1]

num_executors() (in module hops.util), [1] num_param_servers() (in module hops.util), [1]

O

open_file() (in module hops.hdfs), [1]

P

parameter_server() (in module hops.experiment), [1] params (hops.dataset.HTTPUpload attribute), [1] parse_avro_msg() (in module hops.kafka), [1] parse_redhift_jdbc_url() (in module hops.util), [1] path_exists() (in module hops.dataset), [1]

project_id() (in module hops.hdfs), [1] project_id_as_shared() (in module hops.project), [1] project_name() (in module hops.hdfs), [1] project_path() (in module hops.hdfs), [1] project_user() (in module hops.hdfs), [1]

R

random_search() (in module hops.experiment), [1] read_csv() (in module hops.pandas_helper), [1] read_excel() (in module hops.pandas_helper), [1] read_json() (in module hops.pandas_helper), [1] read_parquet() (in module hops.pandas_helper), [1] receive() (hops.experiment_impl.distribute.mirrored_reservation.MessageSocket method) (hops.experiment_impl.distribute.parameter_server_reservation.MessageSocket method) register() (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) register_worker_finished() (hops.experiment_impl.distribute.parameter_server_reservation.Client method) remaining() (hops.experiment_impl.distribute.mirrored_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.Reservations method) (hops.experiment_impl.distribute.parameter_server_reservation.WorkerFinished method)

remove_xattr() (in module hops.xattr) rename() (in module hops.hdfs), [1] request_stop() (hops.experiment_impl.distribute.mirrored_reservation.Client method) (hops.experiment_impl.distribute.parameter_server_reservation.Client method) Reservations (class in hops.experiment_impl.distribute.mirrored_reservation) (class in hops.experiment_impl.distribute.parameter_server_reservation) reservations (hops.experiment_impl.distribute.mirrored_reservation.Server attribute) (hops.experiment_impl.distribute.parameter_server_reservation.Server attribute) resource (hops.dataset.HTTPUpload attribute), [1] RestAPIError rmr() (in module hops.hdfs), [1]

S

save() (in module hops.numpy_helper), [1] savez() (in module hops.numpy_helper), [1] savez_compressed() (in module hops.numpy_helper), [1] send() (hops.experiment_impl.distribute.mirrored_reservation.MessageSocket method) (hops.experiment_impl.distribute.parameter_server_reservation.MessageSocket method) send_request() (in module hops.util), [1] Server (class in hops.experiment_impl.distribute.mirrored_reservation) (class in hops.experiment_impl.distribute.parameter_server_reservation) server_addr (hops.experiment_impl.distribute.mirrored_reservation.Client attribute) (hops.experiment_impl.distribute.parameter_server_reservation.Client attribute) ServiceDiscovery (class in hops.service_discovery) Serving (class in hops.serving), [1] ServingNotFound, [1] set_auth_header() (in module hops.util), [1]

set_xattr() (in module hops.xattr) setup_hive_connection() (in module hops.hive) size_last_chunk (hops.dataset.HTTPUpload attribute), [1] sock (hops.experiment_impl.distribute.mirrored_reservation.Client attribute) (hops.experiment_impl.distribute.parameter_server_reservation.Client attribute) start() (hops.experiment_impl.distribute.mirrored_reservation.Server method) (hops.experiment_impl.distribute.parameter_server_reservation.Server method) (in module hops.serving), [1] start_job() (in module hops.jobs), [1] stat() (in module hops.hdfs), [1] stop() (hops.experiment_impl.distribute.mirrored_reservation.Server method) (hops.experiment_impl.distribute.parameter_server_reservation.Server method) (in module hops.serving), [1] stop_job() (in module hops.jobs), [1]

U

UnkownSecretStorageError

upload() (hops.dataset.HTTPUpload method), [1] (in module hops.dataset), [1]

W

WorkerFinished (class in hops.experiment_impl.distribute.parameter_server_reservation) write_b64_cert_to_bytes() (in module hops.util), [1]

write_csv() (in module hops.pandas_helper), [1] write_json() (in module hops.pandas_helper), [1] write_parquet() (in module hops.pandas_helper), [1]