inflearn logo
강의

Course

Instructor

Learn Python Apache Spark from Silicon Valley Engineers

Reading CSV files into a DataFrame

parquet read시 partition 개수

416

satelites90719

27 asked

0

안녕하세요

parquet을 read할때, 파티션 개수는 저장할때의 partition으로 고정될까요??

parquet을 read 할때 partiton 1개당 size가 너무 커서, partiton 개수를 늘려서 read 하고 싶습니다. 혹시 방법이 있을까용?

 

감사합니다.

머신러닝 머신러닝 배워볼래요? 빅데이터 bigdata apache-spark

Answer 1

1

altoformula

네 제가 알기론 아쉽게도 없습니다. 저장을 그렇게 크게한 파이프라인을 바꾸셔야 돨 듯합니다. 일단 파일 수 자체가 작기 때문에 읽을때도 뭐 그대로 처음부터 그파티션들만 읽어야줘. 방법이 없습니다.

0

satelites90719

명쾌한 답변 감사합니다 ㅎㅎ

databricks에 cluster 메뉴가 없습니다.

0

43

2

주피터 사용 및 도커 설치

0

90

2

S3 폴더 구조에 따른 Static Partition Pruning, DPP 질문

0

76

2

broadcast Join과 boradcast + UDF 차이

0

62

2

append 모드 사용 시 집계

0

63

2

CDC 기반 스파크 아키텍처 구현 방법이 궁금합니다.

0

107

2

BroadCast 지원 가능 메모리 문의

0

88

2

rdd, dataframe, spark sql 각각 언제 사용할까요?

0

185

2

강의 후반부에 나온 실습 코드는 어디서 받을 수 있나요?

0

195

3

cdc 기반의 스트리밍 데이터 처리

1

230

2

broadcast 코드 예시 관련 질문

0

126

2

재생에 문제가 생겼어요 라는 메세지가 자꾸 뜨네요

0

113

1

스트리밍 예제 실행 시 py4j.protocol.Py4JNetworkError 발생

0

213

2

Repartition과 Coalesce에 대해 궁금한 점이 있어요!

1

165

1

pyspark 현업에서 로컬 개발 및 운영

1

335

1

Spark Structured Streaming Gracefully shutdown 질문

1

443

2

PySpark Runtime Architecture 내용 중 질문이 있습니다!

1

212

1

docker 설치 이후에 터미널 여는 부분에서 막혔습니다

1

458

2

app-<timestamp>-<executor_id> 폴더가 spark-events 내부에 생기게 하고 싶습니다.

1

275

1

pyspark.SparkContext 실행 오류 관련 질문

2

378

1

스파크 아키텍쳐 관련 문의 드립니다.

1

351

2

3.0에서 추가된 shuffle_hash, shuffle_replicate_nl hint는 어떤 상황에서 쓰는게 좋을까요?

1

316

1

데이터 엔지니터의 현 트렌드가 궁금합니다

1

469

1

스칼라강의도 제작하신다고 하셨는데 계획하고 계실까요??

1

290

2