Merge pull request #73 from nrkno/feature/prepare-udf

Feature/prepare udf

Author: ingarabr

build.sbt

@@ -79,10 +79,15 @@ val commonSettings = Seq(
   },
   scalacOptions -= "-source:3.0-migration",
   scalacOptions ++= {
+    val compilerWarnings =
+      List(
+        "cat=other-match-analysis:e", // error on exhaustive match
+        "cat=other:e" // compare values like 1 == "str"
+      ).mkString("-Wconf:", ",", ",any:wv")
     if (scalaVersion.value.startsWith("3")) {
-      Seq("-source:3.2-migration")
+      Seq("-source:3.2-migration", compilerWarnings)
     } else {
-      Seq("-feature", "-language:implicitConversions")
+      Seq("-feature", "-language:implicitConversions", compilerWarnings)
     }
   }
 )

core/src/main/scala/no/nrk/bigquery/BQSqlFrag.scala

@@ -116,7 +116,7 @@ object BQSqlFrag {
   def backticks(string: String): BQSqlFrag = Frag("`" + string + "`")
 
   case class Frag(string: String) extends BQSqlFrag
-  case class Call(udf: UDF, args: Seq[BQSqlFrag]) extends BQSqlFrag {
+  case class Call(udf: UDF, args: List[BQSqlFrag]) extends BQSqlFrag {
     require(
       udf.params.length == args.length,
       s"UDF ${udf.name.value}: Expected ${udf.params.length} arguments, got ${args.length}"

core/src/main/scala/no/nrk/bigquery/BigQueryClient.scala

@@ -17,6 +17,7 @@ import com.google.cloud.http.HttpTransportOptions
 import fs2.{Chunk, Stream}
 import io.circe.Encoder
 import no.nrk.bigquery.syntax.showJob
+import no.nrk.bigquery.internal.TableUpdateOperation
 import no.nrk.bigquery.metrics.{BQMetrics, MetricsOps}
 import no.nrk.bigquery.util.StreamUtils
 import org.apache.avro
@@ -319,7 +320,7 @@ class BigQueryClient[F[_]](
     }
     .flatMap(tmp =>
       F.interruptible {
-        val tempTableBqDef = UpdateOperation.createNew(tmp).table
+        val tempTableBqDef = TableUpdateOperation.createNew(tmp).table
         val expirationTime =
           Instant.now.plusMillis(expirationDuration.getOrElse(1.hour).toMillis)