Index _ | A | B | C | D | E | F | G | H | I | K | L | M | N | O | P | Q | R | S | T | V | W _ __call__() (test_split._GriddedArm method) __iter__() (dau_scheduler.rows.RowSource method) (dau_scheduler.RowSource method) __len__() (dau_scheduler.rows.RowSource method) (dau_scheduler.RowSource method) __post_init__() (dau_scheduler.RowBatch method) (dau_scheduler.RowRange method) (dau_scheduler.rows.RowBatch method) (dau_scheduler.rows.RowRange method) __repr__() (dau_scheduler.RowBatch method) (dau_scheduler.rows.RowBatch method) __slots__ (dau_scheduler.rows.RowSource attribute) (dau_scheduler.RowSource attribute) __version__ (in module dau_scheduler) _component() (dau_scheduler.profile.ProfileCache static method) (dau_scheduler.ProfileCache static method) _costs_are_sane() (dau_scheduler.profile.QueryProfile method) (dau_scheduler.QueryProfile method) _execute() (in module test_split) _figures_are_sane() (dau_scheduler.split.SplitExecution method) (dau_scheduler.SplitExecution method) _fold_groups() (in module test_merge) _fold_stats() (in module test_merge) _GriddedArm (class in test_split) _groups() (in module test_merge) _halves() (in module test_merge) _link_path() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) _path() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) _profile() (in module test_profile) _rate_is_usable() (dau_scheduler.LinkRate method) (dau_scheduler.profile.LinkRate method) _reductions() (in module test_merge) _rule() (in module test_split) _run() (in module test_split) _runs() (in module test_merge) _seconds_is_finite() (dau_scheduler.NodeCost method) (dau_scheduler.profile.NodeCost method) _share_is_a_fraction() (dau_scheduler.posture.WorkSplit method) (dau_scheduler.WorkSplit method) _split() (in module test_split) _stats() (in module test_merge) _totals() (in module test_merge) _under_root() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) A ADDITIVE (in module dau_scheduler) (in module dau_scheduler.merge) AGGREGATE_REFUSALS (in module dau_scheduler) (in module dau_scheduler.merge) as_row_source() (in module dau_scheduler) (in module dau_scheduler.rows) B batch_count() (in module dau_scheduler) (in module dau_scheduler.posture) BLOCK (in module test_readme) BOUNDARY_STATS (in module dau_scheduler) (in module dau_scheduler.merge) bytes_per_second (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) C check() (dau_scheduler.LinkRate method) (dau_scheduler.NodeCost method) (dau_scheduler.posture.WorkSplit method) (dau_scheduler.profile.LinkRate method) (dau_scheduler.profile.NodeCost method) (dau_scheduler.profile.QueryProfile method) (dau_scheduler.QueryProfile method) (dau_scheduler.WorkSplit method) check_split() (in module dau_scheduler) (in module dau_scheduler.merge) combine (dau_scheduler.merge.MergeRule attribute) (dau_scheduler.MergeRule attribute) count (test_merge.Group attribute) (test_merge.Stats attribute) D dau_scheduler module dau_scheduler.errors module dau_scheduler.merge module dau_scheduler.posture module dau_scheduler.profile module dau_scheduler.rows module dau_scheduler.split module DEFERRED_MEAN (in module dau_scheduler) (in module dau_scheduler.merge) device (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) device_granularity (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) device_rows (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) device_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) device_share (dau_scheduler.posture.WorkSplit attribute) (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) (dau_scheduler.WorkSplit attribute) E engine_version (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) entries() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) estimate() (dau_scheduler.HostCost method) (dau_scheduler.posture.HostCost method) (dau_scheduler.profile.QueryProfile method) (dau_scheduler.QueryProfile method) execute_split() (in module dau_scheduler) (in module dau_scheduler.split) F failed (dau_scheduler.merge.MergeRule attribute) (dau_scheduler.MergeRule attribute) first (test_merge.Stats attribute) fixed_seconds (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) G get() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) get_link_rate() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) Group (class in test_merge) H host (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) host_identity() (in module dau_scheduler) (in module dau_scheduler.profile) host_rows (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) host_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) HostCost (class in dau_scheduler) (class in dau_scheduler.posture) I is_stale() (dau_scheduler.LinkRate method) (dau_scheduler.profile.LinkRate method) is_stale_for() (dau_scheduler.profile.QueryProfile method) (dau_scheduler.QueryProfile method) K key (test_merge.Group attribute) (test_merge.Stats attribute) KNEE_BYTES (in module test_posture) L last (test_merge.Stats attribute) LinkRate (class in dau_scheduler) (class in dau_scheduler.profile) M materialize_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) maximum (test_merge.Stats attribute) measured_at (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) merge() (dau_scheduler.merge.MergeRule method) (dau_scheduler.MergeRule method) merge_keyed_groups() (in module dau_scheduler) (in module dau_scheduler.merge) merge_ordered_groups() (in module dau_scheduler) (in module dau_scheduler.merge) merge_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) merge_sorted_runs() (in module dau_scheduler) (in module dau_scheduler.merge) merge_top_k() (in module dau_scheduler) (in module dau_scheduler.merge) merge_totals() (in module dau_scheduler) (in module dau_scheduler.merge) mergeable (dau_scheduler.merge.MergeRule attribute) (dau_scheduler.MergeRule attribute) MergeRule (class in dau_scheduler) (class in dau_scheduler.merge) minimum (test_merge.Stats attribute) model_config (dau_scheduler.LinkRate attribute) (dau_scheduler.NodeCost attribute) (dau_scheduler.posture.WorkSplit attribute) (dau_scheduler.profile.LinkRate attribute) (dau_scheduler.profile.NodeCost attribute) (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) (dau_scheduler.WorkSplit attribute) module dau_scheduler dau_scheduler.errors dau_scheduler.merge dau_scheduler.posture dau_scheduler.profile dau_scheduler.rows dau_scheduler.split test_all test_merge test_posture test_profile test_readme test_rows test_split N node (dau_scheduler.NodeCost attribute) (dau_scheduler.profile.NodeCost attribute) NodeCost (class in dau_scheduler) (class in dau_scheduler.profile) nodes (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) O OUTPUTS (in module test_split) overlap_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) P per_row_seconds (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) plan_key (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) plan_split() (in module dau_scheduler) (in module dau_scheduler.posture) posture (dau_scheduler.posture.WorkSplit attribute) (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) (dau_scheduler.WorkSplit attribute) Posture (in module dau_scheduler) (in module dau_scheduler.posture) PostureError, [1], [2] POSTURES (in module dau_scheduler) (in module dau_scheduler.posture) predicted_speedup (dau_scheduler.posture.WorkSplit attribute) (dau_scheduler.WorkSplit attribute) profile_from_spans() (in module dau_scheduler) (in module dau_scheduler.profile) ProfileCache (class in dau_scheduler) (class in dau_scheduler.profile) put() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) put_link_rate() (dau_scheduler.profile.ProfileCache method) (dau_scheduler.ProfileCache method) Q QUERY (in module test_split) QueryProfile (class in dau_scheduler) (class in dau_scheduler.profile) R rationale (dau_scheduler.posture.WorkSplit attribute) (dau_scheduler.WorkSplit attribute) README (in module test_readme) refusal (dau_scheduler.merge.MergeRule attribute) (dau_scheduler.MergeRule attribute) result (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) root (dau_scheduler.profile.ProfileCache attribute) (dau_scheduler.ProfileCache attribute) row_granularity (test_split._GriddedArm attribute) RowBatch (class in dau_scheduler) (class in dau_scheduler.rows) RowRange (class in dau_scheduler) (class in dau_scheduler.rows) rows (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) (dau_scheduler.RowBatch attribute) (dau_scheduler.rows.RowBatch attribute) ROWS (in module test_merge) (in module test_split) RowSource (class in dau_scheduler) (class in dau_scheduler.rows) S samples (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) scales_with_rows (dau_scheduler.NodeCost attribute) (dau_scheduler.profile.NodeCost attribute) seconds (dau_scheduler.NodeCost attribute) (dau_scheduler.profile.NodeCost attribute) selectivity (dau_scheduler.profile.QueryProfile attribute) (dau_scheduler.QueryProfile attribute) SHARES (in module test_split) slice() (dau_scheduler.RowBatch method) (dau_scheduler.RowRange method) (dau_scheduler.rows.RowBatch method) (dau_scheduler.rows.RowRange method) (dau_scheduler.rows.RowSource method) (dau_scheduler.RowSource method) SplitArm (in module dau_scheduler) (in module dau_scheduler.split) SplitError, [1] SplitExecution (class in dau_scheduler) (class in dau_scheduler.split) start (dau_scheduler.RowBatch attribute) (dau_scheduler.RowRange attribute) (dau_scheduler.rows.RowBatch attribute) (dau_scheduler.rows.RowRange attribute) (dau_scheduler.rows.RowSource attribute) (dau_scheduler.RowSource attribute) Stats (class in test_merge) stop (dau_scheduler.RowBatch property) (dau_scheduler.RowRange attribute) (dau_scheduler.rows.RowBatch property) (dau_scheduler.rows.RowRange attribute) (dau_scheduler.rows.RowSource attribute) (dau_scheduler.RowSource attribute) T terminal (dau_scheduler.merge.MergeRule attribute) (dau_scheduler.MergeRule attribute) (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) test_a_batch_repr_does_not_print_the_table() (in module test_rows) test_a_blocking_arm_overlaps_the_other() (in module test_split) test_a_broadcast_build_side_reaches_both_arms_whole() (in module test_split) test_a_copied_link_rate_is_checked_where_it_is_used() (in module test_profile) test_a_copied_profile_is_checked_where_it_is_used() (in module test_profile) test_a_copied_split_is_checked_before_anything_runs() (in module test_split) test_a_declared_aggregate_passes_the_gate() (in module test_split) test_a_declared_mean_passes_when_the_partials_carry_it() (in module test_merge) test_a_degenerate_share_launches_one_engine() (in module test_split) test_a_derived_output_is_recomputed_from_the_merged_totals() (in module test_merge) test_a_failed_arm_is_not_merged_into_a_short_answer() (in module test_merge) test_a_failed_arm_reports_its_failure_rather_than_a_short_answer() (in module test_split) test_a_link_rate_goes_stale_by_age_and_an_undated_one_is_stale() (in module test_profile) test_a_link_rate_is_keyed_by_host_device_and_transfer_size_and_round_trips() (in module test_profile) test_a_link_rate_refuses_numbers_it_cannot_price_with() (in module test_profile) test_a_mean_survives_only_as_a_sum_and_a_count() (in module test_merge) test_a_measured_profile_supplies_the_host_figure() (in module test_posture) test_a_merged_top_k_keeps_the_earliest_arrival_tie_break() (in module test_merge) test_a_negative_limit_is_refused() (in module test_merge) test_a_node_cost_refuses_a_nan() (in module test_profile) test_a_profile_goes_stale_under_a_different_engine() (in module test_profile) test_a_profile_goes_stale_when_the_row_count_moves_too_far() (in module test_profile) test_a_profile_needs_timings_and_a_row_count() (in module test_profile) test_a_profile_prices_a_row_count() (in module test_posture) test_a_profile_refuses_numbers_it_cannot_price_with() (in module test_profile) test_a_range_cannot_be_inverted() (in module test_rows) test_a_range_is_two_integers_at_any_row_count() (in module test_rows) test_a_range_refuses_the_arm_that_reads_values() (in module test_rows) test_a_refusal_arrives_before_either_arm_starts() (in module test_split) test_a_reversed_or_negative_span_is_a_reporting_fault_not_a_cheap_node() (in module test_profile) test_a_row_batch_refuses_a_negative_start() (in module test_rows) test_a_row_range_refuses_the_arm_that_reads_values() (in module test_split) test_a_row_range_splits_a_table_neither_arm_reads() (in module test_split) test_a_rule_with_no_combine_says_so() (in module test_merge) test_a_sequence_is_wrapped_in_place() (in module test_rows) test_a_shape_that_cannot_split_refuses_before_any_aggregate() (in module test_merge) test_a_slice_carries_absolute_offsets() (in module test_rows) test_a_split_pays_least_when_one_engine_dominates() (in module test_posture) test_a_sub_range_may_be_empty_or_the_whole_parent() (in module test_rows) test_a_sub_range_must_lie_inside_its_parent() (in module test_rows) test_a_top_k_merges_two_k_lists() (in module test_merge) test_a_whole_table_slice_does_not_copy() (in module test_rows) test_adaptive_refuses_instead_of_falling_back() (in module test_posture) test_all module test_an_empty_cache_directory_lists_nothing() (in module test_profile) test_an_empty_merge_answers() (in module test_merge) test_an_empty_table_still_answers() (in module test_split) test_an_execution_report_refuses_impossible_figures() (in module test_split) test_an_invalid_granularity_is_refused_before_the_rows_are_consumed() (in module test_split) test_an_iterator_is_drained_because_it_cannot_serve_two_arms() (in module test_rows) test_an_unknown_aggregate_is_refused_rather_than_summed() (in module test_merge) test_an_unrecorded_engine_version_is_unknown_and_therefore_stale() (in module test_profile) test_arms_that_arrive_out_of_order_refuse_the_ordered_merge() (in module test_merge) test_batch_count_rejects_impossible_inputs() (in module test_posture) test_batches_are_never_split_below_the_knee() (in module test_posture) test_boundary_stats_are_declarable_too() (in module test_merge) test_boundary_stats_come_from_the_ranges_that_own_them() (in module test_merge) test_cache_entries_stay_directly_under_the_root() (in module test_profile) test_check_split_refuses_a_distinct_count_by_name() (in module test_merge) test_check_split_refuses_a_mean_by_name() (in module test_merge) test_collaborative_balances_the_engines() (in module test_posture) test_collaborative_refuses_rather_than_inventing_a_cost_model() (in module test_posture) test_collaborative_rejects_nonpositive_estimates() (in module test_posture) test_cpu_and_offload_need_no_estimates() (in module test_posture) test_every_node_is_kept_with_its_own_cost() (in module test_profile) test_every_posture_is_reachable_or_refused_by_name() (in module test_posture) test_fixed_cost_is_not_scaled_by_the_row_count() (in module test_profile) test_fixed_nodes_count_their_overlap_once() (in module test_profile) test_gaps_between_nodes_are_real_elapsed_cost() (in module test_profile) test_iterating_a_range_reaches_the_same_refusal() (in module test_rows) test_keyed_groups_merge_over_the_whole_key_set() (in module test_merge) test_merge module test_models_refuse_fields_they_do_not_declare() (in module test_profile) test_offload_is_not_the_wall_clock_optimum() (in module test_posture) test_one_partial_is_the_answer() (in module test_merge) test_ordered_groups_fold_the_group_that_straddles_the_boundary() (in module test_merge) test_overlapping_nodes_are_not_summed_into_elapsed_time() (in module test_profile) test_posture module test_profile module test_readme module test_resident_wants_one_batch_at_any_size() (in module test_posture) test_rows module test_small_payloads_are_not_split_below_the_knee() (in module test_posture) test_sorted_runs_merge_stably() (in module test_merge) test_split module test_split_validates_its_own_fields() (in module test_posture) test_streamed_reproduces_the_measured_optimum() (in module test_posture) test_sums_and_counts_add() (in module test_merge) test_the_accounting_covers_the_marshalling_it_makes_the_caller_pay() (in module test_split) test_the_arms_split_the_rows_at_the_planned_share() (in module test_split) test_the_boundary_snaps_to_the_device_granularity() (in module test_split) test_the_cache_root_expands_a_home_directory() (in module test_profile) test_the_cache_round_trips_by_plan_and_host() (in module test_profile) test_the_callers_own_rows_reach_the_arm_uncopied() (in module test_split) test_the_closed_form_lands_on_a_measured_optimum() (in module test_posture) test_the_degenerate_shares_survive_a_granularity() (in module test_split) test_the_device_fixed_cost_moves_the_balance_and_can_rule_the_split_out() (in module test_posture) test_the_documented_surface_is_exported() (in module test_all) test_the_engine_version_is_not_part_of_the_key() (in module test_profile) test_the_host_is_part_of_the_identity() (in module test_profile) test_the_knee_has_no_default() (in module test_posture) test_the_leading_rows_go_to_the_first_arm() (in module test_split) test_the_merged_answer_is_the_unsplit_answer_at_every_share() (in module test_split) test_the_order_statistics_and_moments_are_refused_by_name() (in module test_merge) test_the_profile_prices_a_split() (in module test_profile) test_the_readme_examples_run_in_order() (in module test_readme) test_the_two_arms_are_in_flight_together() (in module test_split) test_the_two_optima_are_opposite() (in module test_posture) test_unknown_posture_is_refused() (in module test_posture) test_unsorted_rows_refuse_the_ordered_merge() (in module test_merge) total (test_merge.Group attribute) transfer_bytes (dau_scheduler.LinkRate attribute) (dau_scheduler.profile.LinkRate attribute) V values() (dau_scheduler.RowBatch method) (dau_scheduler.rows.RowBatch method) (dau_scheduler.rows.RowSource method) (dau_scheduler.RowSource method) W wall_seconds (dau_scheduler.split.SplitExecution attribute) (dau_scheduler.SplitExecution attribute) WorkSplit (class in dau_scheduler) (class in dau_scheduler.posture)