pub struct DataFusionEngine { /* private fields */ }Expand description
A Datafusion based Kernel Engine
Implementations§
Source§impl DataFusionEngine
impl DataFusionEngine
pub fn new_from_session(session: &dyn Session) -> Arc<DataFusionEngine> ⓘ
pub fn new_from_context(ctx: Arc<TaskContext>) -> Arc<DataFusionEngine> ⓘ
pub fn new(ctx: Arc<TaskContext>, handle: Handle) -> DataFusionEngine
Trait Implementations§
Source§impl Clone for DataFusionEngine
impl Clone for DataFusionEngine
Source§fn clone(&self) -> DataFusionEngine
fn clone(&self) -> DataFusionEngine
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Engine for DataFusionEngine
impl Engine for DataFusionEngine
Source§fn evaluation_handler(&self) -> Arc<dyn EvaluationHandler> ⓘ
fn evaluation_handler(&self) -> Arc<dyn EvaluationHandler> ⓘ
Get the connector provided
EvaluationHandler.Source§fn storage_handler(&self) -> Arc<dyn StorageHandler> ⓘ
fn storage_handler(&self) -> Arc<dyn StorageHandler> ⓘ
Get the connector provided
StorageHandlerSource§fn json_handler(&self) -> Arc<dyn JsonHandler> ⓘ
fn json_handler(&self) -> Arc<dyn JsonHandler> ⓘ
Get the connector provided
JsonHandler.Source§fn parquet_handler(&self) -> Arc<dyn ParquetHandler> ⓘ
fn parquet_handler(&self) -> Arc<dyn ParquetHandler> ⓘ
Get the connector provided
ParquetHandler.Auto Trait Implementations§
impl !RefUnwindSafe for DataFusionEngine
impl !UnwindSafe for DataFusionEngine
impl Freeze for DataFusionEngine
impl Send for DataFusionEngine
impl Sync for DataFusionEngine
impl Unpin for DataFusionEngine
impl UnsafeUnpin for DataFusionEngine
Blanket Implementations§
Source§impl<T> AsAny for T
impl<T> AsAny for T
Source§fn any_ref(&self) -> &(dyn Any + Sync + Send + 'static)
fn any_ref(&self) -> &(dyn Any + Sync + Send + 'static)
Obtains a
dyn Any reference to the object: Read moreSource§fn as_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send> ⓘ
fn as_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send> ⓘ
Obtains an
Arc<dyn Any> reference to the object: Read moreSource§fn into_any(self: Box<T>) -> Box<dyn Any + Sync + Send>
fn into_any(self: Box<T>) -> Box<dyn Any + Sync + Send>
Converts the object to
Box<dyn Any>: Read moreSource§fn type_name(&self) -> &'static str
fn type_name(&self) -> &'static str
Convenient wrapper for
std::any::type_name, since Any does not provide it and
Any::type_id is useless as a debugging aid (its Debug is just a mess of hex digits).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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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 moreCreates a shared type from an unshared type.