pub trait ExchangeSource: Send + Debug {
// Required methods
fn take_data(
&mut self,
) -> impl Future<Output = Result<Option<DataChunk>>> + '_;
fn get_task_id(&self) -> TaskId;
}Expand description
Each ExchangeSource maps to one task, it takes the execution result from task chunk by chunk.
Required Methods§
fn take_data(&mut self) -> impl Future<Output = Result<Option<DataChunk>>> + '_
sourcefn get_task_id(&self) -> TaskId
fn get_task_id(&self) -> TaskId
Get upstream task id.
Object Safety§
This trait is not object safe.