def mutationsToRow()

in bigtable/src/main/scala/magnolify/bigtable/BigtableType.scala [63:87]


  def mutationsToRow(key: ByteString, mutations: Seq[Mutation]): Row = {
    val families = mutations
      .map(_.getSetCell)
      .groupBy(_.getFamilyName)
      .map { case (familyName, setCells) =>
        val columns = setCells
          .sortBy(_.getColumnQualifier.toStringUtf8)
          .map { setCell =>
            Column
              .newBuilder()
              .setQualifier(setCell.getColumnQualifier)
              .addCells(
                Cell
                  .newBuilder()
                  .setValue(setCell.getValue)
                  .setTimestampMicros(setCell.getTimestampMicros)
              )
              .build()
          }
          .toSeq // keep for java 2.12
        Family.newBuilder().setName(familyName).addAllColumns(columns.asJava).build()
      }
      .toSeq
    Row.newBuilder().setKey(key).addAllFamilies(families.asJava).build()
  }