CREATE TABLE dim_operator (
  operator_id       STRING COMMENT '작업자 고유 ID',
  name              STRING COMMENT '이름',
  organization_unit STRING COMMENT '소속 부서 (예: 품질관리팀)',
  team              STRING COMMENT '소속 팀 (예: 생산3조)',
  shift_group       STRING COMMENT '근무조 (A, B, C)',
  shift_id          STRING COMMENT '교대조 ID (dim_shift 참조)',
  role              STRING COMMENT '직무 (예: 오퍼레이터, 수리기사)',
  certification     STRING COMMENT '자격 등급 코드 (예: C01, C02)',
  experience_year   INT COMMENT '경력 연수',
  join_date         DATE COMMENT '입사일',
  retire_date       DATE COMMENT '퇴사일 또는 예정일',

  location_id       STRING COMMENT '주요 근무 위치 (dim_location 참조)',

  -- PII는 별도 저장
  contact_ref_id    STRING COMMENT 'PII 분리된 contact 테이블 FK',

  -- SCD 필드
  effective_from    TIMESTAMP,
  effective_to      TIMESTAMP,
  is_current        BOOLEAN,
  updated_at        TIMESTAMP,

  PRIMARY KEY (operator_id, effective_from)
)
PARTITIONED BY (bucket(4, operator_id));

CREATE TABLE pii_operator_contact (
  contact_ref_id STRING PRIMARY KEY,
  email          STRING,
  phone_number   STRING,
  updated_at     TIMESTAMP
)