Daniël Heres created ARROW-11533:
------------------------------------
Summary: [Rust][DataFusion] TPC-H Query 20
Key: ARROW-11533
URL: https://issues.apache.org/jira/browse/ARROW-11533
Project: Apache Arrow
Issue Type: Sub-task
Components: Rust - DataFusion
Reporter: Daniël Heres
IN (Subquery) in (WHERE) expression
Error: NotImplemented("Unsupported ast node InSubquery { expr: Identifier(Ident
{ value: \"s_suppkey\", quote_style: None }), subquery: Query { with: None,
body: Select(Select { distinct: false, top: None, projection:
[UnnamedExpr(Identifier(Ident { value: \"ps_suppkey\", quote_style: None }))],
from: [TableWithJoins { relation: Table { name: ObjectName([Ident { value:
\"partsupp\", quote_style: None }]), alias: None, args: [], with_hints: [] },
joins: [] }], selection: Some(BinaryOp { left: InSubquery { expr:
Identifier(Ident { value: \"ps_partkey\", quote_style: None }), subquery: Query
{ with: None, body: Select(Select { distinct: false, top: None, projection:
[UnnamedExpr(Identifier(Ident { value: \"p_partkey\", quote_style: None }))],
from: [TableWithJoins { relation: Table { name: ObjectName([Ident { value:
\"part\", quote_style: None }]), alias: None, args: [], with_hints: [] },
joins: [] }], selection: Some(BinaryOp { left: Identifier(Ident { value:
\"p_name\", quote_style: None }), op: Like, right:
Value(SingleQuotedString(\"forest%\")) }), group_by: [], having: None }),
order_by: [], limit: None, offset: None, fetch: None }, negated: false }, op:
And, right: BinaryOp { left: Identifier(Ident { value: \"ps_availqty\",
quote_style: None }), op: Gt, right: Subquery(Query { with: None, body:
Select(Select { distinct: false, top: None, projection: [UnnamedExpr(BinaryOp {
left: Value(Number(\"0.5\")), op: Multiply, right: Function(Function { name:
ObjectName([Ident { value: \"sum\", quote_style: None }]), args:
[Unnamed(Identifier(Ident { value: \"l_quantity\", quote_style: None }))],
over: None, distinct: false }) })], from: [TableWithJoins { relation: Table {
name: ObjectName([Ident { value: \"lineitem\", quote_style: None }]), alias:
None, args: [], with_hints: [] }, joins: [] }], selection: Some(BinaryOp {
left: BinaryOp { left: BinaryOp { left: BinaryOp { left: Identifier(Ident {
value: \"l_partkey\", quote_style: None }), op: Eq, right: Identifier(Ident {
value: \"ps_partkey\", quote_style: None }) }, op: And, right: BinaryOp { left:
Identifier(Ident { value: \"l_suppkey\", quote_style: None }), op: Eq, right:
Identifier(Ident { value: \"ps_suppkey\", quote_style: None }) } }, op: And,
right: BinaryOp { left: Identifier(Ident { value: \"l_shipdate\", quote_style:
None }), op: GtEq, right: TypedString { data_type: Date, value: \"1994-01-01\"
} } }, op: And, right: BinaryOp { left: Identifier(Ident { value:
\"l_shipdate\", quote_style: None }), op: Lt, right: BinaryOp { left:
Value(SingleQuotedString(\"date 1994-01-01\")), op: Plus, right: Value(Interval
{ value: \"1\", leading_field: Some(Year), leading_precision: None, last_field:
None, fractional_seconds_precision: None }) } } }), group_by: [], having: None
}), order_by: [], limit: None, offset: None, fetch: None }) } }), group_by: [],
having: None }), order_by: [], limit: None, offset: None, fetch: None },
negated: false } in sqltorel")
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
