tjbanghart commented on code in PR #4658:
URL: https://github.com/apache/calcite/pull/4658#discussion_r2599918942
##########
core/src/main/java/org/apache/calcite/runtime/SqlFunctions.java:
##########
@@ -6884,6 +6884,43 @@ public static Map map(Object... args) {
return map;
}
+ /** Combines multiple query result lists into rows for the Combine operator.
+ *
+ * <p>Each input list contains maps representing rows from a query.
+ * The output is a list of Object arrays, where each array is a row
+ * with one element per query. The number of output rows equals the
+ * maximum size across all input lists. Shorter lists are padded with nulls.
+ *
+ * @param queryLists array of lists, one per query
+ * @return list of Object arrays representing combined rows
+ */
+ public static List<Object[]> combineQueryResults(List[] queryLists) {
+ // Find the maximum row count across all queries
+ int maxRows = 0;
+ for (List list : queryLists) {
+ if (list.size() > maxRows) {
+ maxRows = list.size();
+ }
+ }
+
+ // Build the result rows
+ List<Object[]> result = new ArrayList<>(maxRows);
+ for (int rowIdx = 0; rowIdx < maxRows; rowIdx++) {
+ Object[] row = new Object[queryLists.length];
+ for (int queryIdx = 0; queryIdx < queryLists.length; queryIdx++) {
+ List queryList = queryLists[queryIdx];
Review Comment:
Awesome, thank you - that was it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
