Index

A

add() (merge_utils.merge_set.MergeChunk method) (meta.MergeMetaAll method) (meta.MergeMetaMax method) (meta.MergeMetaMin method) (meta.MergeMetaOverride method) (meta.MergeMetaSum method) (meta.MergeMetaUnion method) (meta.MergeMetaUnique method) (retriever.FileRetriever method)

add_file() (merge_utils.merge_set.MergeSet method) add_files() (merge_utils.merge_set.MergeSet method) add_pfn() (merge_utils.merge_rse.MergeRSEs method) add_replicas() (merge_utils.merge_rse.MergeRSEs method)

C

check_consistency() (merge_utils.merge_set.MergeSet method) check_errors() (merge_utils.merge_set.MergeSet method) check_missing() (merge_utils.merge_set.MergeSet method) check_path() (in module merge_utils.merge_rse) check_reachability() (merge_utils.merge_set.MergeSet method) check_remote_path() (in module merge_utils.merge_set) check_required() (in module meta) check_uniqueness() (merge_utils.merge_set.MergeSet method) check_validity() (merge_utils.merge_set.MergeSet method) CheckConfiguration module

checksum() (merge_utils.rucio_utils.RucioRetriever method) checksums() (in module do_merge) chunk() (merge_utils.merge_set.MergeChunk method) cleanup() (merge_utils.merge_rse.MergeRSEs method) config module connect() (merge_utils.merge_rse.MergeRSEs method) (merge_utils.metacat_utils.MetaCatRetriever method) (merge_utils.rucio_utils.RucioRetriever method) (retriever.FileRetriever method) (retriever.LocalRetriever method)

D

did (merge_utils.merge_set.MergeFile property) distance() (merge_utils.merge_rse.MergeRSE method) do_merge module

dupes (merge_utils.merge_set.MergeSet property) (merge_utils.rucio_utils.RucioRetriever property) (retriever.FileRetriever property)

F

FileRetriever (class in retriever) files (merge_utils.merge_set.MergeSet property) (merge_utils.rucio_utils.RucioRetriever property) (retriever.FileRetriever property)

find_fcl() (in module merge_utils.io_utils) fix() (in module meta) format (merge_utils.merge_set.MergeFile property)

G

get_chunks() (scheduler.JobScheduler method) (scheduler.JustinScheduler method) (scheduler.LocalScheduler method) get_cmd() (scheduler.JustinScheduler method) get_distances() (in module merge_utils.justin_utils) get_fields() (merge_utils.merge_set.MergeFile method) get_inputs() (in module merge_utils.io_utils)

get_metadata() (retriever.LocalRetriever method) get_pfns() (merge_utils.merge_rse.MergeRSEs method) get_ping() (merge_utils.merge_rse.MergeRSE method) get_timestamp() (in module merge_utils.io_utils) group_count() (merge_utils.merge_set.MergeSet method) group_size() (merge_utils.merge_set.MergeSet method) groups() (merge_utils.merge_set.MergeSet method)

H

hash (merge_utils.merge_set.MergeSet property)

I

input_batches() (merge_utils.metacat_utils.MetaCatRetriever method) (merge_utils.rucio_utils.RucioRetriever method) (retriever.FileRetriever method) (retriever.LocalRetriever method)

inputs (merge_utils.merge_set.MergeChunk property)

J

JobScheduler (class in scheduler) json (merge_utils.merge_set.MergeChunk property)

json_name() (scheduler.JustinScheduler method) (scheduler.LocalScheduler method) JustinScheduler (class in scheduler)

L

list_extensions() (in module merge_utils.metacat_utils) list_field_values() (in module merge_utils.metacat_utils) load() (in module config)

LocalRetriever (class in retriever) LocalScheduler (class in scheduler) log_dict() (in module merge_utils.io_utils) log_list() (in module merge_utils.io_utils)

M

main() (in module do_merge) (in module merge_utils.__main__) make_name() (in module meta) merge() (in module do_merge) merge_hadd() (in module do_merge) merge_hdf5() (in module do_merge) merge_lar() (in module do_merge) merge_tar() (in module do_merge) merge_utils.__main__ module merge_utils.io_utils module merge_utils.justin_utils module merge_utils.merge_rse module merge_utils.merge_set module merge_utils.metacat_utils module merge_utils.rucio_utils module MergeChunk (class in merge_utils.merge_set) merged_keys() (in module meta) MergeFile (class in merge_utils.merge_set) MergeMetaAll (class in meta) MergeMetaMax (class in meta) MergeMetaMin (class in meta) MergeMetaNameDict (class in meta) MergeMetaOverride (class in meta)

MergeMetaSum (class in meta) MergeMetaUnion (class in meta) MergeMetaUnique (class in meta) MergeRSE (class in merge_utils.merge_rse) MergeRSEs (class in merge_utils.merge_rse) MergeSet (class in merge_utils.merge_set) meta module MetaCatRetriever (class in merge_utils.metacat_utils) metadata (merge_utils.merge_set.MergeChunk property) MetaValidator module MetaValidator() (in module MetaValidator) missing (merge_utils.rucio_utils.RucioRetriever property) (retriever.FileRetriever property) module CheckConfiguration config do_merge merge_utils.__main__ merge_utils.io_utils merge_utils.justin_utils merge_utils.merge_rse merge_utils.merge_set merge_utils.metacat_utils merge_utils.rucio_utils meta MetaValidator retriever scheduler

N

name (merge_utils.merge_set.MergeChunk property) (merge_utils.merge_set.MergeFile property)

namespace (merge_utils.merge_set.MergeFile property) nearest_site() (merge_utils.merge_rse.MergeRSE method)

O

optimize_pfns() (merge_utils.merge_rse.MergeRSEs method)

output_chunks() (merge_utils.rucio_utils.RucioRetriever method) (retriever.FileRetriever method)

P

parents (merge_utils.merge_set.MergeChunk property) parents() (in module meta)

pfns (merge_utils.merge_rse.MergeRSE property) pkg_dir() (in module merge_utils.io_utils) process() (merge_utils.rucio_utils.RucioRetriever method)

R

read_config_file() (in module merge_utils.io_utils) recursive_update() (in module config) retriever module RucioRetriever (class in merge_utils.rucio_utils)

run() (merge_utils.rucio_utils.RucioRetriever method) (retriever.FileRetriever method) (scheduler.JobScheduler method) (scheduler.JustinScheduler method) (scheduler.LocalScheduler method)

S

scheduler module set_log_level() (in module merge_utils.io_utils) set_rse_sites() (merge_utils.merge_rse.MergeRSEs method)

set_unreachable() (merge_utils.merge_set.MergeSet method) setup_log() (in module merge_utils.io_utils) site_pfns() (merge_utils.merge_rse.MergeRSEs method) size (merge_utils.merge_set.MergeSet property) src_dir() (in module merge_utils.io_utils)

T

tier (merge_utils.merge_set.MergeChunk property)

U

update() (in module config)

upload_cfg() (scheduler.JustinScheduler method)

V

valid (meta.MergeMetaAll property) (meta.MergeMetaMax property) (meta.MergeMetaMin property) (meta.MergeMetaOverride property) (meta.MergeMetaSum property) (meta.MergeMetaUnion property) (meta.MergeMetaUnique property)

validate() (in module meta) value (meta.MergeMetaAll property) (meta.MergeMetaUnion property)