Does something like: https://github.com/apache/incubator-wayang/blob/1e0f9e8166225176fe3022de5fbcce3dbcba96b9/wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Hybrid.scala
fit your needs? On 2025/11/20 13:39:25 Christoffer Emil Kristensen wrote: > Hello everyone, > > I am working on a planbuilder query in Apache Wayang that loads from two > sources, one sqlite database and one Apache Iceberg table (I am in the > progress of implementing an Iceberg Source for the Java Platform). > > Does anyone got an example of a planbuilder query that 1. Loads from a sql > table and 2. Performs a Join operation on an Source Operator that outputs an > Wayang Record? > > Best regards, > > Christoffer >
