Citirea fragmentelor ca matrice
În acest exercițiu, vei scrie o funcție table() scalabilă care numără împrumutații din mediul urban și rural din setul de date despre ipoteci, folosind chunk.apply(). În mod implicit, chunk.apply() agregă datele procesate cu funcția rbind(). Astfel, poți crea un tabel din fiecare fragment, apoi să aduni rândurile matricei rezultate pentru a obține totalurile.
Am creat o conexiune la fișier fc pentru fișierul "mortgage-sample.csv" și am citit primul rând pentru a elimina antetul.
Acest exercițiu face parte din cursul
Procesarea scalabilă a datelor în R
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# Define the function to apply to each chunk
make_table <- function(chunk) {
# Read each chunk as a matrix
x <- ___(chunk, type = "integer", sep = ",")
# Create a table of the number of borrowers (column 3) for each chunk
table(x[, 3])
}