Cross Join

def qapi = api.queryApi()

def t1 = qapi.tables().customers()
def t2 = qapi.tables().customerExtensionRows("CX30")


return qapi.source(t1, [t1.customerId().as("CustomerID"), t1.name.as("Customer Name"), t1."Customer Class", t1.Country], t1.customerId().equal("CD-0001"))

        .crossJoin(t2, { it -> [t2.CustomerClassExtra.as("Customer Class Extra")] })
        .take(5)
        .stream { it.collect { it } }