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

分片大小获取接口

Required Methods§

source

fn part_size(&self) -> PartSize

获取分片大小

source

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

反馈分片大小结果

Implementations on Foreign Types§

source§

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

source§

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

source§

impl<'a, T> DataPartitionProvider for &'a mut Twhere T: 'a + DataPartitionProvider + ?Sized, &'a mut T: DynClone + Debug + Sync + Send,

source§

impl<'a, T> DataPartitionProvider for &'a Twhere T: 'a + DataPartitionProvider + ?Sized, &'a T: DynClone + Debug + Sync + Send,

source§

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

Implementors§