Apache Spark RDD

Resilient Distributed Datasets

Resilient Distributed Datasets ( RDD ) là một cấu trúc tài liệu cơ bản của Spark. Nó là một tập hợp không bao giờ thay đổi phân tán của một đối tượng người dùng. Mỗi dataset trong RDD được chia ra thành nhiều phần vùng logical. Có thể được thống kê giám sát trên những node khác nhau của một cụm sever ( cluster ) .
RDDs hoàn toàn có thể chứa bất kể kiểu tài liệu nào của Python, Java, hoặc đối tượng người tiêu dùng Scala, gồm có những kiểu tài liệu do người dùng định nghĩa. Thông thường, RDD chỉ được cho phép đọc, phân mục tập hợp của những bản ghi. RDDs hoàn toàn có thể được tạo ra qua tinh chỉnh và điều khiển xác lập trên tài liệu trong bộ nhớ hoặc RDDs, RDD là một tập hợp có năng lực chịu lỗi mỗi thành phần hoàn toàn có thể được đo lường và thống kê song song .

Có hai cách để tạo RDDs:

• Tạo từ một tập hợp dữ liệu có sẵn trong ngôn ngữ sử dụng như Java, Python, Scala.
• Lấy từ dataset hệ thống lưu trữ bên ngoài như HDFS, Hbase hoặc các cơ sở dữ liệu quan hệ.

Thực thi trên MapRedure

MapReduce được áp dụng rộng rãi để xử lý và tạo các bộ dữ liệu lớn với thuật toán xử lý phân tán song song trên một cụm. Nó cho phép người dùng viết các tính toán song song, sử dụng một tập hợp các toán tử cấp cao, mà không phải lo lắng về xử lý/phân phối công việc và khả năng chịu lỗi.

Tuy nhiên, trong hầu hết các framework hiện tại, cách duy nhất để sử dụng lại dữ liệu giữa các tính toán (Ví dụ: giữa hai công việc MapReduce) là ghi nó vào storage (Ví dụ: HDFS). Mặc dù framework này cung cấp nhiều hàm thư viện để truy cập vào tài nguyên tính toán của cụm Cluster, điều đó vẫn là chưa đủ.

Cả hai ứng dụng Lặp (Iterative) và Tương tác (Interactive) đều yêu cầu chia sẻ truy cập và xử lý dữ liệu nhanh hơn trên các công việc song song. Chia sẻ dữ liệu chậm trong MapReduce do sao chép tuần tự và tốc độ I/O của ổ đĩa. Về hệ thống lưu trữ, hầu hết các ứng dụng Hadoop, cần dành hơn 90% thời gian để thực hiện các thao tác đọc-ghi HDFS.

– Iterative Operation trên MapReduce:

– Interactive Operations trên MapReduce:

Thực thi trên Spark RDD

Để khắc phục được yếu tố về MapRedure, những nhà nghiên cứu đã tăng trưởng một framework chuyên biệt gọi là Apache Spark. Ý tưởng chính của Spark là Resilient Distributed Datasets ( RDD ) ; nó tương hỗ đo lường và thống kê giải quyết và xử lý trong bộ nhớ. Điều này có nghĩa, nó tàng trữ trạng thái của bộ nhớ dưới dạng một đối tượng người tiêu dùng trên những việc làm và đối tượng người tiêu dùng hoàn toàn có thể san sẻ giữa những việc làm đó. Việc giải quyết và xử lý tài liệu trong bộ nhớ nhanh hơn 10 đến 100 lần so với network và disk .

– Iterative Operation trên Spark RDD:

– Interactive Operations trên Spark RDD:

Các loại RDD

• Các RDD biểu diễn một tập hợp cố định, đã được phân vùng các record để có thể xử lý song song.

  Xem thêm: Đầu số 0127 đổi thành gì? Chuyển đổi đầu số VinaPhone có ý nghĩa gì? – http://139.180.218.5

• Các record trong RDD hoàn toàn có thể là đối tượng người tiêu dùng Java, Scale hay Python tùy lập trình viên chọn. Không giống như DataFrame, mỗi record của DataFrame phải là một dòng có cấu trúc chứa những field đã được định nghĩa sẵn .

• RDD đã từng là API chính được sử dụng trong series Spark 1. x và vẫn hoàn toàn có thể sử dụng trong version 2. X nhưng không còn được dùng tiếp tục nữa .

• RDD API hoàn toàn có thể được sử dụng trong Python, Scala hay Java :

  • Scala và Java : Perfomance tương tự trên hầu hết mọi phần. ( giá thành lớn nhất là khi giải quyết và xử lý những raw object )

  • Python : Mất một lượng performance, đa phần là cho việc serialization giữa tiến trình Python và JVM

Các transformation và action với RDD

RDD phân phối những transformation và action hoạt động giải trí giống như DataFrame lẫn DataSets. Transformation giải quyết và xử lý những thao tác lazily và kích hoạt giải quyết và xử lý thao tác cần giải quyết và xử lý tức thời .

– Một số transformation:

Nhiều phiên bản transformation của RDD có thể hoạt động trên các Structured API, transformation xử lý lazily, tức là chỉ giúp dựng execution plans, dữ liệu chỉ được truy xuất thực sự khi thực hiện action

• distinct: loại bỏ trùng lắp trong RDD
• filter: tương đương với việc sử dụng where trong SQL – tìm các record trong RDD xem những phần tử nào thỏa điều kiện. Có thể cung cấp một hàm phức tạp sử dụng để filter các record cần thiết – Như trong Python, ta có thể sử dụng hàm lambda để truyền vào filter
• map: thực hiện một công việc nào đó trên toàn bộ RDD. Trong Python sử dụng lambda với từng phần tử để truyền vào map
• flatMap: cung cấp một hàm đơn giản hơn hàm map. Yêu cầu output của map phải là một structure có thể lặp và mở rộng được.
• sortBy: mô tả một hàm để trích xuất dữ liệu từ các object của RDD và thực hiện sort được từ đó.
• randomSplit: nhận một mảng trọng số và tạo một random seed, tách các RDD thành một mảng các RDD có số lượng chia theo trọng số.

– Một số action:

Action thực thi ngay các transformation đã được thiết lập để thu thập dữ liệu về driver để xử lý hoặc ghi dữ liệu xuống các công cụ lưu trữ.

• reduce: thực hiện hàm reduce trên RDD để thu về 1 giá trị duy nhất
• count: đếm số dòng trong RDD
• countApprox: phiên bản đếm xấp xỉ của count, nhưng phải cung cấp timeout vì có thể không nhận được kết quả.
• countByValue: đếm số giá trị của RDD
  chỉ sử dụng nếu map kết quả nhỏ vì tất cả dữ liệu sẽ được load lên memory của driver để tính toán
  chỉ nên sử dụng trong tình huống số dòng nhỏ và số lượng item khác nhau cũng nhỏ.
• countApproxDistinct: đếm xấp xỉ các giá trị khác nhau
• countByValueApprox: đếm xấp xỉ các giá trị
• first: lấy giá trị đầu tiên của dataset
• max và min: lần lượt lấy giá trị lớn nhất và nhỏ nhất của dataset
• take và các method tương tự: lấy một lượng giá trị từ trong RDD. take sẽ trước hết scan qua một partition và sử dụng kết quả để dự đoán số lượng partition cần phải lấy thêm để thỏa mãn số lượng lấy.
• top và takeOrdered: top sẽ hiệu quả hơn takeOrdered vì top lấy các giá trị đầu tiên được sắp xếp ngầm trong RDD.
• takeSamples: lấy một lượng giá trị ngẫu nhiên trong RDD

Một số kỹ thuật đối với RDD

– Lưu trữ file :

• Thực hiện ghi vào các file plain-text
• Có thể sử dụng các codec nén từ thư viện của Hadoop
• Lưu trữ vào các database bên ngoài yêu cầu ta phải lặp qua tất cả partition của RDD – Công việc được thực hiện ngầm trong các high-level API
• sequenceFile là một flat file chứa các cặp key-value, thường được sử dụng làm định dạng input/output của MapReduce. Spark có thể ghi các sequenceFile bằng các ghi lại các cặp key-value
• Đồng thời, Spark cũng hỗ trợ ghi nhiều định dạng file khác nhau, cho phép define các class, định dạng output, config và compression scheme của Hadoop.

– Caching : Tăng tốc giải quyết và xử lý bằng cache

• Caching với RDD, Dataset hay DataFrame có nguyên lý như nhau.
• Chúng ta có thể lựa chọn cache hay persist một RDD, và mặc định, chỉ xử lý dữ liệu trong bộ nhớ

– Checkpointing : Lưu trữ lại những bước giải quyết và xử lý để phục sinh

• Checkpointing lưu RDD vào đĩa cứng để các tiến trình khác để thể sử dụng lại RDD point này làm partition trung gian thay vì tính toán lại RDD từ các nguồn dữ liệu gốc
• Checkpointing cũng tương tự như cache, chỉ khác nhau là lưu trữ vào đĩa cứng và không dùng được trong API của DataFrame
• Cần sử dụng nhiều để tối ưu tính toán.