trino新建带分区的外部表（trino命令）

2022-05-12 00:00:00 专区 订阅 命令 付费 生成

1、原数据上传 minio 前 timedelta ( interval )类型数据处理

def change_timedelta64_type(zeek_df):
    # 时间间隔类型数据转浮点数
    for column in zeek_df.columns:
        if zeek_df[column].d*=='timedelta64[ns]':
            lie = []
            for onedel in zeek_df[column]:
                onedel_new = onedel.total_seconds()
                lie.append(onedel_new)
            zeek_df[column] = lie

相关文章