File tree Expand file tree Collapse file tree
main/scala/org/apache/comet/rules
test/scala/org/apache/spark/sql/benchmark Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -208,7 +208,7 @@ case class CometScanRule(session: SparkSession)
208208 ! COMET_SCAN_ALLOW_DISABLED_PARQUET_VECTORIZED_READER .get()) {
209209 withInfo(
210210 scanExec,
211- s " Native Parquet scan is incompatible with " +
211+ " Native Parquet scan is incompatible with " +
212212 s " ${SQLConf .PARQUET_VECTORIZED_READER_ENABLED .key}=false; set " +
213213 s " ${COMET_SCAN_ALLOW_DISABLED_PARQUET_VECTORIZED_READER .key}=true to opt in " )
214214 return None
@@ -700,7 +700,7 @@ case class CometScanTypeChecker() extends DataTypeSupport with CometTypeShim {
700700 fallbackReasons : ListBuffer [String ]): Boolean = {
701701 dt match {
702702 case ShortType if CometConf .COMET_PARQUET_UNSIGNED_SMALL_INT_CHECK .get() =>
703- fallbackReasons += s " Native Parquet scan may not handle unsigned UINT_8 correctly for " +
703+ fallbackReasons += " Native Parquet scan may not handle unsigned UINT_8 correctly for " +
704704 s " $dt. Set ${CometConf .COMET_PARQUET_UNSIGNED_SMALL_INT_CHECK .key}=false to allow " +
705705 " native execution if your data does not contain unsigned small integers. " +
706706 CometConf .COMPAT_GUIDE
Original file line number Diff line number Diff line change 1919
2020package org .apache .spark .sql .benchmark
2121
22- import org .apache .comet .CometConf
23-
2422// spotless:off
2523/**
2624 * Benchmark to measure performance of Comet array expressions. To run this benchmark:
You can’t perform that action at this time.
0 commit comments