使用内置的s3 读取方式如下:
INSERT INTO table (xx)
SELECT XX as xx
FROM S3(
"uri" = "s3://s3mongoproduct//.parquet",
"format" = "parquet",
"s3.endpoint" = "s3.eu-central-1.amazonaws.com",
"s3.region" = "eu-central-1",
"s3.access_key" = "",
"s3.secret_key" = ""
);
读取多个parquet 时,这个是schema是以什么为准,比如有的文件有1列,有的文件有2列,3列,是以最多的还是随机的。