Skip to main content

create_session_context

feldera_adapterlib::utils::datafusion

Function create_session_context 

Source 
pub fn create_session_context(
    pipeline_config: &PipelineConfig,
    runtime_env: Arc<RuntimeEnv>,
) -> SessionContext
Expand description

SessionContext bound to the shared RuntimeEnv, configured with the pipeline’s worker count and feldera’s sort-spill thresholds.