Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
wangjunbo committed Feb 23, 2024
1 parent 90a1256 commit 84114f3
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -43,13 +43,13 @@ trait TRowSetGenerator[SchemaT, RowT, ColumnT]

def toRowBasedSet(rows: Seq[RowT], schema: SchemaT): TRowSet = {
val tRows = rows.map { row =>
var j = 0
var i = 0
val columnSize = getColumnSizeFromSchemaType(schema)
val tColumnValues = new JArrayList[TColumnValue](columnSize)
while (j < columnSize) {
val columnValue = toTColumnValue(row, j, schema)
while (i < columnSize) {
val columnValue = toTColumnValue(row, i, schema)
tColumnValues.add(columnValue)
j += 1
i += 1
}
new TRow(tColumnValues)
}.asJava
Expand Down

0 comments on commit 84114f3

Please sign in to comment.