Struct TaskDetector 

pub struct TaskDetector<T: Float + Debug + Send + Sync + 'static> { /* private fields */ }

Task detector for continual learning

Implementations

impl<T: Float + Debug + Send + Sync + 'static> TaskDetector<T>

pub fn buffered_rounds(&self) -> usize

Number of rounds currently buffered.

pub fn detect_task_change( &mut self, updates: &[Array1<T>], round: usize, ) -> Result<bool>

Detect whether this round’s updates come from a different task.

Returns false (and buffers the round) until there is history to compare against. The comparison is the larger of

• the relative L2 shift ||mean_now - mean_history|| / max(||mean_history||, eps), and
• the cosine dissimilarity (1 - cos(mean_now, mean_history)) / 2,

so both a magnitude jump and a direction reversal are detected.

impl<T: Float + Debug + Send + Sync + 'static> TaskDetector<T>

pub fn new() -> Self

Create a new task detector

pub fn detection_threshold(&self) -> f64

Detection threshold on the normalised gradient shift.

pub fn set_detection_threshold(&mut self, threshold: f64) -> Result<()>

Replace the detection threshold.

pub fn detection_method(&self) -> TaskDetectionMethod

The configured detection method.

pub fn change_points(&self) -> &[ChangePoint]

Change points detected so far.

Trait Implementations

impl<T: Float + Debug + Send + Sync + 'static> Default for TaskDetector<T>

fn default() -> Self

Returns the “default value” for a type.