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()
}