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> DataPartitionProvider for &'a T

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

fn part_size(&self) -> PartSize

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

impl<'a, T> DataPartitionProvider for &'a mut T

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

fn part_size(&self) -> PartSize

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

impl<T> DataPartitionProvider for Box<T>

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

fn part_size(&self) -> PartSize

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

impl<T> DataPartitionProvider for Rc<T>

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

fn part_size(&self) -> PartSize

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

impl<T> DataPartitionProvider for Arc<T>

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

fn part_size(&self) -> PartSize

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

Implementors

impl DataPartitionProvider for FixedDataPartitionProvider

impl<P> DataPartitionProvider for LimitedDataPartitionProvider<P>

where P: DataPartitionProvider + Clone,

impl<P> DataPartitionProvider for MultiplyDataPartitionProvider<P>

where P: DataPartitionProvider + Clone,