athena-ctas.sql

CREATE table data_extract.stitch_parquet WITH (
  partitioned_by = ARRAY['dt'],
  bucketed_by = ARRAY['request_id'],
  bucket_count = 25,
  format = 'parquet',
  parquet_compression = 'SNAPPY',
  external_location = 's3://acast-data-extract-cloudfront/stitch_parquet/') AS
SELECT request_id, bytes, edge_location, dt from data_raw.cf_stitch


=====


CREATE table data_extract.stitch_parquet WITH (
  partitioned_by = ARRAY['dt'],
  bucketed_by = ARRAY['request_id'],
  bucket_count = 25,
  format = 'parquet',
  parquet_compression = 'SNAPPY',
  external_location = 's3://acast-data-extract-cloudfront/stitch_parquet/') AS
SELECT request_id, bytes, edge_location, dt from test.stitch_bk