ExecutePlan.buildSinkNode

This is a shortcut of arrow.execute_plan.ExecutePlan.buildNode for sink node.

class ExecutePlan

arrow.execute_node.ExecuteNode

buildSinkNode

(

arrow.execute_node.ExecuteNode input

,

arrow.sink_node_options.SinkNodeOptions options

)

Parameters

input arrow.execute_node.ExecuteNode: A #GArrowExecuteNode.
options arrow.sink_node_options.SinkNodeOptions: A #GArrowSinkNodeOptions.

Return Value

Type: arrow.execute_node.ExecuteNode

A newly built and added #GArrowExecuteNode for sink on success, null on error.

arrow execute_plan ExecutePlan constructors

this

functions