R Select(), Filter(), Arrange(), Pipeline példával
A dplyr nevű könyvtár értékes igéket tartalmaz az adatkészleten belüli navigációhoz. Ebben az oktatóanyagban az utazási idők adatkészletét fogja használni. Az adatkészlet információkat gyűjt a sofőr által az otthona és a munkahelye közötti utazásról. Az adatkészletben tizennégy változó található, köztük:
- DayOfWeek: Határozza meg a hét azon napját, amikor a vezető használja az autóját
- Távolság: Az utazás teljes távolsága
- MaxSpeed: Az utazás maximális sebessége
- TotalTime: Az utazás hossza percekben
Az adatkészletben körülbelül 200 megfigyelés található, és az utazások között történt Monday péntekig.
Először is a következőket kell tennie:
- töltse be az adatkészletet
- ellenőrizze az adatok szerkezetét.
A dplyr egyik praktikus funkciója a glimpse() függvény. Ez előrelépés az str()-hez képest. A glimpse() segítségével láthatjuk az adatkészlet szerkezetét, és eldönthetjük, hogy milyen manipulációra van szükség.
library(dplyr) PATH <- "https://raw.githubusercontent.com/guru99-edu/R-Programming/master/travel_times.csv" df <- read.csv(PATH) glimpse(df)
output:
## Observations: 205 ## Variables: 14 ## $ X <int> 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, ... ## $ Date <fctr> 1/6/2012, 1/6/2012, 1/4/2012, 1/4/2012, 1/3/20... ## $ StartTime <fctr> 16:37, 08:20, 16:17, 07:53, 18:57, 07:57, 17:3... ## $ DayOfWeek <fctr> Friday, Friday, Wednesday, Wednesday, Tuesday,... ## $ GoingTo <fctr> Home, GSK, Home, GSK, Home, GSK, Home, GSK, GS... ## $ Distance <dbl> 51.29, 51.63, 51.27, 49.17, 51.15, 51.80, 51.37... ## $ MaxSpeed <dbl> 127.4, 130.3, 127.4, 132.3, 136.2, 135.8, 123.2... ## $ AvgSpeed <dbl> 78.3, 81.8, 82.0, 74.2, 83.4, 84.5, 82.9, 77.5,... ## $ AvgMovingSpeed <dbl> 84.8, 88.9, 85.8, 82.9, 88.1, 88.8, 87.3, 85.9,... ## $ FuelEconomy <fctr> , , , , , , -, -, 8.89, 8.89, 8.89, 8.89, 8.89... ## $ TotalTime <dbl> 39.3, 37.9, 37.5, 39.8, 36.8, 36.8, 37.2, 37.9,... ## $ MovingTime <dbl> 36.3, 34.9, 35.9, 35.6, 34.8, 35.0, 35.3, 34.3,... ## $ Take407All <fctr> No, No, No, No, No, No, No, No, No, No, No, No... ## $ Comments <fctr> , , , , , , , , , , , , , , , Put snow tires o...
Nyilvánvaló, hogy a Megjegyzések változó további diagnosztikát igényel. A Megjegyzések változó első megfigyelései csak hiányzó értékeket tartalmaznak.
sum(df$Comments =="")
Kód Magyarázat
- sum(df$Comments ==””): Adja össze a megfigyeléseket, amelyek megegyeznek a „” értékkel a df megjegyzések oszlopában
output:
## [1] 181
select()
Kezdjük a select() igével. Nem feltétlenül van szükségünk az összes változóra, és a bevált gyakorlat az, hogy csak azokat a változókat jelöljük ki, amelyeket relevánsnak találunk.
181 hiányzó megfigyelésünk van, az adatkészlet majdnem 90 százaléka. Ha úgy dönt, hogy kizárja őket, nem tudja folytatni az elemzést.
A másik lehetőség a Comment változó eldobása a select() igével.
A select() segítségével többféleképpen is kiválaszthatunk változókat. Vegye figyelembe, hogy az első argumentum az adatkészlet.
- `select(df, A, B ,C)`: Select the variables A, B and C from df dataset. - `select(df, A:C)`: Select all variables from A to C from df dataset. - `select(df, -C)`: Exclude C from the dataset from df dataset.
A harmadik módot használhatja a Megjegyzések változó kizárására.
step_1_df <- select(df, -Comments) dim(df)
output:
## [1] 205 14
dim(step_1_df)
output:
## [1] 205 13
Az eredeti adatkészlet 14, míg a step_1_df 13 szolgáltatást tartalmaz.
Szűrő()
A filter() ige segít abban, hogy a megfigyelések egy kritériumot követjenek. A filter() pontosan úgy működik, mint a select(), először az adatkeretet adja át, majd egy feltételt vesszővel elválasztva:
filter(df, condition) arguments: - df: dataset used to filter the data - condition: Condition used to filter the data
Egy kritérium
Először is megszámolhatja a megfigyelések számát egy faktorváltozó egyes szintjén belül.
table(step_1_df$GoingTo)
Kód Magyarázat
- table(): Számolja meg a megfigyelések számát szintek szerint. Megjegyzés: csak a faktorszintű változók fogadhatók el
- table(step_1_df$GoingTo): Számolja meg a végső cél felé vezető utak számát.
output:
## ## GSK Home ## 105 100
A table() függvény azt jelzi, hogy 105 út megy a GSK-ba és 100 a Home-ba.
Az adatokat szűrhetjük úgy, hogy egy 105 megfigyelést tartalmazó adatkészletet adjunk vissza, és egy másikat 100 megfigyeléssel.
# Select observations if GoingTo == Home select_home <- filter(df, GoingTo == "Home") dim(select_home)
output:
## [1] 100 14
# Select observations if GoingTo == Work select_work <- filter(df, GoingTo == "GSK") dim(select_work)
output:
## [1] 105 14
Több kritérium
Egy adatkészletet több feltétellel is szűrhetünk. Például kivonhatja azokat a megfigyeléseket, ahol a cél az Otthon, és szerdán történt.
select_home_wed <- filter(df, GoingTo == "Home" & DayOfWeek == "Wednesday") dim(select_home_wed)
output:
## [1] 23 14
23 megfigyelés felelt meg ennek a kritériumnak.
Csővezeték
Egy adatkészlet létrehozása sok műveletet igényel, például:
- importáló
- egyesülő
- kiválasztása
- szűrő
- és így tovább
A dplyr könyvtár egy praktikus operátorral, %>%, az úgynevezett csővezeték. A csővezeték funkció tisztává, gyorssá és kevésbé hibás kezelést tesz lehetővé.
Ez az operátor olyan kód, amely lépéseket hajt végre anélkül, hogy közbenső lépéseket mentene a merevlemezre. Ha visszatér a fenti példánkhoz, kiválaszthatja az érdeklődésre számot tartó változókat és szűrheti őket. Három lépésünk van:
- 1. lépés: Adatok importálása: Importálja a GPS-adatokat
- 2. lépés: Adatok kiválasztása: Válassza a GoingTo és DayOfWeek lehetőséget
- 3. lépés: Adatok szűrése: Csak hazatérés és szerda
Használhatjuk a legnehezebb módszert is:
# Step 1 step_1 <- read.csv(PATH) # Step 2 step_2 <- select(step_1, GoingTo, DayOfWeek) # Step 3 step_3 <- filter(step_2, GoingTo == "Home", DayOfWeek == "Wednesday") head(step_3)
output:
## GoingTo DayOfWeek ## 1 Home Wednesday ## 2 Home Wednesday ## 3 Home Wednesday ## 4 Home Wednesday ## 5 Home Wednesday ## 6 Home Wednesday
Ez nem kényelmes módja sok művelet végrehajtásának, különösen sok lépésből álló helyzetben. A környezet végül sok tárolt tárgyat tartalmaz.
Használjuk helyette a %>% pipeline operátort. Csak az elején kell meghatároznunk a használt adatkeretet, és az összes folyamat abból fog folyni.
A folyamat alapvető szintaxisa
New_df <- df %>% step 1 %>% step 2 %>% ... arguments - New_df: Name of the new data frame - df: Data frame used to compute the step - step: Instruction for each step - Note: The last instruction does not need the pipe operator `%`, you don't have instructions to pipe anymore Note: Create a new variable is optional. If not included, the output will be displayed in the console.
Az első csövet a fent felsorolt lépések szerint készítheti el.
# Create the data frame filter_home_wed.It will be the object return at the end of the pipeline filter_home_wed <- #Step 1 read.csv(PATH) % > % #Step 2 select(GoingTo, DayOfWeek) % > % #Step 3 filter(GoingTo == "Home",DayOfWeek == "Wednesday") identical(step_3, filter_home_wed)
output:
## [1] TRUE
Készen állunk egy lenyűgöző adatkészlet létrehozására a csővezeték üzemeltetőjével.
rendezni()
A előző bemutató, megtanulhatja, hogyan kell rendezni az értékeket a sort() függvénnyel. A dplyr könyvtárnak van rendezési funkciója. Úgy működik, mint egy bűbáj a csővezetékkel. Az arrange() ige egy vagy több sort is átrendezhet, növekvő (alapértelmezett) vagy csökkenő sorrendben.
- `arrange(A)`: Ascending sort of variable A - `arrange(A, B)`: Ascending sort of variable A and B - `arrange(desc(A), B)`: Descending sort of variable A and ascending sort of B
A távolságot úti cél szerint rendezhetjük.
# Sort by destination and distance step_2_df <-step_1_df %>% arrange(GoingTo, Distance) head<step_2_df)
output:
## X Date StartTime DayOfWeek GoingTo Distance MaxSpeed AvgSpeed ## 1 193 7/25/2011 08:06 Monday GSK 48.32 121.2 63.4 ## 2 196 7/21/2011 07:59 Thursday GSK 48.35 129.3 81.5 ## 3 198 7/20/2011 08:24 Wednesday GSK 48.50 125.8 75.7 ## 4 189 7/27/2011 08:15 Wednesday GSK 48.82 124.5 70.4 ## 5 95 10/11/2011 08:25 Tuesday GSK 48.94 130.8 85.7 ## 6 171 8/10/2011 08:13 Wednesday GSK 48.98 124.8 72.8 ## AvgMovingSpeed FuelEconomy TotalTime MovingTime Take407All ## 1 78.4 8.45 45.7 37.0 No ## 2 89.0 8.28 35.6 32.6 Yes ## 3 87.3 7.89 38.5 33.3 Yes ## 4 77.8 8.45 41.6 37.6 No ## 5 93.2 7.81 34.3 31.5 Yes ## 6 78.8 8.54 40.4 37.3 No
Összegzésként
Az alábbi táblázatban összefoglalja az oktatóprogram során megtanult összes műveletet.
Ige | Objektív | Kód | Magyarázat |
---|---|---|---|
megpillant | ellenőrizze a df szerkezetét |
glimpse(df) |
Azonos az str() |
select() | Változók kiválasztása/kizárása |
select(df, A, B ,C) |
Válassza ki az A, B és C változókat |
select(df, A:C) |
Válassza ki az összes változót A-tól C-ig | ||
select(df, -C) |
C. kizárása | ||
szűrő() | Szűrje a df-t egy vagy több feltétel alapján |
filter(df, condition1) |
Egy feltétel |
filter(df, condition1 |
feltétel2) | ||
rendezni() | Rendezze az adatkészletet egy vagy több változóval |
arrange(A) |
Növekvő típusú A változó |
arrange(A, B) |
Növekvő típusú A és B változó | ||
arrange(desc(A), B) |
Az A változó csökkenő és a B növekvő fajta | ||
%>% | Hozzon létre egy folyamatot az egyes lépések között |
step 1 %>% step 2 %>% step 3 |