pub trait DataPartitionProvider: DynClone + Debug + Sync + Send {
fn part_size(&self) -> PartSize;
fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>);
}
Expand description
分片大小获取接口
Required Methods§
sourcefn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)
fn feedback(&self, feedback: DataPartitionProviderFeedback<'_>)
反馈分片大小结果