(state: &dyn Session)
| 152 | /// Create a new task context instance from Session |
| 153 | impl From<&dyn Session> for TaskContext { |
| 154 | fn from(state: &dyn Session) -> Self { |
| 155 | let task_id = None; |
| 156 | TaskContext::new( |
| 157 | task_id, |
| 158 | state.session_id().to_string(), |
| 159 | state.config().clone(), |
| 160 | state.scalar_functions().clone(), |
| 161 | state.higher_order_functions().clone(), |
| 162 | state.aggregate_functions().clone(), |
| 163 | state.window_functions().clone(), |
| 164 | Arc::clone(state.runtime_env()), |
| 165 | ) |
| 166 | } |
| 167 | } |
| 168 | type SessionRefLock = Arc<Mutex<Option<Weak<RwLock<dyn Session>>>>>; |
| 169 | /// The state store that stores the reference of the runtime session state. |
nothing calls this directly
no test coverage detected