pub struct PreparedDisclosureQuery { /* private fields */ }Implementations§
Source§impl PreparedDisclosureQuery
impl PreparedDisclosureQuery
pub fn capture( authority: &DisclosureCaptureAuthority, plan: RestrictedQueryPlan, inputs: &[DisclosureDatasetInput], scratch: &ScratchAttempt, deadline: DateTime<Utc>, executable: &Path, ) -> Result<Self, LakeError>
Sourcepub fn capture_owned(
authority: &DisclosureCaptureAuthority,
plan: RestrictedQueryPlan,
inputs: &[DisclosureDatasetInput],
scratch: ScratchAttempt,
deadline: DateTime<Utc>,
executable: &Path,
) -> Result<Self, LakeError>
pub fn capture_owned( authority: &DisclosureCaptureAuthority, plan: RestrictedQueryPlan, inputs: &[DisclosureDatasetInput], scratch: ScratchAttempt, deadline: DateTime<Utc>, executable: &Path, ) -> Result<Self, LakeError>
Capture inside an owned subtree of a durable Dataset writer attempt. The caller’s enclosing reservation tree verifies cleanup before admission or release, including failures of this capability’s best-effort Drop.
Sourcepub fn materialize(
self,
executable: &Path,
deadline: DateTime<Utc>,
max_bytes: u64,
max_rows: u64,
) -> Result<PreparedQueryOutput, LakeError>
pub fn materialize( self, executable: &Path, deadline: DateTime<Utc>, max_bytes: u64, max_rows: u64, ) -> Result<PreparedQueryOutput, LakeError>
Internal transform output, retained in private scratch. User SQL still executes with no Lake or PostgreSQL authority and no ambient file access.
Sourcepub fn execute(
self,
executable: &Path,
lifetime_seconds: u32,
max_bytes: u64,
max_rows: u64,
) -> Result<RestrictedQueryStream, LakeError>
pub fn execute( self, executable: &Path, lifetime_seconds: u32, max_bytes: u64, max_rows: u64, ) -> Result<RestrictedQueryStream, LakeError>
Executable location is deployment-owned. This API never accepts a client path, environment or connection string as worker input authority.
pub fn execute_representation( self, executable: &Path, representation: ContentRepresentation, preview_limit: Option<u64>, lifetime_seconds: u32, max_bytes: u64, max_rows: u64, ) -> Result<RestrictedQueryStream, LakeError>
Auto Trait Implementations§
impl Freeze for PreparedDisclosureQuery
impl RefUnwindSafe for PreparedDisclosureQuery
impl Send for PreparedDisclosureQuery
impl Sync for PreparedDisclosureQuery
impl Unpin for PreparedDisclosureQuery
impl UnsafeUnpin for PreparedDisclosureQuery
impl UnwindSafe for PreparedDisclosureQuery
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