Struct amadeus_parquet::ParquetDirectory

pub struct ParquetDirectory<D> { /* fields omitted */ }

Implementations

impl<D> ParquetDirectory<D>

pub fn new(directory: D) -> Self

Trait Implementations

impl<'de, D> Deserialize<'de> for ParquetDirectory<D> where
    D: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<D> Directory for ParquetDirectory<D> where
    D: Directory,
    D::Partition: Debug, 

fn partitions_filter<'async_trait, F>(
    self,
    f: F
) -> Pin<Box<dyn Future<Output = Result<Vec<Self::Partition>, Self::Error>> + 'async_trait>> where
    F: FnMut(&PathBuf) -> bool,
    F: 'async_trait,
    Self: 'async_trait, 

impl<D> File for ParquetDirectory<D> where
    D: Directory,
    D::Partition: Debug, 

type Partition = D::Partition

type Error = D::Error

fn partitions<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<Vec<Self::Partition>, Self::Error>> + 'async_trait>> where
    Self: 'async_trait, 

impl<D> Serialize for ParquetDirectory<D> where
    D: Serialize, 

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

Serialize this value into the given Serde serializer.