You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm trying to use the engine from Scala.
Pretty simple setup. Using example parquet file from testdata folder.
Code looks like this:
val ctx = new ExecutionContext(Map.empty[String,String].asJava)
val pqtSource = new ParquetDataSource("data/alltypes_plain.parquet")
println(pqtSource.schema().toString)
ctx.registerDataSource("pdata",pqtSource)
val df2 = ctx.sql("select id,bool_col from pdata")
val c2 = ctx.execute(df2).iterator().asScala.toList.map(r => println(r))
First prinln statement works as expected, gives the structure:
I'm trying to use the engine from Scala.
Pretty simple setup. Using example parquet file from testdata folder.
Code looks like this:
First prinln statement works as expected, gives the structure:
Second, only nulls:
What am I doing wrong ? Or is might be a Scala incompatibility ?
The text was updated successfully, but these errors were encountered: