[hive] 맵 조인 처리 기준 사이즈 확인

2020. 6. 11. 23:20·빅데이터/hive

맵 조인은 작은 크기의 테이블을 메모리에 적재하여 조인을 처리합니다. 이 때 테이블 데이터의 크기는 자바 객체의 사이즈입니다. 실제 파일의 사이즈와 다릅니다.

 

예를 들어 다음의 테이블 table_orc, table_txt는 동일한 데이터를 보관하고 있는 테이블입니다. 65,454개의 데이터를 저장 형식만 다르게 하여 저장한 것입니다.

 

맵 조인에는 객체 사이즈(rawDataSize)를 이용하기 때문에 hive.auto.convert.join.noconditionaltask.size를 설정할 때 객체 사이즈 기준으로 설정해야 합니다. 기본 설정이 10MB 일때 table_orc는 셔플 조인으로 처리되고, table_txt는 맵 조인으로 처리됩니다. table_orc를 맵조인으로 처리하기 위해서는 hive.auto.convert.join.noconditionaltask.size=20000000으로 설정해야 합니다.

 

ORC 형식은 데이터를 저장할 때 압축하여 저장하기 때문에 물리적인 파일의 크기가 원본에 비하여 줄어든 것을 확인할 수 있습니다. 객체 사이즈(rawDataSize)는 데이터의 타입과 자바 객체의 오버헤드 통계 정보등을 추가한 사이즈입니다. 따라서 파일 사이즈(totalSize)보다 증가할 수 있습니다.

       
테이블 형식 파일 사이즈(totalSize) 객체 사이즈(rawDataSize)
table_orc ORC 254,632(248 KB) 18,850,752(17.9 MB)
table_txt TXT 2,639,622(2.5 MB) 2,574,168 (2.4 MB)

table 정보 비교

table_txt

hive (hseok1_seo)> desc formatted table_txt;
OK
# col_name                data_type               comment             

column_1                  string                                      
column_2                  string                                      
column_3                  string                                      

# Detailed Table Information          
Table Parameters:          
    numFiles                1                   
    numRows                 65454               
    rawDataSize             2574168             
    totalSize               2639622             

# Storage Information          
SerDe Library:          org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe     
InputFormat:            org.apache.hadoop.mapred.TextInputFormat     
OutputFormat:           org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat     

table_orc

hive (hseok1_seo)> desc formatted table_orc;
OK
# col_name                data_type               comment             

column_1                  string                                      
column_2                  string                                      
column_3                  string                                     

# Detailed Table Information          
Table Parameters:          
    numFiles                1                   
    numRows                 65454               
    rawDataSize             18850752            
    totalSize               254632              

# Storage Information          
SerDe Library:          org.apache.hadoop.hive.ql.io.orc.OrcSerde     
InputFormat:            org.apache.hadoop.hive.ql.io.orc.OrcInputFormat     
OutputFormat:           org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat    
반응형
저작자표시 비영리 동일조건 (새창열림)

'빅데이터 > hive' 카테고리의 다른 글

[hive] MR, TEZ 실행엔진 라이브러리 업로드 위치 설정  (0) 2020.09.29
[hive] Gzip파일 처리 중 Unexpected end of input stream 오류 해결 방법  (0) 2020.07.17
[hive] 맵조인과 셔플조인(Map Join vs Shuffle Join)  (0) 2020.06.09
[hive] collect_list()와 같은 UDAF 함수의 GC 오류 해결 방법  (0) 2020.06.01
[hive] 하이브 매크로(macro)  (0) 2020.04.22
'빅데이터/hive' 카테고리의 다른 글
  • [hive] MR, TEZ 실행엔진 라이브러리 업로드 위치 설정
  • [hive] Gzip파일 처리 중 Unexpected end of input stream 오류 해결 방법
  • [hive] 맵조인과 셔플조인(Map Join vs Shuffle Join)
  • [hive] collect_list()와 같은 UDAF 함수의 GC 오류 해결 방법
hs_seo
hs_seo
Hello World!
    반응형
  • hs_seo
    개발자로 살아남기
    hs_seo
  • 전체
    오늘
    어제
    • 전체 (1140)
      • 개발자 (21)
        • 개발에 유의할 점 (0)
        • 면접 (5)
      • IT 소식 (5)
        • 업계 (1)
      • java (51)
        • 디자인패턴 (3)
        • apache-common (1)
      • 개념 (47)
        • 자료구조 (4)
        • 함수형사고 (8)
        • 디자인패턴 (1)
      • 데이터분석 (1)
      • python (67)
        • 코드조각 (12)
        • 라이브러리 (2)
      • 빅데이터 (418)
        • zookeeper (5)
        • hadoop (78)
        • hdfs (12)
        • hive (127)
        • hbase (16)
        • spark (40)
        • scala (4)
        • trino (3)
        • oozie (41)
        • Hue (9)
        • R (5)
        • sqoop (6)
        • flume (3)
        • elasticsearch (2)
        • airflow (16)
        • kafka (3)
        • kubernetes (10)
        • openstack (3)
        • flink (2)
        • redis (2)
      • 빅데이터 강좌 (2)
      • 알고리즘 (131)
        • 알고리즘 (1)
        • 백준 (61)
        • 정올 (41)
        • 더블릿 (5)
        • 프로그래머스 (1)
      • 프로그래밍 언어 (30)
        • go (4)
        • js (9)
        • .Net (6)
        • Jsp (1)
        • ansible (3)
        • terraform (6)
      • Tools (56)
        • docker (2)
        • macbook (6)
        • maven (3)
        • sublime (1)
      • 프레임워크 (25)
        • [JS] angularjs (2)
        • [JS] node.js (19)
        • [Java] spring (2)
        • Android (2)
      • 데이타베이스 (43)
        • SQLD (5)
        • Oracle (1)
        • MySQL (8)
        • ADsP (2)
      • 리눅스 (25)
        • Bash (61)
      • GCP (5)
      • AWS (34)
        • EC2 (2)
        • EMR (14)
      • 정보보안기사 (4)
        • 네트워크 (1)
      • 개인 (80)
        • 업무실수 (0)
        • 책 (9)
        • 교육 (3)
        • 여행 (17)
        • 영화 (12)
        • 음악 (2)
        • 피규어 (4)
        • 게임 (3)
        • 생각 (7)
        • 기타 (10)
        • 좋은글 (5)
        • 좋은 사이트 (2)
  • 블로그 메뉴

    • 홈
    • 태그
    • 미디어로그
    • 위치로그
    • 방명록
  • 링크

    • 빅데이터-하둡,하이브로 시작하기
    • 빅데이터-스칼라, 스파크로 시작하기
    • Kaggle에서 파이썬으로 데이터 분석 시작하기
    • 쉘스크립트 개발 시작하기
    • 개발자가 데이터 분석 준전문가 되기
    • 데브쿠마
  • 공지사항

  • 인기 글

  • 태그

    k8s
    error
    SPARK
    오류
    airflow
    emr
    백준
    하둡
    ubuntu
    HDFS
    AWS
    Python
    build
    yarn
    mysql
    oozie
    HIVE
    다이나믹
    하이브
    Tez
    nodejs
    파이썬
    bash
    Linux
    알고리즘
    S3
    hbase
    Hadoop
    java
    정올
  • 최근 댓글

  • 최근 글

  • hELLO· Designed By정상우.v4.10.6
hs_seo
[hive] 맵 조인 처리 기준 사이즈 확인
상단으로

티스토리툴바