如何在Amazon Athena中将NULL值列的非NULL数据左移至前一列？

针对你在Athena中需要将非NULL数据左移、填补前置NULL列的需求，这里提供基于Presto SQL（Athena底层引擎）的可行方案，以4列示例展示，10列场景直接扩展即可。

假设原表结构包含col1、col2、col3、col4（实际替换为你的10列），核心思路是将列转为数组、过滤NULL后重新拆分回列：

WITH filtered_vals AS (
    SELECT
        -- 将目标列打包为数组，过滤掉所有NULL值
        array_filter(ARRAY[col1, col2, col3, col4], val -> val IS NOT NULL) AS non_null_array,
        -- 定义总列数（4为示例，实际改为10）
        4 AS total_column_count
    FROM your_table_name
)
SELECT
    -- 按位置提取过滤后的数组元素，超出长度自动返回NULL
    element_at(non_null_array, 1) AS new_col1,
    element_at(non_null_array, 2) AS new_col2,
    element_at(non_null_array, 3) AS new_col3,
    element_at(non_null_array, 4) AS new_col4
    -- 10列场景继续追加：element_at(non_null_array, 5) AS new_col5, ..., element_at(non_null_array, 10) AS new_col10
FROM filtered_vals;

关键逻辑说明 #

1. 数组打包与过滤：用ARRAY[列名1, 列名2, ...]将所有需要处理的列转为数组，再通过array_filter移除其中的NULL值，得到仅含非NULL数据的有序数组。
2. 重新拆分列：使用element_at按索引提取数组元素，当索引超出数组长度时，Athena会自动返回NULL，刚好填补末尾的空位，实现非NULL数据左移的效果。

特殊场景处理 #

如果你的列存在多种数据类型（比如部分是字符串、部分是数字），需要先统一类型再打包数组，例如全部转为字符串：

array_filter(ARRAY[cast(col1 as varchar), cast(col2 as varchar), cast(col3 as varchar), cast(col4 as varchar)], val -> val IS NOT NULL)

内容的提问来源于stack exchange，提问作者jiaawe