Crate ballista_executor

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.

execution_loop

executor

Ballista executor logic

executor_server

flight_service

Implementation of the Apache Arrow Flight protocol that wraps an executor.

metrics

Functions

as_task_status

new_standalone_executor