[ARROW-11533] [Rust][DataFusion] TPC-H Query 20

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Component/s: Rust - DataFusion
• External issue URL: https://github.com/apache/arrow/issues/27407
• Assignee: Unassigned
• Reporter: Daniël Heres
• Created: 06/Feb/21 11:11
• Updated: 11/Jan/23 08:20
• Resolved: 26/Apr/21 13:29

Description

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")