mozetl.bhr_collection package

Submodules

mozetl.bhr_collection.bhr_collection module

class mozetl.bhr_collection.bhr_collection.GrowToFitList(iterable=(), /)[source]

Bases: list

class mozetl.bhr_collection.bhr_collection.ProfileProcessor(config)[source]

Bases: object

debug_dump(dump_str)[source]
ingest(data, usage_hours_by_date)[source]
ingest_processed_profile(profile)[source]
ingest_row(row)[source]
pre_ingest_row(row)[source]
process_date(date)[source]
process_into_profile()[source]
process_into_split_profile()[source]
process_thread(thread)[source]
class mozetl.bhr_collection.bhr_collection.UniqueKeyedTable(get_default_from_key, key_names=())[source]

Bases: object

get_items()[source]
index_to_item(index)[source]
inner_struct_of_arrays(items)[source]
key_to_index(key)[source]
key_to_item(key)[source]
sorted_struct_of_arrays(key)[source]
struct_of_arrays()[source]
mozetl.bhr_collection.bhr_collection.debug_print_rdd_count(rdd, really=False)[source]
mozetl.bhr_collection.bhr_collection.decode_response(response)[source]
mozetl.bhr_collection.bhr_collection.deep_merge(original, overrides)[source]
mozetl.bhr_collection.bhr_collection.etl_job_daily(sc, sql_context, config=None)[source]
mozetl.bhr_collection.bhr_collection.fetch_url(url)[source]
mozetl.bhr_collection.bhr_collection.filter_hang(hang, config)[source]
mozetl.bhr_collection.bhr_collection.get_all_hangs(pings, config)[source]
mozetl.bhr_collection.bhr_collection.get_data(sc, sql_context, config, date, end_date=None)[source]
mozetl.bhr_collection.bhr_collection.get_default_lib(name)[source]
mozetl.bhr_collection.bhr_collection.get_default_thread(name, minimal_sample_table)[source]
mozetl.bhr_collection.bhr_collection.get_file_url(module, config)[source]
mozetl.bhr_collection.bhr_collection.get_frames_by_module(hangs)[source]
mozetl.bhr_collection.bhr_collection.get_frames_with_hang_id(hang_tuple)[source]
mozetl.bhr_collection.bhr_collection.get_grouped_sums_and_counts(hangs, usage_hours_by_date, config)[source]
mozetl.bhr_collection.bhr_collection.get_ping_properties(ping, properties)[source]
mozetl.bhr_collection.bhr_collection.get_prop(val, prop)[source]
mozetl.bhr_collection.bhr_collection.get_symbolication_mapping_by_hang_id(joined)[source]
mozetl.bhr_collection.bhr_collection.get_usage_hours(ping)[source]
mozetl.bhr_collection.bhr_collection.get_usage_hours_by_date(pings)[source]
mozetl.bhr_collection.bhr_collection.hexify(num)[source]
mozetl.bhr_collection.bhr_collection.make_sym_map(data)[source]
mozetl.bhr_collection.bhr_collection.map_to_frame_info(hang)[source]
mozetl.bhr_collection.bhr_collection.map_to_hang_data(hang, config)[source]
mozetl.bhr_collection.bhr_collection.merge_hang_data(a, b)[source]
mozetl.bhr_collection.bhr_collection.merge_number_dicts(a, b)[source]
mozetl.bhr_collection.bhr_collection.merge_usage_hours(a, b)[source]
mozetl.bhr_collection.bhr_collection.module_to_string(module)[source]
mozetl.bhr_collection.bhr_collection.ping_is_valid(ping)[source]
mozetl.bhr_collection.bhr_collection.print_progress(job_start, iterations, current_iteration, iteration_start, iteration_name)[source]
mozetl.bhr_collection.bhr_collection.process_frame(frame, modules)[source]
mozetl.bhr_collection.bhr_collection.process_hang(hang)[source]
mozetl.bhr_collection.bhr_collection.process_hang_key(key, processed_modules)[source]
mozetl.bhr_collection.bhr_collection.process_hang_value(key, val, usage_hours_by_date)[source]
mozetl.bhr_collection.bhr_collection.process_hangs(ping, config)[source]
mozetl.bhr_collection.bhr_collection.process_module(module, offsets, config)[source]
mozetl.bhr_collection.bhr_collection.process_modules(frames_by_module, config)[source]
mozetl.bhr_collection.bhr_collection.properties_are_not_none(ping, properties)[source]
mozetl.bhr_collection.bhr_collection.read_file(name, config)[source]
mozetl.bhr_collection.bhr_collection.reconstruct_stack(string_array, func_table, stack_table, lib_table, stack_index)[source]
mozetl.bhr_collection.bhr_collection.shallow_merge(original, overrides)[source]
mozetl.bhr_collection.bhr_collection.string_to_module(string_module)[source]
mozetl.bhr_collection.bhr_collection.symbolicate_hang_keys(hangs, processed_modules)[source]
mozetl.bhr_collection.bhr_collection.symbolicate_hang_with_mapping(joined)[source]
mozetl.bhr_collection.bhr_collection.symbolicate_stacks(stack, processed_modules)[source]
mozetl.bhr_collection.bhr_collection.time_code(name, callback)[source]
mozetl.bhr_collection.bhr_collection.to_struct_of_arrays(a)[source]
mozetl.bhr_collection.bhr_collection.transform_pings(_, pings, config)[source]
mozetl.bhr_collection.bhr_collection.tupleize_annotation_list(d)[source]
mozetl.bhr_collection.bhr_collection.write_file(name, stuff, config)[source]

Module contents