Struct FederatedSplitCoordinator 

pub struct FederatedSplitCoordinator { /* private fields */ }

Federated split coordination (no raw data leaves nodes)

Implementations

impl FederatedSplitCoordinator

pub fn new(strategy: FederatedSplitStrategy) -> Self

Create a new coordinator with the given strategy

pub fn strategy(&self) -> &FederatedSplitStrategy

Get the current strategy

pub fn compute_split_plan( &self, manifests: &[NodeSplitManifest], ) -> Result<Vec<NodeSplitInstruction>>

Compute split instructions for each node (runs on coordinator)

The coordinator only sees manifests (metadata), never raw data.

pub fn execute_local_split( dataset: &ArrowDataset, instruction: &NodeSplitInstruction, ) -> Result<DatasetSplit>

Execute split locally (runs on each node)

This function runs on the data-owning node - raw data never leaves.

pub fn verify_global_split( manifests: &[NodeSplitManifest], ) -> Result<GlobalSplitReport>

Verify global split quality (runs on coordinator)

Only examines manifests - no access to raw data.

Trait Implementations

impl Clone for FederatedSplitCoordinator

fn clone(&self) -> FederatedSplitCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FederatedSplitCoordinator

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

Formats the value using the given formatter.