private def this()

in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model/QueryJsonProtocol.scala [207:287]
69 lines of code
1 McCabe index (conditional complexity)

  private def this(@JsonProperty("schema") schema: TableSchema,
      @JsonProperty(value = "jobReference", required = true) jobReference: JobReference,
      @JsonProperty("totalRows") totalRows: String,
      @JsonProperty("pageToken") pageToken: String,
      @JsonProperty("rows") rows: util.List[T],
      @JsonProperty("totalBytesProcessed") totalBytesProcessed: String,
      @JsonProperty(value = "jobComplete", required = true) jobComplete: Boolean,
      @JsonProperty("errors") errors: util.List[ErrorProto],
      @JsonProperty("cacheHit") cacheHit: lang.Boolean,
      @JsonProperty("numDmlAffectedRows") numDmlAffectedRows: String) =
    this(
      Option(schema),
      jobReference,
      Option(totalRows).map(_.toLong),
      Option(pageToken),
      Option(rows).map(_.asScala.toList),
      Option(totalBytesProcessed).map(_.toLong),
      jobComplete,
      Option(errors).map(_.asScala.toList),
      Option(cacheHit).map(_.booleanValue),
      Option(numDmlAffectedRows).map(_.toLong))

  def getSchema = schema.toJava
  def getJobReference = jobReference
  def getTotalRows = totalRows.toJavaPrimitive
  def getPageToken = pageToken.toJava
  def getRows: util.Optional[util.List[T] @uncheckedVariance] = rows.map(_.asJava).toJava
  def getTotalBytesProcessed = totalBytesProcessed.toJavaPrimitive
  def getJobComplete = jobComplete
  def getErrors = errors.map(_.asJava).toJava
  def getCacheHit = cacheHit.map(lang.Boolean.valueOf).toJava
  def getNumDmlAffectedRows = numDmlAffectedRows.toJavaPrimitive

  def withSchema(schema: Option[TableSchema]) =
    copy(schema = schema)
  def withSchema(schema: util.Optional[TableSchema]) =
    copy(schema = schema.toScala)

  def withJobReference(jobReference: JobReference) =
    copy(jobReference = jobReference)

  def withTotalRows(totalRows: Option[Long]) =
    copy(totalRows = totalRows)
  def withTotalRows(totalRows: util.OptionalLong) =
    copy(totalRows = totalRows.toScala)

  def withPageToken(pageToken: Option[String]) =
    copy(pageToken = pageToken)
  def withPageToken(pageToken: util.Optional[String]) =
    copy(pageToken = pageToken.toScala)

  def withRows[S >: T](rows: Option[Seq[S]]) =
    copy(rows = rows)
  def withRows(rows: util.Optional[util.List[T] @uncheckedVariance]) =
    copy(rows = rows.toScala.map(_.asScala.toList))

  def withTotalBytesProcessed(totalBytesProcessed: Option[Long]) =
    copy(totalBytesProcessed = totalBytesProcessed)
  def withTotalBytesProcessed(totalBytesProcessed: util.OptionalLong) =
    copy(totalBytesProcessed = totalBytesProcessed.toScala)

  def withJobComplete(jobComplete: Boolean) =
    copy(jobComplete = jobComplete)

  def withErrors(errors: Option[Seq[ErrorProto]]) =
    copy(errors = errors)
  def withErrors(errors: util.Optional[util.List[ErrorProto]]) =
    copy(errors = errors.toScala.map(_.asScala.toList))

  def withCacheHit(cacheHit: Option[Boolean]) =
    copy(cacheHit = cacheHit)
  def withCacheHit(cacheHit: util.Optional[lang.Boolean]) =
    copy(cacheHit = cacheHit.toScala.map(_.booleanValue))

  def withNumDmlAffectedRows(numDmlAffectedRows: Option[Long]) =
    copy(numDmlAffectedRows = numDmlAffectedRows)
  def withNumDmlAffectedRows(numDmlAffectedRows: util.OptionalLong) =
    copy(numDmlAffectedRows = numDmlAffectedRows.toScala)
}

object QueryResponse {