initial commit of code with parquet data

.gitignore

@@ -0,0 +1,4 @@
+.Rproj.user
+.Rhistory
+.RData
+.Ruserdata

R/get_locs_obs.R

@@ -0,0 +1,42 @@
+library(DBI)
+library(dbplyr)
+library(dplyr)
+library(RPostgres)
+library(sf)
+library(arrow)
+library(geoarrow)
+
+tryCatch({
+ con <- dbConnect(
+ RPostgres::Postgres(),
+ dbname = 'pep',
+ host = Sys.getenv('PEP_PG_IP'),
+ user = keyringr::get_kc_account("pgpep_londonj"),
+ password = keyringr::decrypt_kc_pw("pgpep_londonj")
+ )
+}, error = function(cond) {
+ print("Unable to connect to Database.")
+})
+
+tbl_deploy <- dplyr::tbl(con,in_schema("telem","tbl_tag_deployments")) |> 
+ dplyr::collect()
+
+locs_obs <- sf::st_read(con,Id("telem","geo_wc_locs_qa")) |> 
+ dplyr::left_join(tbl_deploy) |> 
+ dplyr::filter(meta_project %in% c('Ice Seals'),
+ species %in% c('Hf','Pl')) |> 
+ dplyr::select(speno,deployid,ptt,instr,tag_family,type,quality,locs_dt,latitude,longitude,
+ error_radius, error_semi_major_axis,error_semi_minor_axis,
+ error_ellipse_orientation, project, species, qa_status,deploy_dt, end_dt,
+ deploy_lat,deploy_long,capture_lat,capture_long, geom)
+
+unlink(here::here('locs_obs'), 
+ recursive = TRUE, 
+ force = TRUE)
+
+write_dataset(locs_obs,
+ path='locs_obs',
+ format="parquet",
+ partitioning = 'speno')
+
+dbDisconnect(con, disconnect = TRUE)

cefi-ice-seal-movement.Rproj

@@ -0,0 +1,15 @@
+Version: 1.0
+
+RestoreWorkspace: Default
+SaveWorkspace: Default
+AlwaysSaveHistory: Default
+
+EnableCodeIndexing: Yes
+UseSpacesForTab: Yes
+NumSpacesForTab: 2
+Encoding: UTF-8
+
+RnwWeave: Sweave
+LaTeX: pdfLaTeX
+
+AutoAppendNewline: Yes