Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
81 changes: 30 additions & 51 deletions .github/workflows/tpcds-reusable.yml
Original file line number Diff line number Diff line change
Expand Up @@ -88,45 +88,6 @@ env:
WGET_OPTS: "--tries=3 --timeout=30 -c"

jobs:
build-validator:
name: Build TPC-DS Validator
runs-on: ubuntu-24.04
steps:
- name: Cache TPC-DS Validator
uses: actions/cache@v5
id: cache-tpcds-validator
with:
key: tpcds-validator_${{ inputs.scalaver }}
path: target/tpcds-validator_${{ inputs.scalaver }}-0.1.0-SNAPSHOT-with-dependencies.jar

- name: Checkout TPC-DS Validator
uses: actions/checkout@v6
if: steps.cache-tpcds-validator.outputs.cache-hit != 'true'
with:
repository: auron-project/tpcds-validator

- name: Setup Java and Maven cache
uses: actions/setup-java@v5
if: steps.cache-tpcds-validator.outputs.cache-hit != 'true'
with:
distribution: 'adopt-hotspot'
java-version: ${{ inputs.javaver }}
cache: 'maven'

- name: Build TPC-DS Validator
if: steps.cache-tpcds-validator.outputs.cache-hit != 'true'
run: ./build/mvn package -DskipTests -Pscala-${{ inputs.scalaver }}

- name: Upload TPC-DS Validator
uses: actions/upload-artifact@v6
with:
name: >
tpcds-validator-${{ inputs.sparkver }}_${{ inputs.scalaver }}-jdk-${{ inputs.javaver
}}${{ inputs.celebornver && format('-{0}', inputs.celebornver) || ''
}}${{ inputs.unifflever && format('-{0}', inputs.unifflever) || '' }}
path: target/tpcds-validator_${{ inputs.scalaver }}-0.1.0-SNAPSHOT-with-dependencies.jar
overwrite: true

build-auron-jar:
name: Build Auron JAR
runs-on: ubuntu-24.04
Expand Down Expand Up @@ -159,8 +120,8 @@ jobs:
clippy

- name: Cargo clippy
# First eliminate unwrap; then enable -D warnings to enforce all default lints.
run: |
# First eliminate unwrap; then enable -D warnings to enforce all default lints.
cargo clippy --all-targets --workspace -- -A warnings -A clippy::all -D clippy::unwrap_used

- name: Cargo test
Expand Down Expand Up @@ -223,10 +184,18 @@ jobs:
}}${{ inputs.unifflever && format('-{0}', inputs.unifflever) || '' }}
path: target/auron-${{ inputs.sparkver }}_${{ inputs.scalaver }}-pre-*.jar
overwrite: true
- name: Upload auron maven artifacts (Spark ${{ inputs.sparkver }}, Scala ${{ inputs.scalaver }}, JDK ${{ inputs.javaver }})
uses: actions/upload-artifact@v4
with:
name: auron-artifacts-${{ inputs.sparkver }}_${{ inputs.scalaver }}-jdk-${{ inputs.javaver
}}${{ inputs.celebornver && format('-{0}', inputs.celebornver) || ''
}}${{ inputs.unifflever && format('-{0}', inputs.unifflever) || '' }}
path: ~/.m2/repository/org/apache/auron
if-no-files-found: error

run-tpcds-test:
name: Run TPC-DS test ${{ matrix.query }}
needs: [build-validator, build-auron-jar]
needs: [build-auron-jar]
runs-on: ubuntu-24.04
strategy:
fail-fast: false
Expand Down Expand Up @@ -286,13 +255,14 @@ jobs:
}}${{ inputs.celebornver && format('-{0}', inputs.celebornver) || ''
}}${{ inputs.unifflever && format('-{0}', inputs.unifflever) || '' }}

- name: Download TPC-DS Validator JAR
- name: Download auron maven artifacts
uses: actions/download-artifact@v7
with:
name: >
tpcds-validator-${{ inputs.sparkver }}_${{ inputs.scalaver }}-jdk-${{ inputs.javaver
}}${{ inputs.celebornver && format('-{0}', inputs.celebornver) || ''
auron-artifacts-${{ inputs.sparkver }}_${{ inputs.scalaver }}-jdk-${{ inputs.javaver
}}${{ inputs.celebornver && format('-{0}', inputs.celebornver) || ''
}}${{ inputs.unifflever && format('-{0}', inputs.unifflever) || '' }}
path: ~/.m2/repository/org/apache/auron

- name: Checkout TPC-DS Data
uses: actions/checkout@v6
Expand All @@ -303,7 +273,10 @@ jobs:
- name: Install Auron JAR
run: |
ls -la
cp auron-*${{ inputs.sparkver }}_${{ inputs.scalaver }}*.jar spark-bin-${{ inputs.sparkver }}_${{ inputs.scalaver }}/jars/
jar=$(ls -1 auron-${{ inputs.sparkver }}_${{ inputs.scalaver }}*.jar | head -n1)
[ -n "$jar" ] || { echo "No jar matched: auron-${{ inputs.sparkver }}_${{ inputs.scalaver }}*.jar"; exit 1; }
echo "AURON_SPARK_JAR=$jar" >> "$GITHUB_ENV"
cp "$jar" spark-bin-${{ inputs.sparkver }}_${{ inputs.scalaver }}/jars/

- name: Setup Java and Maven cache
uses: actions/setup-java@v5
Expand Down Expand Up @@ -406,16 +379,22 @@ jobs:
cp uniffle-bin-${{ steps.get-dependency-version.outputs.uniffleversion }}/jars/client/spark3/*.jar spark-bin-${{ inputs.sparkver }}_${{ inputs.scalaver }}/jars/

- name: Run TPC-DS Query ${{ matrix.query }}
env:
RUST_LOG: ERROR
RUST_BACKTRACE: 1
SPARK_VERSION: ${{ inputs.sparkver }}
SCALA_VERSION: ${{ inputs.scalaver }}
SPARK_HOME: spark-bin-${{ inputs.sparkver }}_${{ inputs.scalaver }}
run: |
ls -la
export RUST_LOG=ERROR
export RUST_BACKTRACE=1
export SCALA_VERSION=${{ inputs.scalaver }}
export SPARK_HOME=spark-bin-${{ inputs.sparkver }}_${{ inputs.scalaver }}
dev/run-tpcds-test \
ls -la ~/.m2/repository/org/apache/auron
dev/auron-it/run-it.sh \
${{ inputs.extrasparkconf }} \
--type tpcds \
--data-location dev/tpcds_1g \
--query-filter ${{ matrix.query }}
--query-filter ${{ matrix.query }} \
--result-check \
--plan-check

- name: Upload RSS log
if: ${{ failure() && (inputs.celebornver != '' || inputs.unifflever != '') }}
Expand Down
64 changes: 64 additions & 0 deletions dev/auron-it/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,70 @@

<build>
<plugins>

<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<version>${checkstyle-plugin.version}</version>
<configuration>
<failOnViolation>true</failOnViolation>
<includeTestSourceDirectory>true</includeTestSourceDirectory>
<sourceDirectories>
<directory>${project.basedir}/src/main/java</directory>
<directory>${project.basedir}/src/main/scala</directory>
</sourceDirectories>
<testSourceDirectories>
<directory>${project.basedir}/src/test/java</directory>
</testSourceDirectories>
<suppressionsLocation>${maven.multiModuleProjectDirectory}/../../dev/checkstyle-suppressions.xml</suppressionsLocation>
<configLocation>${maven.multiModuleProjectDirectory}/../../dev/checkstyle.xml</configLocation>
<outputFile>${project.basedir}/target/checkstyle-output.xml</outputFile>
<inputEncoding>UTF-8</inputEncoding>
<outputEncoding>UTF-8</outputEncoding>
</configuration>
<dependencies>
<dependency>
<groupId>com.puppycrawl.tools</groupId>
<artifactId>checkstyle</artifactId>
<version>8.29</version>
</dependency>
</dependencies>
<executions>
<execution>
<goals>
<goal>check</goal>
</goals>
<phase>validate</phase>
</execution>
</executions>
</plugin>

<plugin>
<groupId>org.scalastyle</groupId>
<artifactId>scalastyle-maven-plugin</artifactId>
<version>${maven.plugin.scalastyle.version}</version>
<configuration>
<verbose>false</verbose>
<failOnViolation>true</failOnViolation>
<includeTestSourceDirectory>false</includeTestSourceDirectory>
<failOnWarning>false</failOnWarning>
<sourceDirectory>${basedir}/src/main/scala</sourceDirectory>
<testSourceDirectory>${basedir}/src/test/scala</testSourceDirectory>
<configLocation>${maven.multiModuleProjectDirectory}/../../dev/scalastyle-config.xml</configLocation>
<outputFile>${basedir}/target/scalastyle-output.xml</outputFile>
<inputEncoding>${project.build.sourceEncoding}</inputEncoding>
<outputEncoding>${project.reporting.outputEncoding}</outputEncoding>
</configuration>
<executions>
<execution>
<goals>
<goal>check</goal>
</goals>
<phase>validate</phase>
</execution>
</executions>
</plugin>

<!-- spotless -->
<plugin>
<groupId>com.diffplug.spotless</groupId>
Expand Down
4 changes: 2 additions & 2 deletions dev/auron-it/run-it.sh
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,8 @@ while [[ $# -gt 0 ]]; do
done

exec $SPARK_HOME/bin/spark-submit \
--driver-memory 5g \
--conf spark.driver.memoryOverhead=3072 \
--driver-memory 8g \
--conf spark.driver.memoryOverhead=4g \
--conf spark.auron.memoryFraction=0.8 \
--conf spark.driver.extraJavaOptions=-XX:+UseG1GC \
--conf spark.ui.enabled=false \
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -440,13 +440,13 @@ Condition : isnotnull((avg(ctr_total_return) * 1.2)#26)
Input [2]: [(avg(ctr_total_return) * 1.2)#26, ctr_store_sk#21]
Arguments: [ctr_store_sk#21 ASC NULLS FIRST], false

(67) SortMergeJoin [codegen id : 1]
(67) SortMergeJoin [codegen id : X]
Left keys [1]: [ctr_store_sk#12]
Right keys [1]: [ctr_store_sk#21]
Join type: Inner
Join condition: (cast(ctr_total_return#13 as decimal(24,7)) > (avg(ctr_total_return) * 1.2)#26)

(68) Project [codegen id : 1]
(68) Project [codegen id : X]
Output [2]: [ctr_customer_sk#11, ctr_store_sk#12]
Input [5]: [ctr_customer_sk#11, ctr_store_sk#12, ctr_total_return#13, (avg(ctr_total_return) * 1.2)#26, ctr_store_sk#21]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -888,13 +888,13 @@ Input [2]: [customer_id#71, year_total#72]
Input [2]: [customer_id#71, year_total#72]
Arguments: [customer_id#71 ASC NULLS FIRST], false

(151) SortMergeJoin [codegen id : 1]
(151) SortMergeJoin [codegen id : X]
Left keys [1]: [customer_id#19]
Right keys [1]: [customer_id#71]
Join type: Inner
Join condition: (CASE WHEN (year_total#56 > 0.00) THEN (year_total#72 / year_total#56) END > CASE WHEN (year_total#20 > 0.00) THEN (year_total#37 / year_total#20) END)

(152) Project [codegen id : 1]
(152) Project [codegen id : X]
Output [1]: [customer_preferred_cust_flag#36]
Input [7]: [customer_id#19, year_total#20, customer_preferred_cust_flag#36, year_total#37, year_total#56, customer_id#71, year_total#72]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,7 @@ Arguments: [i_class#8 ASC NULLS FIRST], false
Input [7]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, _w0#17, i_item_id#5]
Arguments: [sum(_w0#17) windowspecdefinition(i_class#8, specifiedwindowframe(RowFrame, unboundedpreceding$(), unboundedfollowing$())) AS _we0#18], [i_class#8]

(49) Project [codegen id : 1]
(49) Project [codegen id : X]
Output [7]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, ((_w0#17 * 100) / _we0#18) AS revenueratio#19, i_item_id#5]
Input [8]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, _w0#17, i_item_id#5, _we0#18]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -272,13 +272,13 @@ Input [2]: [ca_address_sk#12, ca_state#13]
Input [2]: [ca_address_sk#12, ca_state#13]
Arguments: [ca_address_sk#12 ASC NULLS FIRST], false

(33) SortMergeJoin [codegen id : 1]
(33) SortMergeJoin [codegen id : X]
Left keys [1]: [ss_addr_sk#4]
Right keys [1]: [ca_address_sk#12]
Join type: Inner
Join condition: ((((ca_state#13 IN (TX,OH) AND (ss_net_profit#10 >= 100.00)) AND (ss_net_profit#10 <= 200.00)) OR ((ca_state#13 IN (OR,NM,KY) AND (ss_net_profit#10 >= 150.00)) AND (ss_net_profit#10 <= 300.00))) OR ((ca_state#13 IN (VA,TX,MS) AND (ss_net_profit#10 >= 50.00)) AND (ss_net_profit#10 <= 250.00)))

(34) Project [codegen id : 1]
(34) Project [codegen id : X]
Output [7]: [ss_sold_date_sk#1, ss_cdemo_sk#2, ss_hdemo_sk#3, ss_quantity#6, ss_sales_price#7, ss_ext_sales_price#8, ss_ext_wholesale_cost#9]
Input [11]: [ss_sold_date_sk#1, ss_cdemo_sk#2, ss_hdemo_sk#3, ss_addr_sk#4, ss_quantity#6, ss_sales_price#7, ss_ext_sales_price#8, ss_ext_wholesale_cost#9, ss_net_profit#10, ca_address_sk#12, ca_state#13]

Expand Down Expand Up @@ -405,13 +405,13 @@ Input [3]: [#17#17, #18#18, #19#19]
Input [3]: [#17#17, #18#18, #19#19]
Arguments: [cd_demo_sk#17 ASC NULLS FIRST], false

(65) SortMergeJoin [codegen id : 2]
(65) SortMergeJoin [codegen id : X]
Left keys [1]: [ss_cdemo_sk#2]
Right keys [1]: [cd_demo_sk#17]
Join type: Inner
Join condition: ((((((cd_marital_status#18 = M) AND (cd_education_status#19 = Advanced Degree)) AND (ss_sales_price#7 >= 100.00)) AND (ss_sales_price#7 <= 150.00)) OR ((((cd_marital_status#18 = S) AND (cd_education_status#19 = College)) AND (ss_sales_price#7 >= 50.00)) AND (ss_sales_price#7 <= 100.00))) OR ((((cd_marital_status#18 = W) AND (cd_education_status#19 = 2 yr Degree)) AND (ss_sales_price#7 >= 150.00)) AND (ss_sales_price#7 <= 200.00)))

(66) Project [codegen id : 2]
(66) Project [codegen id : X]
Output [7]: [ss_hdemo_sk#3, ss_quantity#6, ss_sales_price#7, ss_ext_sales_price#8, ss_ext_wholesale_cost#9, cd_marital_status#18, cd_education_status#19]
Input [9]: [ss_cdemo_sk#2, ss_hdemo_sk#3, ss_quantity#6, ss_sales_price#7, ss_ext_sales_price#8, ss_ext_wholesale_cost#9, #17#17, #18#18, #19#19]

Expand Down Expand Up @@ -471,17 +471,17 @@ Input [2]: [#20#20, #21#21]
Input [2]: [#20#20, #21#21]
Arguments: [hd_demo_sk#20 ASC NULLS FIRST], false

(81) SortMergeJoin [codegen id : 3]
(81) SortMergeJoin [codegen id : X]
Left keys [1]: [ss_hdemo_sk#3]
Right keys [1]: [hd_demo_sk#20]
Join type: Inner
Join condition: (((((((cd_marital_status#18 = M) AND (cd_education_status#19 = Advanced Degree)) AND (ss_sales_price#7 >= 100.00)) AND (ss_sales_price#7 <= 150.00)) AND (hd_dep_count#21 = 3)) OR (((((cd_marital_status#18 = S) AND (cd_education_status#19 = College)) AND (ss_sales_price#7 >= 50.00)) AND (ss_sales_price#7 <= 100.00)) AND (hd_dep_count#21 = 1))) OR (((((cd_marital_status#18 = W) AND (cd_education_status#19 = 2 yr Degree)) AND (ss_sales_price#7 >= 150.00)) AND (ss_sales_price#7 <= 200.00)) AND (hd_dep_count#21 = 1)))

(82) Project [codegen id : 3]
(82) Project [codegen id : X]
Output [3]: [ss_quantity#6, ss_ext_sales_price#8, ss_ext_wholesale_cost#9]
Input [9]: [ss_hdemo_sk#3, ss_quantity#6, ss_sales_price#7, ss_ext_sales_price#8, ss_ext_wholesale_cost#9, cd_marital_status#18, cd_education_status#19, #20#20, #21#21]

(83) HashAggregate [codegen id : 3]
(83) HashAggregate [codegen id : X]
Input [3]: [ss_quantity#6, ss_ext_sales_price#8, ss_ext_wholesale_cost#9]
Keys: []
Functions [4]: [partial_avg(ss_quantity#6), partial_avg(UnscaledValue(ss_ext_sales_price#8)), partial_avg(UnscaledValue(ss_ext_wholesale_cost#9)), partial_sum(UnscaledValue(ss_ext_wholesale_cost#9))]
Expand All @@ -496,7 +496,7 @@ Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=11]
Output [7]: [sum#29, count#30, sum#31, count#32, sum#33, count#34, sum#35]
Arguments: X

(86) HashAggregate [codegen id : 4]
(86) HashAggregate [codegen id : X]
Input [7]: [sum#29, count#30, sum#31, count#32, sum#33, count#34, sum#35]
Keys: []
Functions [4]: [avg(ss_quantity#6), avg(UnscaledValue(ss_ext_sales_price#8)), avg(UnscaledValue(ss_ext_wholesale_cost#9)), sum(UnscaledValue(ss_ext_wholesale_cost#9))]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -225,13 +225,13 @@ Input [3]: [#6#6, #7#7, #8#8]
Input [3]: [#6#6, #7#7, #8#8]
Arguments: [ca_address_sk#6 ASC NULLS FIRST], false

(32) SortMergeJoin [codegen id : 1]
(32) SortMergeJoin [codegen id : X]
Left keys [1]: [c_current_addr_sk#5]
Right keys [1]: [ca_address_sk#6]
Join type: Inner
Join condition: ((substr(ca_zip#8, 1, 5) IN (85669,86197,88274,83405,86475,85392,85460,80348,81792) OR ca_state#7 IN (CA,WA,GA)) OR (cs_sales_price#3 > 500.00))

(33) Project [codegen id : 1]
(33) Project [codegen id : X]
Output [3]: [cs_sold_date_sk#1, cs_sales_price#3, ca_zip#8]
Input [6]: [cs_sold_date_sk#1, cs_sales_price#3, c_current_addr_sk#5, #6#6, #7#7, #8#8]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -199,13 +199,13 @@ Input [2]: [#8#8, #9#9]
Input [2]: [#8#8, #9#9]
Arguments: [cs_order_number#9 ASC NULLS FIRST], false

(16) SortMergeJoin [codegen id : 1]
(16) SortMergeJoin [codegen id : X]
Left keys [1]: [cs_order_number#5]
Right keys [1]: [cs_order_number#9]
Join type: LeftSemi
Join condition: NOT (cs_warehouse_sk#4 = cs_warehouse_sk#8)

(17) Project [codegen id : 1]
(17) Project [codegen id : X]
Output [6]: [cs_ship_date_sk#1, cs_ship_addr_sk#2, cs_call_center_sk#3, cs_order_number#5, cs_ext_ship_cost#6, cs_net_profit#7]
Input [7]: [#1#1, #2#2, #3#3, #4#4, #5#5, #6#6, #7#7]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -466,17 +466,17 @@ Input [2]: [#19#19, #20#20]
Input [2]: [#19#19, #20#20]
Arguments: [s_store_sk#19 ASC NULLS FIRST], false

(79) SortMergeJoin [codegen id : 1]
(79) SortMergeJoin [codegen id : X]
Left keys [1]: [ss_store_sk#7]
Right keys [1]: [s_store_sk#19]
Join type: Inner
Join condition: NOT (substr(ca_zip#18, 1, 5) = substr(s_zip#20, 1, 5))

(80) Project [codegen id : 1]
(80) Project [codegen id : X]
Output [5]: [ss_ext_sales_price#8, i_brand_id#10, i_brand#11, i_manufact_id#12, i_manufact#13]
Input [9]: [ss_store_sk#7, ss_ext_sales_price#8, i_brand_id#10, i_brand#11, i_manufact_id#12, i_manufact#13, ca_zip#18, #19#19, #20#20]

(81) HashAggregate [codegen id : 1]
(81) HashAggregate [codegen id : X]
Input [5]: [ss_ext_sales_price#8, i_brand_id#10, i_brand#11, i_manufact_id#12, i_manufact#13]
Keys [4]: [i_brand#11, i_brand_id#10, i_manufact_id#12, i_manufact#13]
Functions [1]: [partial_sum(UnscaledValue(ss_ext_sales_price#8))]
Expand All @@ -495,7 +495,7 @@ Arguments: X
Input [5]: [i_brand#11, i_brand_id#10, i_manufact_id#12, i_manufact#13, sum#22]
Arguments: coalesced

(85) HashAggregate [codegen id : 2]
(85) HashAggregate [codegen id : X]
Input [5]: [i_brand#11, i_brand_id#10, i_manufact_id#12, i_manufact#13, sum#22]
Keys [4]: [i_brand#11, i_brand_id#10, i_manufact_id#12, i_manufact#13]
Functions [1]: [sum(UnscaledValue(ss_ext_sales_price#8))]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -442,7 +442,7 @@ Right keys [1]: [(d_week_seq2#76 - 53)]
Join type: Inner
Join condition: None

(71) Project [codegen id : 1]
(71) Project [codegen id : X]
Output [8]: [d_week_seq1#43, round((sun_sales1#44 / sun_sales2#77), 2) AS round((sun_sales1 / sun_sales2), 2)#84, round((mon_sales1#45 / mon_sales2#78), 2) AS round((mon_sales1 / mon_sales2), 2)#85, round((tue_sales1#46 / tue_sales2#79), 2) AS round((tue_sales1 / tue_sales2), 2)#86, round((wed_sales1#47 / wed_sales2#80), 2) AS round((wed_sales1 / wed_sales2), 2)#87, round((thu_sales1#48 / thu_sales2#81), 2) AS round((thu_sales1 / thu_sales2), 2)#88, round((fri_sales1#49 / fri_sales2#82), 2) AS round((fri_sales1 / fri_sales2), 2)#89, round((sat_sales1#50 / sat_sales2#83), 2) AS round((sat_sales1 / sat_sales2), 2)#90]
Input [16]: [d_week_seq1#43, sun_sales1#44, mon_sales1#45, tue_sales1#46, wed_sales1#47, thu_sales1#48, fri_sales1#49, sat_sales1#50, d_week_seq2#76, sun_sales2#77, mon_sales2#78, tue_sales2#79, wed_sales2#80, thu_sales2#81, fri_sales2#82, sat_sales2#83]

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,7 @@ Arguments: [i_class#8 ASC NULLS FIRST], false
Input [7]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, _w0#17, i_item_id#5]
Arguments: [sum(_w0#17) windowspecdefinition(i_class#8, specifiedwindowframe(RowFrame, unboundedpreceding$(), unboundedfollowing$())) AS _we0#18], [i_class#8]

(49) Project [codegen id : 1]
(49) Project [codegen id : X]
Output [7]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, ((_w0#17 * 100) / _we0#18) AS revenueratio#19, i_item_id#5]
Input [8]: [i_item_desc#6, i_category#9, i_class#8, i_current_price#7, itemrevenue#16, _w0#17, i_item_id#5, _we0#18]

Expand Down
Loading
Loading