-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy path01_tidy_82.jl
108 lines (95 loc) · 3.78 KB
/
01_tidy_82.jl
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
## ------------------------------------------------------------------------
##
## Script name: 01_tidy_82.jl
## Purpose: Clean Census 1982 data
## Author: Yanwen Wang
## Date Created: 2024-12-08
## Email: [email protected]
##
## ------------------------------------------------------------------------
##
## Notes: Census 1982 was downloaded from IPUMS International.
##
## ------------------------------------------------------------------------
# 1 Load data ---------------------------------------------------------------
census_1982 = DataFrame(Arrow.Table("Data_raw/census_1982.arrow"))
# 2 Clean data --------------------------------------------------------------
# 2.1 Select variables of interest ------------------------------------------
census_1982 = @chain census_1982 begin
@select(
:year, :geo1_cn, :geo2_cn, :serial,
:persons, :headloc, :pernum, :sploc,
:relate, :sex, :age, :marst, :ethniccn,
:educcn
)
@transform(
:province = lpad.(:geo1_cn .% 156000, 2, "0"),
:district = lpad.(:geo2_cn .% (:geo1_cn .* 1000), 2, "0"),
:hhnumber = lpad.(Int.(:serial), 10, "0"),
:hhsize = :persons
)
@transform(:region = get.(Ref(region_dict), :province, missing))
@transform(:hhid = string.(:year, "_", :province, :district, :hhnumber))
@transform(
:minority = ifelse.(:ethniccn .== 1, 0, 1),
:ethnicity = get.(Ref(ethn_dict), :ethniccn, missing),
:ethngrp = get.(Ref(ethngrp_dict1), :ethniccn, missing)
)
@transform(:female = ifelse.(:sex .== 1, 0, 1))
@transform(:age = ifelse.(:age .== 999, missing, :age))
@transform(:birthy = :year - :age)
@transform(:marst = get.(Ref(marst_dict), :marst, missing))
@transform(
:eduraw = eduraw_map[:educcn.+1],
:edu = edu_map[:educcn.+1]
)
@transform(:urban = 999) # missing urban status
@select(
:year, :hhid, :region, :province, :district, :hhnumber,
:pernum, :headloc, :sploc,
:relate, :female, :age, :birthy, :marst, :urban, :hhsize,
:eduraw, :edu,
:ethnicity, :ethngrp, :minority
)
end
# 2.2 Spousal information ----------------------------------------------------
# Information needed for spouse
df = @select(
census_1982,
:hhid, :pernum, :sploc,
:ethnicity, :ethngrp, :minority,
:eduraw, :edu,
:age, :female, :urban
)
# Identify spousal information using `pernum` to `sploc` linkage
sp_df = leftjoin(
df, df,
on=[:hhid => :hhid, :pernum => :sploc],
renamecols="" => "_sp")
@select!(
sp_df,
:hhid, :pernum, :ethnicity_sp, :ethngrp_sp, :minority_sp,
:eduraw_sp, :edu_sp, :age_sp, :urban_sp
)
# Merge spousal information back to main dataset
leftjoin!(census_1982, sp_df, on=[:hhid, :pernum])
# Identiy male and female information
@transform!(
census_1982,
:ethnicity_m = ifelse.(:female .== 0, :ethnicity, :ethnicity_sp),
:ethnicity_f = ifelse.(:female .== 0, :ethnicity_sp, :ethnicity),
:ethngrp_m = ifelse.(:female .== 0, :ethngrp, :ethngrp_sp),
:ethngrp_f = ifelse.(:female .== 0, :ethngrp_sp, :ethngrp),
:minority_m = ifelse.(:female .== 0, :minority, :minority_sp),
:minority_f = ifelse.(:female .== 0, :minority_sp, :minority),
:eduraw_m = ifelse.(:female .== 0, :eduraw, :eduraw_sp),
:eduraw_f = ifelse.(:female .== 0, :eduraw_sp, :eduraw),
:edu_m = ifelse.(:female .== 0, :edu, :edu_sp),
:edu_f = ifelse.(:female .== 0, :edu_sp, :edu),
:age_m = ifelse.(:female .== 0, :age, :age_sp),
:age_f = ifelse.(:female .== 0, :age_sp, :age),
:urban_m = ifelse.(:female .== 0, :urban, :urban_sp),
:urban_f = ifelse.(:female .== 0, :urban_sp, :urban)
)
# 3 Save data ---------------------------------------------------------------
Arrow.write("Data_clean/census_1982.arrow", census_1982)