Skip to content

Commit fe7d960

Browse files
committed
small refactor, revert change to build.sbt
1 parent e969cd5 commit fe7d960

File tree

4 files changed

+12
-15
lines changed

4 files changed

+12
-15
lines changed

build.sbt

+1-1
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ lazy val ratatoolCommon = project
165165
"org.apache.avro" % "avro" % avroVersion,
166166
"org.apache.avro" % "avro-mapred" % avroVersion classifier "hadoop2",
167167
"com.google.guava" % "guava" % guavaVersion,
168-
"com.google.apis" % "google-api-services-bigquery" % bigqueryVersion,
168+
"com.google.apis" % "google-api-services-bigquery" % bigqueryVersion % Test,
169169
"org.apache.avro" % "avro" % avroVersion % Test classifier "tests",
170170
"org.slf4j" % "slf4j-simple" % slf4jVersion % Test,
171171
),
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,12 @@
11
package com.spotify.ratatool
22

3-
import com.google.api.services.bigquery.model.TableFieldSchema
4-
53
object BigQueryUtil {
64
// a null TableFieldSchema mode can be treated as "NULLABLE", which is the
7-
// default value according to the docs
8-
def getFieldModeWithDefault(f: TableFieldSchema): String = {
9-
if (f.getMode == null) {
10-
"NULLABLE"
11-
} else {
12-
f.getMode
5+
// default value according to the docs, so return "NULLABLE" if fieldMode is null
6+
// otherwise return fieldMode
7+
def getFieldModeWithDefault(fieldMode: String): String =
8+
fieldMode match {
9+
case null => "NULLABLE"
10+
case _ => fieldMode
1311
}
14-
}
1512
}

ratatool-diffy/src/main/scala/com/spotify/ratatool/diffy/BigDiffy.scala

+4-4
Original file line numberDiff line numberDiff line change
@@ -553,11 +553,11 @@ object BigDiffy extends Command with Serializable {
553553
case (Some(f), None) => f
554554
case (None, Some(f)) => f
555555
case (Some(fx), Some(fy)) =>
556+
val fxMode = getFieldModeWithDefault(fx.getMode)
557+
val fyMode = getFieldModeWithDefault(fy.getMode)
556558
assert(
557-
fx.getType == fy.getType && getFieldModeWithDefault(fx) == getFieldModeWithDefault(fy),
558-
f"field ${fx.getName} in lhs, type: ${fx.getType} mode: ${getFieldModeWithDefault(
559-
fx
560-
)}, and rhs, type: ${fy.getType} mode: ${getFieldModeWithDefault(fy)}, do not match"
559+
fx.getType == fy.getType && fxMode == fyMode,
560+
f"field ${fx.getName} in lhs, type: ${fx.getType} mode: $fxMode, and rhs, type: ${fy.getType} mode: $fyMode, do not match"
561561
)
562562
if (fx.getType == "RECORD") {
563563
fx.setFields(

ratatool-scalacheck/src/main/scala/com/spotify/ratatool/scalacheck/TableRowGenerator.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ trait TableRowGeneratorOps {
144144
case t => throw new RuntimeException(s"Unknown type: $t")
145145
}
146146

147-
getFieldModeWithDefault(fieldSchema) match {
147+
getFieldModeWithDefault(fieldSchema.getMode) match {
148148
case "REQUIRED" => genV()
149149
case "NULLABLE" =>
150150
Arbitrary.arbBool.arbitrary.flatMap { e =>

0 commit comments

Comments
 (0)