KSQLDB-Live-Aggregation

Query - SELECT sum(totalCost) AS cost ,count(itemType) as items, ROWTIME FROM orderTable group by itemType,totalCost,ROWTIME emit changes;

KSQLDB-Live-Join

For "SELECT itemTable.itemType, itemTable.unitPrice,orderTable.totalRevenue, orderTable.totalCost, orderTable.totalProfit, orderTable.ROWTIME FROM orderTable JOIN itemTable ON orderTable.itemType=itemTable.itemType emit changes;" Query

KSQLDB-Live

For "SELECT ip,ROWTIME FROM network EMIT CHANGES;" Query