pub struct ExecutorProcessConfig {Show 25 fields
pub bind_host: String,
pub external_host: Option<String>,
pub port: u16,
pub grpc_port: u16,
pub scheduler_host: String,
pub scheduler_port: u16,
pub scheduler_connect_timeout_seconds: u16,
pub concurrent_tasks: usize,
pub task_scheduling_policy: TaskSchedulingPolicy,
pub log_dir: Option<String>,
pub work_dir: Option<String>,
pub special_mod_log_level: String,
pub print_thread_info: bool,
pub log_file_name_prefix: String,
pub log_rotation_policy: LogRotationPolicy,
pub job_data_ttl_seconds: u64,
pub job_data_clean_up_interval_seconds: u64,
pub data_cache_policy: Option<DataCachePolicy>,
pub cache_dir: Option<String>,
pub cache_capacity: u64,
pub cache_io_concurrency: u32,
pub grpc_max_decoding_message_size: u32,
pub grpc_max_encoding_message_size: u32,
pub executor_heartbeat_interval_seconds: u64,
pub execution_engine: Option<Arc<dyn ExecutionEngine>>,
}Fields§
§bind_host: String§external_host: Option<String>§port: u16§grpc_port: u16§scheduler_host: String§scheduler_port: u16§scheduler_connect_timeout_seconds: u16§concurrent_tasks: usize§task_scheduling_policy: TaskSchedulingPolicy§log_dir: Option<String>§work_dir: Option<String>§special_mod_log_level: String§print_thread_info: bool§log_file_name_prefix: String§log_rotation_policy: LogRotationPolicy§job_data_ttl_seconds: u64§job_data_clean_up_interval_seconds: u64§data_cache_policy: Option<DataCachePolicy>§cache_dir: Option<String>§cache_capacity: u64§cache_io_concurrency: u32§grpc_max_decoding_message_size: u32The maximum size of a decoded message
grpc_max_encoding_message_size: u32The maximum size of an encoded message
executor_heartbeat_interval_seconds: u64§execution_engine: Option<Arc<dyn ExecutionEngine>>Optional execution engine to use to execute physical plans, will default to DataFusion if none is provided.
Auto Trait Implementations§
impl Freeze for ExecutorProcessConfig
impl !RefUnwindSafe for ExecutorProcessConfig
impl Send for ExecutorProcessConfig
impl Sync for ExecutorProcessConfig
impl Unpin for ExecutorProcessConfig
impl !UnwindSafe for ExecutorProcessConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request