[ 
https://issues.apache.org/jira/browse/ARROW-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17483372#comment-17483372
 ] 

Weston Pace commented on ARROW-15262:
-------------------------------------

Consuming sink sounds right to me.

For now let's not worry about sorting or select-k.  At some point we are going 
to have to figure out how to support those operations mid-plan and so I think 
we can come up with a more general solution at that time.

> [C++] Create a ToTable sink node
> --------------------------------
>
>                 Key: ARROW-15262
>                 URL: https://issues.apache.org/jira/browse/ARROW-15262
>             Project: Apache Arrow
>          Issue Type: Sub-task
>          Components: C++
>            Reporter: Weston Pace
>            Assignee: Vibhatha Lakmal Abeykoon
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 40m
>  Remaining Estimate: 0h
>
> The invocation would look something like:
> {code}
>   std::shared_ptr<Table> out_table;
>   ARROW_RETURN_NOT_OK(arrow::compute::MakeExecNode(
>       "table_sink", plan, {terminal_node}, 
> arrow::compute::TableSinkOptions{&out_table}));
> {code}
> When the plan is finished (assuming a successful finish) then {{out_table}} 
> will be the output of the plan collected into a table.  The schema of the 
> table will be {{terminal_node->output_schema()}}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to