Struct MetadataPartitionSpec 

pub struct MetadataPartitionSpec {
    pub view_metadata: ViewMetadata,
    pub schema: Arc<Schema>,
    pub insert_range: TimeRange,
    pub record_count: i64,
    pub data_sql: Arc<String>,
    pub compute_time_bounds: Arc<dyn DataFrameTimeBounds>,
}

Fields

view_metadata: ViewMetadata

schema: Arc<Schema>

insert_range: TimeRange

record_count: i64

data_sql: Arc<String>

compute_time_bounds: Arc<dyn DataFrameTimeBounds>

Trait Implementations

impl Debug for MetadataPartitionSpec

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

Formats the value using the given formatter.

impl PartitionSpec for MetadataPartitionSpec

fn is_empty(&self) -> bool

Returns true if the partition is empty.

fn get_source_data_hash(&self) -> Vec<u8>

Returns a hash of the source data.

fn write<'life0, 'async_trait>( &'life0 self, lake: Arc<DataLakeConnection>, logger: Arc<dyn Logger>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, MetadataPartitionSpec: 'async_trait,

Writes the partition to the data lake.