Compare text

Find the difference between two text files

Real-time diff

Unified diff

Collapse lines

Highlight change

Syntax highlighting

Tools

Diffchecker Desktop The most secure way to run Diffchecker. Get the Diffchecker Desktop app: your diffs never leave your computer!Get Desktop

tpch-q1

Created 6 days agoDiff never expires

Lines
Total
Removed

Words
Total
Removed

To continue using this feature, upgrade to Diffchecker Pro View Pricing

1 line

Lines
Total
Added

Words
Total
Added

To continue using this feature, upgrade to Diffchecker Pro View Pricing

Saved diffs

Original text

Open file

SortPreservingMergeExec { input: SortExec { input: ProjectionExec { expr: [(Column { name: \"l_returnflag\", index: 0 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 1 }, \"l_linestatus\"), (Column { name: \"sum(lineitem.l_quantity)\", index: 2 }, \"sum_qty\"), (Column { name: \"sum(lineitem.l_extendedprice)\", index: 3 }, \"sum_base_price\"), (Column { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", index: 4 }, \"sum_disc_price\"), (Column { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", index: 5 }, \"sum_charge\"), (Column { name: \"avg(lineitem.l_quantity)\", index: 6 }, \"avg_qty\"), (Column { name: \"avg(lineitem.l_extendedprice)\", index: 7 }, \"avg_price\"), (Column { name: \"avg(lineitem.l_discount)\", index: 8 }, \"avg_disc\"), (Column { name: \"count(Int64(1))\", index: 9 }, \"count_order\")], schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input: AggregateExec { mode: FinalPartitioned, group_by: PhysicalGroupBy { expr: [(Column { name: \"l_returnflag\", index: 0 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 1 }, \"l_linestatus\")], null_expr: [], groups: [[false, false]] }, aggr_expr: [AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"sum\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_quantity)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"sum\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"__common_expr_1\", index: 0 }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [BinaryExpr { left: Column { name: \"__common_expr_1\", index: 0 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Plus, right: Column { name: \"l_tax\", index: 4 }, fail_on_overflow: false }, fail_on_overflow: false }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1@0 * (Some(1),20,0 + l_tax@4)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"avg\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_quantity)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"avg\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_extendedprice)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_discount\", index: 3 }], return_field: Field { name: \"avg\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Count { name: \"count\", signature: Signature { type_signature: OneOf([VariadicAny, Nullary]), volatility: Immutable } } }, args: [Literal { value: Int64(1), field: Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }], return_field: Field { name: \"count\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"count(Int64(1))\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: false }], filter_expr: [None, None, None, None, None, None, None, None], limit: None, input: CoalesceBatchesExec { input: RepartitionExec { input: AggregateExec { mode: Partial, group_by: PhysicalGroupBy { expr: [(Column { name: \"l_returnflag\", index: 5 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 6 }, \"l_linestatus\")], null_expr: [], groups: [[false, false]] }, aggr_expr: [AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"sum\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_quantity)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"sum\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"__common_expr_1\", index: 0 }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [BinaryExpr { left: Column { name: \"__common_expr_1\", index: 0 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Plus, right: Column { name: \"l_tax\", index: 4 }, fail_on_overflow: false }, fail_on_overflow: false }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1@0 * (Some(1),20,0 + l_tax@4)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"avg\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_quantity)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"avg\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_extendedprice)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_discount\", index: 3 }], return_field: Field { name: \"avg\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Count { name: \"count\", signature: Signature { type_signature: OneOf([VariadicAny, Nullary]), volatility: Immutable } } }, args: [Literal { value: Int64(1), field: Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }], return_field: Field { name: \"count\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"count(Int64(1))\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: false }], filter_expr: [None, None, None, None, None, None, None, None], limit: None, input: ProjectionExec { expr: [(BinaryExpr { left: Column { name: \"l_extendedprice\", index: 1 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Minus, right: Column { name: \"l_discount\", index: 2 }, fail_on_overflow: false }, fail_on_overflow: false }, \"__common_expr_1\"), (Column { name: \"l_quantity\", index: 0 }, \"l_quantity\"), (Column { name: \"l_extendedprice\", index: 1 }, \"l_extendedprice\"), (Column { name: \"l_discount\", index: 2 }, \"l_discount\"), (Column { name: \"l_tax\", index: 3 }, \"l_tax\"), (Column { name: \"l_returnflag\", index: 4 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 5 }, \"l_linestatus\")], schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input: CoalesceBatchesExec { input: FilterExec { predicate: BinaryExpr { left: Column { name: \"l_shipdate\", index: 6 }, op: LtEq, right: Literal { value: Date32(\"1998-09-02\"), field: Field { name: \"lit\", data_type: Date32, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, fail_on_overflow: false }, input: RepartitionExec { input: DataSourceExec { data_source: FileScanConfig {object_store_url=ObjectStoreUrl { url: Url { scheme: \"file\", cannot_be_a_base: false, username: \"\", password: None, host: None, port: None, path: \"/\", query: None, fragment: None } }, statistics=Statistics { num_rows: Inexact(20), total_byte_size: Inexact(2770), column_statistics: [ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(7)), min_value: Inexact(Int64(1)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(183095)), min_value: Inexact(Int64(2132)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(9662)), min_value: Inexact(Int64(35)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int32(6)), min_value: Inexact(Int32(1)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(5000),4,2)), min_value: Inexact(Decimal128(Some(200),4,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(7342650),7,2)), min_value: Inexact(Decimal128(Some(261876),7,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(10),2,2)), min_value: Inexact(Decimal128(Some(0),2,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(8),2,2)), min_value: Inexact(Decimal128(Some(0),2,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"R\")), min_value: Inexact(Utf8View(\"A\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"O\")), min_value: Inexact(Utf8View(\"F\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-01-28\")), min_value: Inexact(Date32(\"1992-04-27\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-01-14\")), min_value: Inexact(Date32(\"1992-05-15\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-02-02\")), min_value: Inexact(Date32(\"1992-05-02\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"TAKE BACK RETURN\")), min_value: Inexact(Utf8View(\"DELIVER IN PERSON\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"TRUCK\")), min_value: Inexact(Utf8View(\"AIR\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"y. fluffily pending d\")), min_value: Inexact(Utf8View(\" pending foxes. slyly re\")), sum_value: Absent, distinct_count: Absent }] }, file_groups={1 group: [[home/hao/coding/datafusion/datafusion/core/tests/data/tpch_lineitem_small.parquet]]}, projection=[l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag, l_linestatus, l_shipdate]}, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_shipdate\", data_type: Date32, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: UnknownPartitioning(1), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: Cooperative, output_ordering: None } }, state: Mutex { data: NotInitialized }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_order: false, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_shipdate\", data_type: Date32, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, default_selectivity: 20, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None }, projection: Some([0, 1, 2, 3, 4, 5]) }, target_batch_size: 8192, fetch: None, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input_schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, required_input_ordering: None, input_order_mode: Linear, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, state: Mutex { data: NotInitialized }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_order: false, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: None } }, target_batch_size: 8192, fetch: None, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input_schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, required_input_ordering: None, input_order_mode: Linear, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, expr: LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }, metrics_set: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_partitioning: true, fetch: None, common_sort_prefix: [], cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, leading_map: {Column { name: \"l_returnflag\", index: 0 }: [0]} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: Some(LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }) }, filter: None }, expr: LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, fetch: None, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, leading_map: {Column { name: \"l_returnflag\", index: 0 }: [0]} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: UnknownPartitioning(1), emission_type: Final, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: Some(LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }) }, enable_round_robin_repartition: true }

Changed text

Open file

SortPreservingMergeExec { input: SortExec { input: ProjectionExec { expr: [(Column { name: \"l_returnflag\", index: 0 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 1 }, \"l_linestatus\"), (Column { name: \"sum(lineitem.l_quantity)\", index: 2 }, \"sum_qty\"), (Column { name: \"sum(lineitem.l_extendedprice)\", index: 3 }, \"sum_base_price\"), (Column { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", index: 4 }, \"sum_disc_price\"), (Column { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", index: 5 }, \"sum_charge\"), (Column { name: \"avg(lineitem.l_quantity)\", index: 6 }, \"avg_qty\"), (Column { name: \"avg(lineitem.l_extendedprice)\", index: 7 }, \"avg_price\"), (Column { name: \"avg(lineitem.l_discount)\", index: 8 }, \"avg_disc\"), (Column { name: \"count(Int64(1))\", index: 9 }, \"count_order\")], schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input: AggregateExec { mode: FinalPartitioned, group_by: PhysicalGroupBy { expr: [(Column { name: \"l_returnflag\", index: 0 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 1 }, \"l_linestatus\")], null_expr: [], groups: [[false, false]] }, aggr_expr: [AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"sum\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_quantity)\", human_display: \"sum(lineitem.l_quantity)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"sum\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice)\", human_display: \"sum(lineitem.l_extendedprice)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"__common_expr_1\", index: 0 }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [BinaryExpr { left: Column { name: \"__common_expr_1\", index: 0 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Plus, right: Column { name: \"l_tax\", index: 4 }, fail_on_overflow: false }, fail_on_overflow: false }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1@0 * (Some(1),20,0 + l_tax@4)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"avg\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_quantity)\", human_display: \"avg(lineitem.l_quantity)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"avg\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_extendedprice)\", human_display: \"avg(lineitem.l_extendedprice)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_discount\", index: 3 }], return_field: Field { name: \"avg\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_discount)\", human_display: \"avg(lineitem.l_discount)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Count { name: \"count\", signature: Signature { type_signature: OneOf([VariadicAny, Nullary]), volatility: Immutable } } }, args: [Literal { value: Int64(1), field: Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }], return_field: Field { name: \"count\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"count(Int64(1))\", human_display: \"count(1)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: false }], filter_expr: [None, None, None, None, None, None, None, None], limit: None, input: CoalesceBatchesExec { input: RepartitionExec { input: AggregateExec { mode: Partial, group_by: PhysicalGroupBy { expr: [(Column { name: \"l_returnflag\", index: 5 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 6 }, \"l_linestatus\")], null_expr: [], groups: [[false, false]] }, aggr_expr: [AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"sum\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_quantity)\", human_display: \"sum(lineitem.l_quantity)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"sum\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice)\", human_display: \"sum(lineitem.l_extendedprice)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [Column { name: \"__common_expr_1\", index: 0 }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Sum { signature: Signature { type_signature: UserDefined, volatility: Immutable } } }, args: [BinaryExpr { left: Column { name: \"__common_expr_1\", index: 0 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Plus, right: Column { name: \"l_tax\", index: 4 }, fail_on_overflow: false }, fail_on_overflow: false }], return_field: Field { name: \"sum\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", human_display: \"\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"__common_expr_1@0 * (Some(1),20,0 + l_tax@4)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_quantity\", index: 1 }], return_field: Field { name: \"avg\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_quantity)\", human_display: \"avg(lineitem.l_quantity)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_extendedprice\", index: 2 }], return_field: Field { name: \"avg\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_extendedprice)\", human_display: \"avg(lineitem.l_extendedprice)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Avg { signature: Signature { type_signature: UserDefined, volatility: Immutable }, aliases: [\"mean\"] } }, args: [Column { name: \"l_discount\", index: 3 }], return_field: Field { name: \"avg\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"avg(lineitem.l_discount)\", human_display: \"avg(lineitem.l_discount)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: true }, AggregateFunctionExpr { fun: AggregateUDF { inner: Count { name: \"count\", signature: Signature { type_signature: OneOf([VariadicAny, Nullary]), volatility: Immutable } } }, args: [Literal { value: Int64(1), field: Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }], return_field: Field { name: \"count\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }, name: \"count(Int64(1))\", human_display: \"count(1)\", schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, order_bys: [], ignore_nulls: false, ordering_fields: [], is_distinct: false, is_reversed: false, input_fields: [Field { name: \"lit\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], is_nullable: false }], filter_expr: [None, None, None, None, None, None, None, None], limit: None, input: ProjectionExec { expr: [(BinaryExpr { left: Column { name: \"l_extendedprice\", index: 1 }, op: Multiply, right: BinaryExpr { left: Literal { value: Decimal128(Some(1),20,0), field: Field { name: \"lit\", data_type: Decimal128(20, 0), nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, op: Minus, right: Column { name: \"l_discount\", index: 2 }, fail_on_overflow: false }, fail_on_overflow: false }, \"__common_expr_1\"), (Column { name: \"l_quantity\", index: 0 }, \"l_quantity\"), (Column { name: \"l_extendedprice\", index: 1 }, \"l_extendedprice\"), (Column { name: \"l_discount\", index: 2 }, \"l_discount\"), (Column { name: \"l_tax\", index: 3 }, \"l_tax\"), (Column { name: \"l_returnflag\", index: 4 }, \"l_returnflag\"), (Column { name: \"l_linestatus\", index: 5 }, \"l_linestatus\")], schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input: CoalesceBatchesExec { input: FilterExec { predicate: BinaryExpr { left: Column { name: \"l_shipdate\", index: 6 }, op: LtEq, right: Literal { value: Date32(\"1998-09-02\"), field: Field { name: \"lit\", data_type: Date32, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} } }, fail_on_overflow: false }, input: RepartitionExec { input: DataSourceExec { data_source: FileScanConfig {object_store_url=ObjectStoreUrl { url: Url { scheme: \"file\", cannot_be_a_base: false, username: \"\", password: None, host: None, port: None, path: \"/\", query: None, fragment: None } }, statistics=Statistics { num_rows: Inexact(20), total_byte_size: Inexact(2770), column_statistics: [ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(7)), min_value: Inexact(Int64(1)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(183095)), min_value: Inexact(Int64(2132)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int64(9662)), min_value: Inexact(Int64(35)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Int32(6)), min_value: Inexact(Int32(1)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(5000),4,2)), min_value: Inexact(Decimal128(Some(200),4,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(7342650),7,2)), min_value: Inexact(Decimal128(Some(261876),7,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(10),2,2)), min_value: Inexact(Decimal128(Some(0),2,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Decimal128(Some(8),2,2)), min_value: Inexact(Decimal128(Some(0),2,2)), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"R\")), min_value: Inexact(Utf8View(\"A\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"O\")), min_value: Inexact(Utf8View(\"F\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-01-28\")), min_value: Inexact(Date32(\"1992-04-27\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-01-14\")), min_value: Inexact(Date32(\"1992-05-15\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Date32(\"1997-02-02\")), min_value: Inexact(Date32(\"1992-05-02\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"TAKE BACK RETURN\")), min_value: Inexact(Utf8View(\"DELIVER IN PERSON\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"TRUCK\")), min_value: Inexact(Utf8View(\"AIR\")), sum_value: Absent, distinct_count: Absent }, ColumnStatistics { null_count: Inexact(0), max_value: Inexact(Utf8View(\"y. fluffily pending d\")), min_value: Inexact(Utf8View(\" pending foxes. slyly re\")), sum_value: Absent, distinct_count: Absent }] }, file_groups={1 group: [[home/hao/coding/datafusion/datafusion/core/tests/data/tpch_lineitem_small.parquet]]}, projection=[l_quantity, l_extendedprice, l_discount, l_tax, l_returnflag, l_linestatus, l_shipdate]}, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_shipdate\", data_type: Date32, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: UnknownPartitioning(1), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: Cooperative, output_ordering: None } }, state: Mutex { data: NotInitialized }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_order: false, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_shipdate\", data_type: Date32, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, default_selectivity: 20, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None }, projection: Some([0, 1, 2, 3, 4, 5]) }, target_batch_size: 8192, fetch: None, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [] }, schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Incremental, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input_schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, required_input_ordering: None, input_order_mode: Linear, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: RoundRobinBatch(24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, state: Mutex { data: NotInitialized }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_order: false, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: None } }, target_batch_size: 8192, fetch: None, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)[sum]\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)[sum]\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)[sum]\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)[sum]\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)[sum]\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[count]\", data_type: UInt64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)[sum]\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))[count]\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, input_schema: Schema { fields: [Field { name: \"__common_expr_1\", data_type: Decimal128(31, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_quantity\", data_type: Decimal128(4, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_extendedprice\", data_type: Decimal128(7, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_discount\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_tax\", data_type: Decimal128(2, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, required_input_ordering: None, input_order_mode: Linear, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_quantity)\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice)\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount)\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum(lineitem.l_extendedprice * Int64(1) - lineitem.l_discount * Int64(1) + lineitem.l_tax)\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_quantity)\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_extendedprice)\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg(lineitem.l_discount)\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count(Int64(1))\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [] }, leading_map: {} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: None } }, expr: LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }, metrics_set: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, preserve_partitioning: true, fetch: None, common_sort_prefix: [], cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, leading_map: {Column { name: \"l_returnflag\", index: 0 }: [0]} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: Hash([Column { name: \"l_returnflag\", index: 0 }, Column { name: \"l_linestatus\", index: 1 }], 24), emission_type: Final, boundedness: Bounded, evaluation_type: Lazy, scheduling_type: NonCooperative, output_ordering: Some(LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }) }, filter: None }, expr: LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }, metrics: ExecutionPlanMetricsSet { inner: Mutex { data: MetricsSet { metrics: [] } } }, fetch: None, cache: PlanProperties { eq_properties: EquivalenceProperties { eq_group: EquivalenceGroup { map: {}, classes: [] }, oeq_class: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, oeq_cache: OrderingEquivalenceCache { normal_cls: OrderingEquivalenceClass { orderings: [LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }] }, leading_map: {Column { name: \"l_returnflag\", index: 0 }: [0]} }, constraints: Constraints { inner: [Unique([0, 1]), Unique([0, 1])] }, schema: Schema { fields: [Field { name: \"l_returnflag\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"l_linestatus\", data_type: Utf8View, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_qty\", data_type: Decimal128(14, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_base_price\", data_type: Decimal128(17, 2), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_disc_price\", data_type: Decimal128(38, 4), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"sum_charge\", data_type: Decimal128(38, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_qty\", data_type: Decimal128(8, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_price\", data_type: Decimal128(11, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"avg_disc\", data_type: Decimal128(6, 6), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }, Field { name: \"count_order\", data_type: Int64, nullable: false, dict_id: 0, dict_is_ordered: false, metadata: {} }], metadata: {} } }, partitioning: UnknownPartitioning(1), emission_type: Final, boundedness: Bounded, evaluation_type: Eager, scheduling_type: Cooperative, output_ordering: Some(LexOrdering { exprs: [PhysicalSortExpr { expr: Column { name: \"l_returnflag\", index: 0 }, options: SortOptions { descending: false, nulls_first: false } }, PhysicalSortExpr { expr: Column { name: \"l_linestatus\", index: 1 }, options: SortOptions { descending: false, nulls_first: false } }], set: {Column { name: \"l_linestatus\", index: 1 }, Column { name: \"l_returnflag\", index: 0 }} }) }, enable_round_robin_repartition: true }