TPC-H Query 11

[alamb]

Note: migrated from original JIRA: https://issues.apache.org/jira/browse/ARROW-11525

Needs subquery support.

{{Error: NotImplemented("Unsupported ast node Subquery(Query { with: None, body: Select(Select { distinct: false, top: None, projection: [UnnamedExpr(BinaryOp { left: Function(Function { name: ObjectName([Ident { value: "sum", quote_style: None }]), args: [Unnamed(BinaryOp { left: Identifier(Ident { value: "ps_supplycost", quote_style: None }), op: Multiply, right: Identifier(Ident { value: "ps_availqty", quote_style: None }) })], over: None, distinct: false }), op: Multiply, right: Value(Number("0.0001")) })], from: [TableWithJoins { relation: Table { name: ObjectName([Ident { value: "partsupp", quote_style: None }]), alias: None, args: [], with_hints: [] }, joins: [] }, TableWithJoins { relation: Table { name: ObjectName([Ident { value: "supplier", quote_style: None }]), alias: None, args: [], with_hints: [] }, joins: [] }, TableWithJoins { relation: Table { name: ObjectName([Ident { value: "nation", quote_style: None }]), alias: None, args: [], with_hints: [] }, joins: [] }], selection: Some(BinaryOp { left: BinaryOp { left: BinaryOp { left: Identifier(Ident { value: "ps_suppkey", quote_style: None }), op: Eq, right: Identifier(Ident { value: "s_suppkey", quote_style: None }) }, op: And, right: BinaryOp { left: Identifier(Ident { value: "s_nationkey", quote_style: None }), op: Eq, right: Identifier(Ident { value: "n_nationkey", quote_style: None }) } }, op: And, right: BinaryOp { left: Identifier(Ident { value: "n_name", quote_style: None }), op: Eq, right: Value(SingleQuotedString("GERMANY")) } }), group_by: [], having: None }), order_by: [], limit: None, offset: None, fetch: None }) in sqltorel")}}

[andygrove]

Latest failure:

Error: NotImplemented("Physical plan does not support logical expression (Subquery: Projection: #SUM(partsupp.ps_supplycost * partsupp.ps_availqty) * Float64(0.0001)\n  Aggregate: groupBy=[[]], aggr=[[SUM(#partsupp.ps_supplycost * #partsupp.ps_availqty)]]\n    Filter: #nation.n_name = Utf8(\"GERMANY\")\n      Inner Join: #supplier.s_nationkey = #nation.n_nationkey\n        Inner Join: #partsupp.ps_suppkey = #supplier.s_suppkey\n          TableScan: partsupp projection=None\n          TableScan: supplier projection=None\n        TableScan: nation projection=None)")
t

[avantgardnerio]

Fixed in this branch:

| 122819     | 7888881.02         |
| 154731     | 7888301.33         |
| 101674     | 7879324.6          |
| 51968      | 7879102.21         |
| 72073      | 7877736.11         |
| 5182       | 7874521.7299999995 |
+------------+--------------------+
Query 11 iteration 0 took 5595.7 ms and returned 1048 rows
Query 11 avg time: 5595.66 ms

postgres:

|122819    |7888881.02        |
|154731    |7888301.33        |
|101674    |7879324.6         |
|51968     |7879102.21        |
|72073     |7877736.11        |
|5182      |7874521.7299999995|
+----------+------------------+