accumulate_correlation_states

datafusion_functions_aggregate::correlation

Function accumulate_correlation_states 

Source 
fn accumulate_correlation_states(
    group_indices: &[usize],
    state_arrays: (&UInt64Array, &Float64Array, &Float64Array, &Float64Array, &Float64Array, &Float64Array),
    value_fn: impl FnMut(usize, u64, &[f64]),
)
Expand description

Specialized version of accumulate_multiple for correlation’s merge_batch

Note: Arrays in state_arrays should not have null values, because they are all intermediate states created within the accumulator, instead of inputs from outside.