Trait vector::sinks::prelude::Partitioner

pub trait Partitioner {
    type Item;
    type Key: Clone + Eq + Hash;

    // Required method
    fn partition(&self, item: &Self::Item) -> Self::Key;
}

Calculate partitions for an item

This trait allows us to express in the type system that for some Item we are able to calculate a Key that identifies that item.

Required Associated Types

type Item

type Key: Clone + Eq + Hash

Required Methods

fn partition(&self, item: &Self::Item) -> Self::Key

Partition the Item by calculating its Key

The resulting key should ideally be unique for an Item or arrived at in such a way that if two distinct Item instances partition to the same key they are mergeable if put into the same collection by this key.

Implementors

impl Partitioner for EventPartitioner

type Item = Event

type Key = Option<Arc<str>>

impl Partitioner for ChroniclePartitioner

type Item = Event

type Key = Option<ChroniclePartitionKey>

impl Partitioner for S3KeyPartitioner

type Item = Event

type Key = Option<S3PartitionKey>

impl Partitioner for KeyPartitioner

type Item = Event

type Key = Option<String>