Index

A

adapt() (bob.pipelines.distributed.sge.SGEMultipleQueuesCluster method)

AdaptiveMultipleQueue (class in bob.pipelines.distributed.sge) assert_picklable() (in module bob.pipelines)

B

BaseWrapper (class in bob.pipelines) Block (class in bob.pipelines.xarray) bob.pipelines module bob.pipelines.distributed.sge module

bob.pipelines.transformers module bob.pipelines.xarray module

C

cancel_command (bob.pipelines.distributed.sge.SGEIdiapJob attribute) check_parameter_for_validity() (in module bob.pipelines) check_parameters_for_validity() (in module bob.pipelines)

CheckpointWrapper (class in bob.pipelines) close_counts (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute) config_name (bob.pipelines.distributed.sge.SGEIdiapJob attribute) CSVToSamples (class in bob.pipelines)

D

dask_tags() (in module bob.pipelines) DaskWrapper (class in bob.pipelines) data (bob.pipelines.DelayedSample property) dataset_map (bob.pipelines.xarray.Block attribute) DatasetPipeline (class in bob.pipelines.xarray) decision_function() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.xarray.DatasetPipeline method)

delayed_output (bob.pipelines.SampleWrapper attribute) DelayedSample (class in bob.pipelines) DelayedSamplesCall (class in bob.pipelines) DelayedSampleSet (class in bob.pipelines) DelayedSampleSetCached (class in bob.pipelines)

E

estimator (bob.pipelines.SampleWrapper attribute) (bob.pipelines.xarray.Block attribute)

estimator_name (bob.pipelines.xarray.Block attribute) estimator_requires_fit() (in module bob.pipelines) extension (bob.pipelines.xarray.Block attribute)

F

features_dir (bob.pipelines.xarray.Block attribute) FileListDatabase (class in bob.pipelines) FileListToSamples (class in bob.pipelines) fit() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.ToDaskBag method) (bob.pipelines.xarray.DatasetPipeline method)

fit_extra_arguments (bob.pipelines.SampleWrapper attribute) fit_input (bob.pipelines.xarray.Block attribute) fit_kwargs (bob.pipelines.xarray.Block attribute) flatten_samplesets() (in module bob.pipelines) from_sample() (bob.pipelines.DelayedSample class method)

G

get_bob_tags() (in module bob.pipelines) get_max_jobs() (in module bob.pipelines.distributed.sge) get_no_worker_tasks_resource_restrictions() (bob.pipelines.distributed.sge.SchedulerResourceRestriction method) get_reader() (bob.pipelines.FileListDatabase method)

get_resource_requirements() (in module bob.pipelines.distributed.sge) getattr_nested() (in module bob.pipelines) graph (bob.pipelines.xarray.DatasetPipeline attribute) groups() (bob.pipelines.FileListDatabase method)

H

hash_string() (in module bob.pipelines)

I

input_dask_array (bob.pipelines.xarray.Block attribute) insert() (bob.pipelines.SampleSet method) interval (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute)

is_instance_nested() (in module bob.pipelines) is_picklable() (in module bob.pipelines) is_pipeline_wrapped() (in module bob.pipelines)

L

list_file() (bob.pipelines.FileListDatabase method) load() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.xarray.Block method) (in module bob.pipelines.xarray)

load_func (bob.pipelines.xarray.Block attribute) load_model() (bob.pipelines.CheckpointWrapper method) log (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute)

M

make_path() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.xarray.Block method) maximum (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute) minimum (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute) model_path (bob.pipelines.xarray.Block attribute)

module bob.pipelines bob.pipelines.distributed.sge bob.pipelines.transformers bob.pipelines.xarray

N

npartitions (bob.pipelines.ToDaskBag attribute)

O

output_attribute (bob.pipelines.SampleWrapper attribute) output_dims (bob.pipelines.xarray.Block attribute)

output_dtype (bob.pipelines.xarray.Block attribute) output_ndim (bob.pipelines.xarray.Block property)

P

periodic_callback (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute) predict() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.xarray.DatasetPipeline method)

predict_proba() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.xarray.DatasetPipeline method) protocol (bob.pipelines.FileListDatabase property) protocols() (bob.pipelines.FileListDatabase method)

R

recommendations() (bob.pipelines.distributed.sge.AdaptiveMultipleQueue method)

rows (bob.pipelines.CSVToSamples property)

S

Sample (class in bob.pipelines) SampleBatch (class in bob.pipelines) samples (bob.pipelines.DelayedSampleSet property) (bob.pipelines.DelayedSampleSetCached property) samples() (bob.pipelines.FileListDatabase method) samples_to_dataset() (in module bob.pipelines.xarray) SampleSet (class in bob.pipelines) SampleWrapper (class in bob.pipelines) save() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.xarray.Block method) (in module bob.pipelines.xarray) save_func (bob.pipelines.xarray.Block attribute) save_model() (bob.pipelines.CheckpointWrapper method) scale() (bob.pipelines.distributed.sge.SGEMultipleQueuesCluster method) scale_down() (bob.pipelines.distributed.sge.AdaptiveMultipleQueue method) (bob.pipelines.distributed.sge.SGEMultipleQueuesCluster method)

scale_up() (bob.pipelines.distributed.sge.AdaptiveMultipleQueue method) (bob.pipelines.distributed.sge.SGEMultipleQueuesCluster method) SchedulerResourceRestriction (class in bob.pipelines.distributed.sge) score() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.xarray.DatasetPipeline method) SGEIdiapJob (class in bob.pipelines.distributed.sge) SGEMultipleQueuesCluster (class in bob.pipelines.distributed.sge) sort() (bob.pipelines.FileListDatabase static method) steps (bob.pipelines.xarray.DatasetPipeline attribute) str_to_bool() (in module bob.pipelines.transformers) Str_To_Types() (in module bob.pipelines.transformers) submit_command (bob.pipelines.distributed.sge.SGEIdiapJob attribute)

T

ToDaskBag (class in bob.pipelines) transform() (bob.pipelines.CheckpointWrapper method) (bob.pipelines.DaskWrapper method) (bob.pipelines.SampleWrapper method) (bob.pipelines.ToDaskBag method) (bob.pipelines.xarray.DatasetPipeline method)

transform_extra_arguments (bob.pipelines.SampleWrapper attribute) transform_input (bob.pipelines.xarray.Block attribute) transformer (bob.pipelines.FileListDatabase property)

W

wait_count (bob.pipelines.distributed.sge.AdaptiveMultipleQueue attribute)

wrap() (in module bob.pipelines)