CodeEntropy.levels.execution package

Submodules

• CodeEntropy.levels.execution.chunks module
  • chunk_frame_indices()
• CodeEntropy.levels.execution.policy module
  • ExecutionPolicy
    • ExecutionPolicy.frame_chunk_size()
    • ExecutionPolicy.max_frame_chunk_size
    • ExecutionPolicy.max_frame_in_flight_multiplier
    • ExecutionPolicy.max_frame_in_flight_tasks()
    • ExecutionPolicy.min_frame_chunk_size
    • ExecutionPolicy.requested_worker_count()
    • ExecutionPolicy.target_frame_chunks_per_worker
• CodeEntropy.levels.execution.reducers module
  • CovarianceReducer
    • CovarianceReducer.merge_chunk_partial()
    • CovarianceReducer.reduce_frame_map_output()
    • CovarianceReducer.reduce_frame_output()
  • NeighborReducer
    • NeighborReducer.finalise()
    • NeighborReducer.initialise()
    • NeighborReducer.merge_chunk_partial()
    • NeighborReducer.reduce_frame_output()
  • incremental_mean()
  • merge_means()
  • stable_keys()
• CodeEntropy.levels.execution.scheduler module
  • FrameScheduler
    • FrameScheduler.execute()
• CodeEntropy.levels.execution.tasks module
  • CovarianceChunkPartial
    • CovarianceChunkPartial.force
    • CovarianceChunkPartial.forcetorque
    • CovarianceChunkPartial.forcetorque_counts
    • CovarianceChunkPartial.frame_counts
    • CovarianceChunkPartial.torque
  • FrameChunkResult
    • FrameChunkResult.chunk_index
    • FrameChunkResult.covariance_partial
    • FrameChunkResult.frame_indices
    • FrameChunkResult.neighbor_samples
    • FrameChunkResult.neighbor_totals
  • FrameChunkTask
    • FrameChunkTask.chunk_index
    • FrameChunkTask.frame_indices
  • execute_frame_chunk_worker()
  • execute_frame_map_output()
  • get_worker_frame_universe()
  • incremental_mean_value()
  • make_frame_worker_shared_data()
  • reduce_frame_covariance_into_partial()

Module contents