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 > > >
