(cond: expr.ColumnExpression)
| 1122 | |
| 1123 | |
| 1124 | def validate_shape(cond: expr.ColumnExpression) -> expr.ColumnBinaryOpExpression: |
| 1125 | if ( |
| 1126 | not isinstance(cond, expr.ColumnBinaryOpExpression) |
| 1127 | or cond._operator != op.eq |
| 1128 | or not isinstance(cond._left, expr.ColumnReference) |
| 1129 | or not isinstance(cond._right, expr.ColumnReference) |
| 1130 | ): |
| 1131 | raise ValueError( |
| 1132 | "join condition should be of form <left_table>.<column> == <right_table>.<column>" |
| 1133 | ) |
| 1134 | return cond |
| 1135 | |
| 1136 | |
| 1137 | def validate_join_condition( |
no outgoing calls
no test coverage detected