pub struct DistributedPlanner { /* private fields */ }Implementations§
Source§impl DistributedPlanner
impl DistributedPlanner
Sourcepub fn plan_query_stages<'a>(
&'a mut self,
job_id: &'a str,
execution_plan: Arc<dyn ExecutionPlan>,
) -> Result<Vec<Arc<ShuffleWriterExec>>>
pub fn plan_query_stages<'a>( &'a mut self, job_id: &'a str, execution_plan: Arc<dyn ExecutionPlan>, ) -> Result<Vec<Arc<ShuffleWriterExec>>>
Returns a vector of ExecutionPlans, where the root node is a ShuffleWriterExec. Plans that depend on the input of other plans will have leaf nodes of type UnresolvedShuffleExec. A ShuffleWriterExec is created whenever the partitioning changes.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for DistributedPlanner
impl RefUnwindSafe for DistributedPlanner
impl Send for DistributedPlanner
impl Sync for DistributedPlanner
impl Unpin for DistributedPlanner
impl UnwindSafe for DistributedPlanner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request