(join *ast.SQLCrossJoin, seq sem.Seq)
| 549 | } |
| 550 | |
| 551 | func (t *translator) sqlCrossJoin(join *ast.SQLCrossJoin, seq sem.Seq) (sem.Seq, relScope) { |
| 552 | if len(seq) > 0 { |
| 553 | // At some point we might want to let parent data flow into a join somehow, |
| 554 | // but for now we flag an error. |
| 555 | t.error(join, errors.New("SQL cross join cannot inherit data from pipeline parent")) |
| 556 | } |
| 557 | leftSeq, leftSchema := t.sqlTableExpr(join.Left, nil) |
| 558 | return t.sqlAppendCrossJoin(join, leftSeq, leftSchema, join.Right) |
| 559 | } |
| 560 | |
| 561 | func (t *translator) sqlAppendCrossJoin(node ast.Node, leftSeq sem.Seq, leftScope relScope, rhs ast.SQLTableExpr) (sem.Seq, relScope) { |
| 562 | rightSeq, rightScope := t.sqlTableExpr(rhs, nil) |
no test coverage detected