fetch_sql_partition_spec

micromegas::analytics::lakehouse::sql_partition_spec

Function fetch_sql_partition_spec 

Source 
pub async fn fetch_sql_partition_spec(
    ctx: SessionContext,
    transformer: Arc<dyn RecordBatchTransformer>,
    compute_time_bounds: Arc<dyn DataFrameTimeBounds>,
    schema: Arc<Schema>,
    count_src_sql: String,
    extract_query: String,
    view_metadata: ViewMetadata,
    insert_range: TimeRange,
) -> Result<SqlPartitionSpec, Error>
Expand description

Fetches a SqlPartitionSpec by executing a count query and an extract query.