Struct PredictablePluginEProcess 

pub struct PredictablePluginEProcess {
    pub process: EProcess,
}

Sequential universal inference over a stream of batches with a PREDICTABLE plug-in: at batch t the alternative parameters were fit using only data before t, the null sup is taken on batch t, and the per-batch ratios compound into an e-process. This is the streaming / optional-stopping form the corpus-scale pipeline (#973 shards) needs — evidence is resumable: serialize EProcess, keep absorbing on the next shard.

Fields

process: EProcess

Implementations

impl PredictablePluginEProcess

pub fn new() -> Self

pub fn try_absorb_batch( &mut self, log_lik_alternative_prefit: f64, log_lik_null_sup_on_batch: f64, ) -> Result<(), String>

Absorb one batch. The caller guarantees the alternative was fit WITHOUT batch-t data (predictability — this is what makes the product a supermartingale; violating it voids the guarantee, which is why the SAE integration must hand this function the PREVIOUS shard’s fitted dictionary, never the current one).

Trait Implementations

impl Clone for PredictablePluginEProcess

fn clone(&self) -> PredictablePluginEProcess

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PredictablePluginEProcess

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PredictablePluginEProcess

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PredictablePluginEProcess

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PredictablePluginEProcess

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.