· 5 years ago · Nov 06, 2020, 06:26 PM
1CREATE TABLE <ACTION_TYPE>_INPUT_<ENV> IF NOT EXISTS (
2 action_id STRING, -- Unique identifier for every record to be actioned
3 .....
4) PARTITIONED BY (
5 ds STRING
6)
7STORED AS PARQUET
8LOCATION 's3://........';
9
10CREATE TABLE <ACTION_TYPE>_RESULTS_<ENV> IF NOT EXISTS (
11 action_id STRING, -- Unique identifier for every record to be actioned
12 .....
13) PARTITIONED BY (
14 ds STRING,
15 status STRING
16)
17STORED AS PARQUET
18LOCATION 's3://........';
19