Struct DatasetExecutor 

pub struct DatasetExecutor { /* private fields */ }

One process generation, held by Sessions and every outstanding Lake attempt. The stable lock file lives in durable coordination storage outside source scratch.

Implementations

impl DatasetExecutor

pub fn acquire( root: &Path, datastore_id: Uuid, ) -> Result<Arc<Self>, ScratchError>

Opens the configured durable coordination root. Source scratch is separate.

Trait Implementations

impl DatasetExecutorLease for DatasetExecutor

fn identity(&self) -> DatasetExecutorIdentity

fn begin_attempt( self: Arc<Self>, attempt_id: Uuid, ) -> Result<Box<dyn DatasetAttemptExecutor>, CoreError>

fn begin_maintenance( self: Arc<Self>, ) -> Result<Box<dyn DatasetAttemptExecutor>, CoreError>

fn can_recover(&self, owner: DatasetExecutorIdentity, attempt_id: Uuid) -> bool

True only when the recorded executor cannot perform another effect.

impl Debug for DatasetExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.