Trait DataPartitionProvider

pub trait DataPartitionProvider:
    DynClone
    + Debug
    + Sync
    + Send {
    // Required methods
    fn part_size(&self) -> PartSize;
    fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>);
}

分片大小获取接口

Required Methods

fn part_size(&self) -> PartSize

获取分片大小

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

反馈分片大小结果

Implementations on Foreign Types

impl<'a, T: 'a + DataPartitionProvider + ?Sized> DataPartitionProvider for &'a T

where &'a T: DynClone + Debug + Sync + Send,

fn part_size(&self) -> PartSize

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

impl<'a, T: 'a + DataPartitionProvider + ?Sized> DataPartitionProvider for &'a mut T

where &'a mut T: DynClone + Debug + Sync + Send,

fn part_size(&self) -> PartSize

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

impl<T: DataPartitionProvider + ?Sized> DataPartitionProvider for Box<T>

where Box<T>: DynClone + Debug + Sync + Send,

fn part_size(&self) -> PartSize

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

impl<T: DataPartitionProvider + ?Sized> DataPartitionProvider for Rc<T>

where Rc<T>: DynClone + Debug + Sync + Send,

fn part_size(&self) -> PartSize

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

impl<T: DataPartitionProvider + ?Sized> DataPartitionProvider for Arc<T>

where Arc<T>: DynClone + Debug + Sync + Send,

fn part_size(&self) -> PartSize

fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)

Implementors

impl DataPartitionProvider for FixedDataPartitionProvider

impl<P: DataPartitionProvider + Clone> DataPartitionProvider for LimitedDataPartitionProvider<P>

impl<P: DataPartitionProvider + Clone> DataPartitionProvider for MultiplyDataPartitionProvider<P>