Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
bowenliang123 committed Dec 29, 2023
1 parent 0d86705 commit e12528c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ trait TRowSetGenerator[SchemaT, RowT, ColumnT]
}

def toColumnBasedSetInParallel(rows: Seq[RowT], schema: SchemaT): TRowSet = {
val columnIndexPar = (0 until getColumnSizeFromSchemaType(schema)).toIndexedSeq.par
val columnIndexPar = (0 until getColumnSizeFromSchemaType(schema)).par
columnIndexPar.tasksupport = tColumnParallelGenerator
val tColumns = columnIndexPar.map { colIdx =>
(colIdx, toTColumn(rows, colIdx, getColumnType(schema, colIdx)))
Expand Down

0 comments on commit e12528c

Please sign in to comment.