Struct datafusion::physical_plan::parquet::ParquetExec [−][src]
pub struct ParquetExec { /* fields omitted */ }
Execution plan for scanning one or more Parquet partitions
Implementations
impl ParquetExec
[src]
impl ParquetExec
[src]pub fn try_from_path(
path: &str,
projection: Option<Vec<usize>>,
predicate: Option<Expr>,
batch_size: usize,
max_concurrency: usize,
limit: Option<usize>
) -> Result<Self>
[src]
path: &str,
projection: Option<Vec<usize>>,
predicate: Option<Expr>,
batch_size: usize,
max_concurrency: usize,
limit: Option<usize>
) -> Result<Self>
Create a new Parquet reader execution plan based on the specified Parquet filename or directory containing Parquet files
pub fn try_from_files(
filenames: &[&str],
projection: Option<Vec<usize>>,
predicate: Option<Expr>,
batch_size: usize,
max_concurrency: usize,
limit: Option<usize>
) -> Result<Self>
[src]
filenames: &[&str],
projection: Option<Vec<usize>>,
predicate: Option<Expr>,
batch_size: usize,
max_concurrency: usize,
limit: Option<usize>
) -> Result<Self>
Create a new Parquet reader execution plan based on the specified list of Parquet files
pub fn new(
partitions: Vec<ParquetPartition>,
schema: Schema,
projection: Option<Vec<usize>>,
predicate_builder: Option<RowGroupPredicateBuilder>,
batch_size: usize,
limit: Option<usize>
) -> Self
[src]
partitions: Vec<ParquetPartition>,
schema: Schema,
projection: Option<Vec<usize>>,
predicate_builder: Option<RowGroupPredicateBuilder>,
batch_size: usize,
limit: Option<usize>
) -> Self
Create a new Parquet reader execution plan with provided partitions and schema
pub fn partitions(&self) -> &[ParquetPartition]
[src]
Parquet partitions to read
pub fn projection(&self) -> &[usize]
[src]
Projection for which columns to load
pub fn batch_size(&self) -> usize
[src]
Batch size
pub fn statistics(&self) -> &Statistics
[src]
Statistics for the data set (sum of statistics for all partitions)
Trait Implementations
impl Clone for ParquetExec
[src]
impl Clone for ParquetExec
[src]fn clone(&self) -> ParquetExec
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl ExecutionPlan for ParquetExec
[src]
impl ExecutionPlan for ParquetExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
fn with_new_children(
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
fn execute<'life0, 'async_trait>(
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn required_child_distribution(&self) -> Distribution
[src]
fn metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for ParquetExec
impl !RefUnwindSafe for ParquetExec
impl Send for ParquetExec
impl Send for ParquetExec
impl Sync for ParquetExec
impl Sync for ParquetExec
impl Unpin for ParquetExec
impl Unpin for ParquetExec
impl !UnwindSafe for ParquetExec
impl !UnwindSafe for ParquetExec