Return a projection expression respecting schema availability.
(self, source: str, alias: str, column: str, output_alias: str)
| 128 | return all(self._has_column(source, col) for col in columns) |
| 129 | |
| 130 | def _column_expr(self, source: str, alias: str, column: str, output_alias: str) -> str: |
| 131 | """Return a projection expression respecting schema availability.""" |
| 132 | if self._has_column(source, column): |
| 133 | actual = self._get_actual_column_name(source, column) |
| 134 | column_ref = f"{alias}.{actual}" |
| 135 | return f"{column_ref} AS {output_alias}" |
| 136 | return f"NULL AS {output_alias}" |
| 137 | |
| 138 | def build_dynamic_query(self, |
| 139 | group_cols: List[str], |