Index

A

absolute_path() (TFNodeContext method) add() (Reservations method) args (TFParams attribute)

argv (Namespace attribute) await_reservations() (Client method) (Server method)

B

batch_results() (DataFeed method) (in module tensorflowonspark.TFNode)

C

Client (class in tensorflowonspark.reservation) close() (Client method) cluster_id (TFCluster attribute) (TFSparkNode attribute)

cluster_info (TFCluster attribute) cluster_meta (TFCluster attribute) connect() (in module tensorflowonspark.TFManager)

D

DataFeed (class in tensorflowonspark.TFNode) defaultFS (TFCluster attribute)

done (Server attribute) done() (Reservations method)

E

EndPartition (class in tensorflowonspark.marker) export_fn (TFEstimator attribute)

export_saved_model() (in module tensorflowonspark.TFNode) (TFNodeContext method)

F

find_in_path() (in module tensorflowonspark.util)

fromTFExample() (in module tensorflowonspark.dfutil)

G

get() (Reservations method) get_data_feed() (TFNodeContext method) get_gpus() (in module tensorflowonspark.gpu_info) get_ip_address() (in module tensorflowonspark.util) get_meta_graph_def() (in module tensorflowonspark.pipeline) get_reservations() (Client method) get_server_ip() (Server method) get_server_ports() (Server method) getBatchSize() (HasBatchSize method) getClusterSize() (HasClusterSize method) getDriverPSNodes() (HasNumPS method) getEpochs() (HasEpochs method) getExportDir() (HasExportDir method)

getGraceSecs() (HasGraceSecs method) getInputMapping() (HasInputMapping method) getInputMode() (HasInputMode method) getMasterNode() (HasMasterNode method) getModelDir() (HasModelDir method) getNumPS() (HasNumPS method) getOutputMapping() (HasOutputMapping method) getProtocol() (HasProtocol method) getReaders() (HasReaders method) getSignatureDefKey() (HasSignatureDefKey method) getSteps() (HasSteps method) getTagSet() (HasTagSet method) getTensorboard() (HasTensorboard method) getTFRecordDir() (HasTFRecordDir method)

H

HasBatchSize (class in tensorflowonspark.pipeline) HasClusterSize (class in tensorflowonspark.pipeline) HasEpochs (class in tensorflowonspark.pipeline) HasExportDir (class in tensorflowonspark.pipeline) HasGraceSecs (class in tensorflowonspark.pipeline) HasInputMapping (class in tensorflowonspark.pipeline) HasInputMode (class in tensorflowonspark.pipeline) HasMasterNode (class in tensorflowonspark.pipeline) HasModelDir (class in tensorflowonspark.pipeline)

HasNumPS (class in tensorflowonspark.pipeline) HasOutputMapping (class in tensorflowonspark.pipeline) HasProtocol (class in tensorflowonspark.pipeline) HasReaders (class in tensorflowonspark.pipeline) HasSignatureDefKey (class in tensorflowonspark.pipeline) HasSteps (class in tensorflowonspark.pipeline) HasTagSet (class in tensorflowonspark.pipeline) HasTensorboard (class in tensorflowonspark.pipeline) HasTFRecordDir (class in tensorflowonspark.pipeline) hdfs_path() (in module tensorflowonspark.TFNode)

I

infer_schema() (in module tensorflowonspark.dfutil) inference() (in module tensorflowonspark.TFSparkNode) (TFCluster method)

input_mode (TFCluster attribute) InputMode (class in tensorflowonspark.TFCluster) is_gpu_available() (in module tensorflowonspark.gpu_info) isLoadedDF() (in module tensorflowonspark.dfutil)

L

loadTFRecords() (in module tensorflowonspark.dfutil)

M

Marker (class in tensorflowonspark.marker) MAX_RETRIES (in module tensorflowonspark.gpu_info) merge_args_params() (TFParams method) MessageSocket (class in tensorflowonspark.reservation) mgr (TFSparkNode attribute) module tensorflowonspark tensorflowonspark.dfutil tensorflowonspark.gpu_info tensorflowonspark.marker tensorflowonspark.pipeline tensorflowonspark.reservation tensorflowonspark.TFCluster tensorflowonspark.TFManager tensorflowonspark.TFNode tensorflowonspark.TFParallel tensorflowonspark.TFSparkNode tensorflowonspark.util

N

Namespace (class in tensorflowonspark.pipeline) next_batch() (DataFeed method) (in module tensorflowonspark.TFNode)

nodeRDD (TFCluster attribute) num_executors (TFCluster attribute)

Q

queues (TFCluster attribute)

R

read_executor_id() (in module tensorflowonspark.util) receive() (MessageSocket method) register() (Client method) release_port() (in module tensorflowonspark.TFNode) (TFNodeContext method) remaining() (Reservations method)

request_stop() (Client method) Reservations (class in tensorflowonspark.reservation) reservations (Server attribute) run() (in module tensorflowonspark.TFCluster) (in module tensorflowonspark.TFParallel) (in module tensorflowonspark.TFSparkNode)

S

saveAsTFRecords() (in module tensorflowonspark.dfutil) sc (TFCluster attribute) send() (MessageSocket method) Server (class in tensorflowonspark.reservation) server (TFCluster attribute) server_addr (Client attribute) setBatchSize() (HasBatchSize method) setClusterSize() (HasClusterSize method) setDriverPSNodes() (HasNumPS method) setEpochs() (HasEpochs method) setExportDir() (HasExportDir method) setGraceSecs() (HasGraceSecs method) setInputMapping() (HasInputMapping method) setInputMode() (HasInputMode method) setMasterNode() (HasMasterNode method) setModelDir() (HasModelDir method) setNumPS() (HasNumPS method) setOutputMapping() (HasOutputMapping method) setProtocol() (HasProtocol method)

setReaders() (HasReaders method) setSignatureDefKey() (HasSignatureDefKey method) setSteps() (HasSteps method) setTagSet() (HasTagSet method) setTensorboard() (HasTensorboard method) setTFRecordDir() (HasTFRecordDir method) should_stop() (DataFeed method) shutdown() (in module tensorflowonspark.TFSparkNode) (TFCluster method) single_node_env() (in module tensorflowonspark.pipeline) (in module tensorflowonspark.util) sock (Client attribute) SPARK (InputMode attribute) start() (in module tensorflowonspark.TFManager) (Server method) start_cluster_server() (in module tensorflowonspark.TFNode) (TFNodeContext method) start_listening_socket() (Server method) stop() (Server method)

T

tensorboard_url() (TFCluster method) TENSORFLOW (InputMode attribute) tensorflowonspark module tensorflowonspark.dfutil module tensorflowonspark.gpu_info module tensorflowonspark.marker module tensorflowonspark.pipeline module tensorflowonspark.reservation module tensorflowonspark.TFCluster module tensorflowonspark.TFManager module tensorflowonspark.TFNode module

tensorflowonspark.TFParallel module tensorflowonspark.TFSparkNode module tensorflowonspark.util module terminate() (DataFeed method) (in module tensorflowonspark.TFNode) TFCluster (class in tensorflowonspark.TFCluster) TFEstimator (class in tensorflowonspark.pipeline) TFManager (class in tensorflowonspark.TFManager) TFModel (class in tensorflowonspark.pipeline) TFNodeContext (class in tensorflowonspark.TFSparkNode) TFParams (class in tensorflowonspark.pipeline) TFSparkNode (class in tensorflowonspark.TFSparkNode) TFTypeConverters (class in tensorflowonspark.pipeline) toDict() (TFTypeConverters static method) toTFExample() (in module tensorflowonspark.dfutil) train() (in module tensorflowonspark.TFSparkNode) (TFCluster method) train_fn (TFEstimator attribute)

W

working_dir (TFCluster attribute)

write_executor_id() (in module tensorflowonspark.util)

Y

yield_batch() (in module tensorflowonspark.pipeline)