arrow.execute_plan

Module for [ExecutePlan] class

class ExecutePlan ExecutePlanGidBuilder ExecutePlanGidBuilderImpl

Types 3

classExecutePlan : gobject.object.ObjectWrap
Methods
GType _getGType()
GType _gType() @property
ExecutePlan self()Returns `this`, for use in `with` statements.
ExecutePlanGidBuilder builder()Get builder for [arrow.execute_plan.ExecutePlan] Returns: New builder object
arrow.execute_node.ExecuteNode buildAggregateNode(arrow.execute_node.ExecuteNode input, arrow.aggregate_node_options.AggregateNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for aggregate node.
arrow.execute_node.ExecuteNode buildFilterNode(arrow.execute_node.ExecuteNode input, arrow.filter_node_options.FilterNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for filter node.
arrow.execute_node.ExecuteNode buildHashJoinNode(arrow.execute_node.ExecuteNode left, arrow.execute_node.ExecuteNode right, arrow.hash_join_node_options.HashJoinNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for hash join node.
arrow.execute_node.ExecuteNode buildNode(string factoryName, arrow.execute_node.ExecuteNode[] inputs, arrow.execute_node_options.ExecuteNodeOptions options)
arrow.execute_node.ExecuteNode buildProjectNode(arrow.execute_node.ExecuteNode input, arrow.project_node_options.ProjectNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for project node.
arrow.execute_node.ExecuteNode buildSinkNode(arrow.execute_node.ExecuteNode input, arrow.sink_node_options.SinkNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for sink node.
arrow.execute_node.ExecuteNode buildSourceNode(arrow.source_node_options.SourceNodeOptions options)This is a shortcut of [arrow.execute_plan.ExecutePlan.buildNode] for source node.
arrow.execute_node.ExecuteNode[] getNodes()
void start()Starts this plan.
void stop()Stops this plan.
bool validate()
bool wait()Waits for finishing this plan. Returns: true on success, false on error. Throws: [ErrorWrap]
Constructors
this(void * ptr, Flag!"Take" take)
this()
classExecutePlanGidBuilderImpl(T) : gobject.object.ObjectWrapGidBuilderImpl!T
Methods
T plan(void * propval)
classExecutePlanGidBuilder : ExecutePlanGidBuilderImpl!ExecutePlanGidBuilder

Fluent builder for [arrow.execute_plan.ExecutePlan]

Methods
ExecutePlan build()