pub struct ViewInstanceTableFunction { /* private fields */ }Expand description
ViewInstanceTableFunction gives access to any view instance using a ViewFactory.
# Python code showing the usage of `view_instance(view_set_name, view_instance_id)`
sql = """
SELECT *
FROM view_instance('thread_spans', '{stream_id}')
;""".format(stream_id=stream_id)
df_spans = client.query(sql, begin_spans, end_spans)The only site that supplies an AudienceGuard to the MaterializedViews it builds:
every caller-named instance goes through this table function, so this is where the
scan-time audience check gets wired in.
Implementations§
Source§impl ViewInstanceTableFunction
impl ViewInstanceTableFunction
pub fn new( lakehouse: Arc<LakehouseContext>, view_factory: Arc<ViewFactory>, part_provider: Arc<dyn QueryPartitionProvider>, query_range: Option<TimeRange>, guard: Arc<AudienceGuard>, ) -> ViewInstanceTableFunction
Trait Implementations§
Source§impl Debug for ViewInstanceTableFunction
impl Debug for ViewInstanceTableFunction
Source§impl TableFunctionImpl for ViewInstanceTableFunction
impl TableFunctionImpl for ViewInstanceTableFunction
Source§fn call_with_args(
&self,
args: TableFunctionArgs<'_, '_>,
) -> Result<Arc<dyn TableProvider>, DataFusionError>
fn call_with_args( &self, args: TableFunctionArgs<'_, '_>, ) -> Result<Arc<dyn TableProvider>, DataFusionError>
Create a table provider
Auto Trait Implementations§
impl !RefUnwindSafe for ViewInstanceTableFunction
impl !UnwindSafe for ViewInstanceTableFunction
impl Freeze for ViewInstanceTableFunction
impl Send for ViewInstanceTableFunction
impl Sync for ViewInstanceTableFunction
impl Unpin for ViewInstanceTableFunction
impl UnsafeUnpin for ViewInstanceTableFunction
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> 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 more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].