YYYYMMDD

STRING

dynamic_partition.enable

DATE

DATETIME

str2date

STRING

sql
CREATE TABLE my_table (
    date_str STRING NOT NULL, -- '20231027' 형태의 문자열
    id INT,
    data VARCHAR(100)
)
PARTITION BY str2date(date_str, '%Y%m%d') -- 문자열을 날짜로 변환하여 파티셔닝
DISTRIBUTED BY HASH(id)
PROPERTIES (
    "partition_live_number" = "30" -- (선택사항) 최근 30개의 파티션만 유지 (TTL 기능)
);

partition_live_number

sql
CREATE TABLE my_table (
    date_str STRING NOT NULL,
    -- 문자열을 DATE 타입으로 변환하는 생성 컬럼 추가
    event_day DATE AS str2date(date_str, '%Y%m%d'),
    id INT
)
DUPLICATE KEY(date_str, event_day)
PARTITION BY RANGE(event_day) () -- 생성 컬럼을 기반으로 파티셔닝
DISTRIBUTED BY HASH(id)
PROPERTIES (
    "dynamic_partition.enable" = "true",
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p"
);

STRING

PARTITION BY str2date(컬럼, '%Y%m%d')

DATE

date_trunc

time_slice

str2date

STRING

INT

DATETIME

DAY

sql
CREATE TABLE site_access (
    event_day DATETIME,
    site_id INT
)
PARTITION BY date_trunc("day", event_day) -- 일 단위로 자동 파티셔닝
DISTRIBUTED BY HASH(site_id);

STRING

sql
CREATE TABLE users (
    city STRING,
    user_id INT
)
PARTITION BY (city) -- 'Seoul', 'Tokyo' 등 데이터가 들어올 때마다 파티션 자동 생성
DISTRIBUTED BY HASH(user_id);

yyyymmdd

sql
CREATE TABLE sales_data (
    order_date STRING, -- '20231027'
    amount INT
)
PARTITION BY str2date(order_date, '%Y%m%d')
DISTRIBUTED BY HASH(amount);

prefix

start

end

PARTITION BY 함수

STRING

dt

STRING

str2date

PARTITION BY

sql
CREATE TABLE my_table (
    dt STRING NOT NULL, -- '20231027' 형태
    id INT,
    data VARCHAR(100)
)
-- 1. str2date를 통해 문자열을 날짜로 변환하여 파티셔닝
PARTITION BY str2date(dt, '%Y%m%d') 
DISTRIBUTED BY HASH(id)
PROPERTIES (
    -- 2. 이제 날짜 계산이 가능하므로 TTL 설정이 작동합니다.
    "partition_live_number" = "30" 
);

partition_retention_condition

sql
PROPERTIES (
    -- dt가 '20231027' 형태의 문자열일 때, 비교 연산을 통해 유지 조건 설정
    "partition_retention_condition" = "dt >= '20240101'"
)

STRING

PARTITION BY (dt)

STRING

STRING

YYYYMMDD

'20241027'

YYYYMMDD

dt

dt

sql
CREATE TABLE my_table (
    dt STRING NOT NULL, -- '20231027' 형태
    id INT,
    data VARCHAR(100)
)
PARTITION BY (dt) -- dt 값에 따라 자동 파티션 생성
DISTRIBUTED BY HASH(id)
PROPERTIES (
    -- v3.5 이상에서 지원되는 파티션 유지 조건
    "partition_retention_condition" = "dt >= CURRENT_DATE() - INTERVAL 3 MONTH"
);

'N/A'

'000000'

partition_live_number