Skip to main content

Partitioner

oxigdal_streaming::transformations

Trait Partitioner 

Source 
pub trait Partitioner: Send + Sync {
    // Required methods
    fn partition(
        &self,
        element: &StreamElement,
        num_partitions: usize,
    ) -> Result<usize>;
    fn strategy(&self) -> PartitionStrategy;
}
Expand description

Partitioner trait.

Required Methods§

Source

fn partition( &self, element: &StreamElement, num_partitions: usize, ) -> Result<usize>

Determine the partition for an element.

Source

fn strategy(&self) -> PartitionStrategy

Get the partitioning strategy.

Implementors§