forked from anujdahiya24/FIDE
-
Notifications
You must be signed in to change notification settings - Fork 0
/
compilationcsv.R
41 lines (30 loc) · 1.28 KB
/
compilationcsv.R
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
library(tidyverse)
library(arrow)
pathcsv <- "Step 4 - Cleaning/Cleaned csvs/"
pathcsv <- list.files(path = pathcsv, pattern = "*.csv")
tableauranking <- read.csv(file = "Step 4 - Cleaning/Cleaned csvs/APR01.csv", sep = "*") %>%
as_tibble()
tableauranking <- tableauranking %>%
mutate(estpasvide = "1") %>%
filter(estpasvide == 0) %>%
select(-estpasvide) %>%
select(ID_Number, Name, Title, Country, Rating, Games, Activity, Date) %>%
mutate(ID_Number = as.character(ID_Number)) %>%
mutate(Games = as.character(Games))
for (i in 1:length(pathcsv)) {
tableauimport <- read.csv(file = paste0("Step 4 - Cleaning/Cleaned csvs/", pathcsv[i]), sep = "*") %>%
as_tibble() %>%
select(ID_Number, Name, Title, Country, Rating, Games, Activity, Date) %>%
mutate(ID_Number = as.character(ID_Number)) %>%
mutate(Games = as.character(Games)) %>%
mutate(dateranking = str_remove_all(string = pathcsv[i], pattern = ".csv"))
print(pathcsv[i])
tableauranking <- tableauranking %>%
bind_rows(tableauimport)
}
results <- tableauranking %>%
group_by(dateranking) %>%
arrange(desc(Rating), .by_group = TRUE) %>%
mutate(ranking = rank(x = desc(Rating), ties.method = "min")) %>%
ungroup()
write_parquet(x = results, sink = "FIDE_standard_compilations_Dahiya.parquet")