asheeshgarg commented on issue #6003:
URL: https://github.com/apache/iceberg/issues/6003#issuecomment-1282569968
@nastra
Thanks for the inputs one thing I see when I call getVector and do a println
below code the columns are already deseralized in the print statement I was
assuming the vector should be serialized format while reading. The underlying
storage is parquet for these files
import util.control.Breaks._
val columns = table.schema().columns()
val itr = new VectorizedTableScanIterable(filteredScan, 2,
false).iterator()
while (itr.hasNext()) {
breakable {
val columnarBatch = itr.next();
val schemaRoot = columnarBatch.createVectorSchemaRootFromVectors
columns.forEach {
case (column) => {
println(column.name(), schemaRoot.getVector(column.name()))
}
}
}
break
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
