api.getPriceGridSummaryQuery()

def pgId = "929.PG"

def q = api.getPriceGridSummaryQuery()
q.addObjectTypedId(pgId)
q.setDoCount(true)
q.setItemGroupBy("attribute1")
q.setProductGroupBy("attribute3")
q.addProjection("Cost", "SUM")

def rows = api.runSummaryQuery(q)

def pgId = 929

def qapi = api.queryApi()
def exprs = qapi.exprs()

def t1 = qapi.tables().priceGridLineItems(pgId)
def t2 = qapi.tables().products()

def rows = qapi.source(t1, [t1.sku, t1.SalesOrg, t1.Cost])
        .leftOuterJoin(t2, { cols -> [t2.ProductGroup] }, { cols -> t2.sku().equal(cols.sku) })
        .aggregateBy({ cols -> [cols.SalesOrg, cols.ProductGroup] }, { cols ->
            [
                    cols.SalesOrg,
                    cols.ProductGroup,
                    exprs.sum(cols.RevenueImpact).as("RevenueImpact"),
                    exprs.count().as("Count")
            ]
        })
        .stream { it.collect { it } }