Crate ballista_executor

Source
Expand description

§Ballista Executor Process

This crate contains the Ballista executor process.

Modules§

collect
The CollectExec operator retrieves results from the cluster and returns them as a single vector of RecordBatch.
config
execution_engine
execution_loop
executor
Ballista executor logic
executor_process
Ballista Executor Process
executor_server
flight_service
Implementation of the Apache Arrow Flight protocol that wraps an executor.
metrics
shutdown
terminate

Structs§

TaskExecutionTimes

Functions§

as_task_status
new_standalone_executor
Creates standalone executor with most values set as default.
new_standalone_executor_from_builder
new_standalone_executor_from_state
Creates new standalone executor based on session_state provided.

Type Aliases§

ArrowFlightServerProvider
ArrowFlightServerProvider provides a function which creates a new Arrow Flight server.