Hello thank you, Yes that helps.
But I can see that you pass down alot of parameters in the Apply function: [cid:ee590753-1e3a-41dd-b0b8-9e5c8585e970] 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: [cid:c692c0ac-3c43-475f-bb49-e1f6d7e40e84] [cid:4c25919b-e7ac-4e84-aba5-488c60cf5c08] In the JavaPlanBuilder I can find a similar function: [cid:5f3d335f-d210-4b0d-b2b3-659ac3cccb8f] 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 >
