We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ece06ef commit 828a455Copy full SHA for 828a455
1 file changed
spark/src/test/scala/org/apache/spark/sql/benchmark/CometHashExpressionBenchmark.scala
@@ -50,6 +50,10 @@ object CometHashExpressionBenchmark extends CometBenchmarkBase {
50
runBenchmarkWithTable("Hash expression benchmarks", values) { v =>
51
withTempPath { dir =>
52
withTempTable("parquetV1Table") {
53
+ // Data distribution: 1% NULL per column
54
+ // - c_str: unique strings "string_0" through "string_N"
55
+ // - c_int: integers 0-999,999 (cycling)
56
+ // - c_long: large values 0 to ~1 billion
57
prepareTable(
58
dir,
59
spark.sql(s"""
0 commit comments