asheeshgarg opened a new issue, #6003:
URL: https://github.com/apache/iceberg/issues/6003
### Query engine
Java API
### Question
I am trying to create a API that need to return data using Apache Arrow. The
data is stored as Iceberg table I want to filter the data using the Java api to
avoid any heavy compute job. I am able to load and run scan
val namespace = Namespace.of("Test")
catalog.listTables(namespace)
val tableIdentifier = TableIdentifier.of("Test", "Temp")
val table = catalog.loadTable(tableIdentifier)
val scan = table.newScan();
val filteredScan = scan.filter(Expressions.and(Expressions.equal("date",
"20220810"),Expressions.equal("class", "test")))
val resultsItr= filteredScan.planTasks().iterator()
while(resultsItr.hasNext()){
val task = resultsItr.next();
val dataFile = task.files().iterator().next().file();
println(dataFile);
}
this gives me datafile
Now I want to read the parquet file using the
val itr = new VectorizedTableScanIterable(filteredScan).iterator()
it always giving me nullpointer exception any idea what is wrong?
--
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]
