Hi Christoffer, just note that screenshots cannot be displayed so you need to paste your code as text.
Best -- Zoi On 2025/11/21 18:19:06 Kaustubh Beedkar wrote: > perhaps some examples from here might help > https://github.com/kbeedkar/wayang-demo/tree/main/src/main/java/demo > > Best, > Kaustubh > > > On Fri, Nov 21, 2025 at 12:59 PM Christoffer Emil Kristensen <[email protected]> > wrote: > > > Hello thank you, > > > > Yes that helps. > > > > But I can see that you pass down alot of parameters in the Apply function: > > > > > > If I just want to create very simple planbuilder that loads from a sqlite > > source and perfroms some kind of filter operation is there an example for > > this? > > > > Similar to how I setup for example the Iceberg table source: > > > > > > > > In the JavaPlanBuilder I can find a similar function: > > > > > > But what instance of TableSource should I create? > > > > Does anyone have any documentation for how to get started using this 🙂 > > > > Thank you in advance! > > > > > > ------------------------------ > > *From:* Mads Sejer Pedersen <[email protected]> > > *Sent:* Thursday, November 20, 2025 2:50 PM > > *To:* [email protected] <[email protected]> > > *Subject:* Re: Apache Wayang Join Example > > > > [You don't often get email from [email protected]. Learn why this is > > important at https://aka.ms/LearnAboutSenderIdentification ] > > > > 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 > > > > > >
