FlinkSQL多个select group by统计union后输出？

具体SQL如下。 方案2：

INSERT INTO flink_sdk_stats ( SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd77' AS field_key, d77 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d77, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd79' AS field_key, d79 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d79, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd80' AS field_key, d80 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d80, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd81' AS field_key, d81 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d81, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd83' AS field_key, d83 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d83, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd84' AS field_key, d84 AS filed_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d84, TUMBLE(event_time, INTERVAL '5' MINUTE)

UNION ALL

SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, sid AS supply_id, 'd86' AS field_key, d86 AS field_value, count(1) AS pv FROM baidu_log_view GROUP BY sid, d86, TUMBLE(event_time, INTERVAL '5' MINUTE) );

方案3:

INSERT INTO flink_sdk_stats SELECT DATE_FORMAT(TUMBLE_END(event_time, INTERVAL '5' MINUTE), 'yyyyMMddHHmm') AS time, supply_id, field_key, field_value, count(1) AS pv FROM ( SELECT event_time, sid AS supply_id, 'd107' AS field_key, d107 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd77' AS field_key, d77 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd77' AS field_key, d77 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd79' AS field_key, d79 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd80' AS field_key, d80 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd81' AS field_key, d81 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd83' AS field_key, d83 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd84' AS field_key, d84 AS field_value FROM baidu_log_view UNION ALL SELECT event_time, sid AS supply_id, 'd86' AS field_key, d86 AS field_value FROM baidu_log_view ) GROUP BY supply_id, field_key, field_value, TUMBLE(event_time, INTERVAL '5' MINUTE);*来自志愿者整理的FLINK邮件归档