[ https://issues.apache.org/jira/browse/ARROW-7787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andy Grove reassigned ARROW-7787: --------------------------------- Assignee: Jorge > [Rust] Add collect to Table API > ------------------------------- > > Key: ARROW-7787 > URL: https://issues.apache.org/jira/browse/ARROW-7787 > Project: Apache Arrow > Issue Type: Improvement > Components: Rust - DataFusion > Reporter: Jorge > Assignee: Jorge > Priority: Major > Labels: pull-request-available > Fix For: 0.17.0 > > Original Estimate: 2h > Time Spent: 0.5h > Remaining Estimate: 1.5h > > Currently, executing using the table API requires some effort: given a table > `t`: > {code:java} > plan = t.to_logical_plan() > plan = ctx.optimize(plan) > plan = ctx.create_physical_plan(plan, batch_size) > result = ctx.collect(plan) > {code} > This issue proposes 2 new public methods, one for Table, > {code:java} > fn collect(&self, ctx: &mut ExecutionContext, batch_size: usize) -> > Result<Vec<RecordBatch>>; > {code} > and one for ExecutionContext, > {code:java} > pub fn collect_plan(&mut self, plan: &LogicalPlan, batch_size: usize) -> > Result<Vec<RecordBatch>> > {code} > that optimize, execute and collect the results of the Table/LogicalPlan > respectively, in the same spirit of `ExecutionContext.sql`. > > > -- This message was sent by Atlassian Jira (v8.3.4#803005)