Skip to content

Commit

Permalink
fix naming
Browse files Browse the repository at this point in the history
  • Loading branch information
peter-toth committed Mar 22, 2021
1 parent 30d2d8b commit 0d38ac2
Showing 1 changed file with 27 additions and 27 deletions.
54 changes: 27 additions & 27 deletions sql/core/src/test/scala/org/apache/spark/sql/FileScanSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
test(s"SPARK-33482: Test $name equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -105,7 +105,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanEquals = scanBuilder(
val scanEquals = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema.copy(),
Expand All @@ -116,13 +116,13 @@ trait FileScanSuiteBase extends SharedSparkSession {
Seq(partitionFilters: _*),
Seq(dataFilters: _*))

assert(parquetScan === parquetScanEquals)
assert(scan === scanEquals)
}

test(s"SPARK-33482: Test $name fileIndex not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -135,7 +135,7 @@ trait FileScanSuiteBase extends SharedSparkSession {

val partitioningAwareFileIndexNotEqual = newPartitioningAwareFileIndex()

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndexNotEqual,
dataSchema,
Expand All @@ -146,14 +146,14 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}

if (!exclusions.contains("dataSchema")) {
test(s"SPARK-33482: Test $name dataSchema not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -164,7 +164,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchemaNotEqual,
Expand All @@ -175,14 +175,14 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}
}

test(s"SPARK-33482: Test $name readDataSchema not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -193,7 +193,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -204,13 +204,13 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}

test(s"SPARK-33482: Test $name readPartitionSchema not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -221,7 +221,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -232,14 +232,14 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}

if (!exclusions.contains("pushedFilters")) {
test(s"SPARK-33482: Test $name pushedFilters not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -250,7 +250,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -261,14 +261,14 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}
}

test(s"SPARK-33482: Test $name options not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -279,7 +279,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -290,13 +290,13 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}

test(s"SPARK-33482: Test $name partitionFilters not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -307,7 +307,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -317,13 +317,13 @@ trait FileScanSuiteBase extends SharedSparkSession {
options,
partitionFiltersNotEqual,
dataFilters)
assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}

test(s"SPARK-33482: Test $name dataFilters not equals") {
val partitioningAwareFileIndex = newPartitioningAwareFileIndex()

val parquetScan = scanBuilder(
val scan = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -334,7 +334,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
partitionFilters,
dataFilters)

val parquetScanNotEqual = scanBuilder(
val scanNotEqual = scanBuilder(
spark,
partitioningAwareFileIndex,
dataSchema,
Expand All @@ -344,7 +344,7 @@ trait FileScanSuiteBase extends SharedSparkSession {
options,
partitionFilters,
dataFiltersNotEqual)
assert(parquetScan !== parquetScanNotEqual)
assert(scan !== scanNotEqual)
}
}
}
Expand Down

0 comments on commit 0d38ac2

Please sign in to comment.