1
RDD를 업데이트 할 수 있습니까? --- 즉 "a.txt"파일에서 RDD를 생성했다고 가정합니다. "a.txt"가 업데이트되었습니다. a.txt 전체 파일을 읽지 않고 RDD를 업데이트 할 수 있습니까?스파크 RDD (Resilient Distributed Dataset)를 업데이트 할 수 있습니까?
A
답변
1
RDD는 정의에 따라 불변하므로 "a.txt"파일이 변경되면 RDD를 변경할 수 있어야합니다.
관련 문제
- 1. 스파크 RDD 데이터 선택
- 2. HBase에서 레코드를 읽는 방법을 Spark RDD (Resilient Distributed Datasets)에 저장합니다. 하나의 RDD 기록을 읽고 HBase에 기록합니까?
- 3. 스파크 및 스칼라에서 json으로 RDD
- 4. 스파크 스트리밍 콘솔에서 RDD 출력
- 5. 스파크 RDD 파티션과 Hadoop 스플릿
- 6. 나쁜 JSON에서 스파크 RDD 병합
- 7. 누군가가 집행자의 rdd 블록에 대해 설명 할 수 있습니까
- 8. 스파크 필터와 카운트 큰 RDD 여러 번
- 9. 스파크 RDD any() 및 all() 메소드?
- 10. 여러 값을 반환하는 스파크 RDD 줄이기
- 11. 스파크 RDD 유니온에 대해 매우 느림
- 12. 스파크 목록은 모든 RDD 이름을 캐시
- 13. 3 개의 RDD 오브젝트를 결합한 스파크
- 14. 스파크 RDD : 여러 reducebykey 또는 한 번만
- 15. 스파크 오류 RDD를 만들 때 RDD 유형을 찾을 수 없습니다.
- 16. apache ignite rdd를 scala의 rdd spark로 변환 할 수 있습니까?
- 17. 스파크 라벨을 어떻게 스키닝 할 수 있습니까?
- 18. Distributed Computing Engine없이 MATLAB의 MPI 기능에 액세스 할 수 있습니까?
- 19. 는 RDD
- 20. 아파치 스파크 : 어떻게 RDD [v]를 Map [k, RDD [v]]로 분할합니까?
- 21. 스파크 작업으로 제출할 때 Spark RDD 맵에서 NullPointerException이 발생했습니다.
- 22. 스파크 : 여러 프로그램에서 사용하기 위해 RDD/DF 캐싱
- 23. RDD
- 24. 스파크 파이썬 특수 기호를 사용하여 RDD 항목을 그룹화하는 방법은 무엇입니까?
- 25. 스파크 : Scala의 RDD [행]에서 집계를 만드는 방법
- 26. 스파크 : RDD [(Long, Iterable [String])]을 RDD [(Long, String)]로 변환하는 방법?
- 27. 맵 변환 성능 스파크 데이터 프레임 대 RDD
- 28. 스칼라로 스파크 : 다른 목록에 포함 된 값으로 RDD 필터링하기
- 29. 다른 RDD의 값을 기반으로 RDD 업데이트
- 30. 스파크 스칼라에서 RDD의 감소