Struct SqlSourceRead 

pub struct SqlSourceRead {
    pub source: SqlReadSource,
    pub sql: String,
    pub budgets: DisclosureBudgets,
    pub credentials: Option<SourceCredentials>,
}

Fields

source: SqlReadSource

sql: String

budgets: DisclosureBudgets

credentials: Option<SourceCredentials>

Implementations

impl SqlSourceRead

pub fn read( self, executable: &Path, directory: &Path, deadline: Instant, cancelled: Arc<AtomicBool>, ) -> Result<File, LakeError>

Return a verified finite Parquet file only after the worker and its source connection have ended. Failure drops the anonymous partial output.

Trait Implementations

impl<'de> Deserialize<'de> for SqlSourceRead

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SqlSourceRead

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.