andreas.czerniak
/
BrBETA_dnet-hadoop
forked from D-Net/dnet-hadoop
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'clean_subjects' of https://code-repo.d4science.org/D-Net/dnet-hadoop into clean_subjects

This commit is contained in:
Claudio Atzori 2022-08-05 16:56:37 +02:00
parent 4eaa063b1f 844f6eb465
commit 29c4cde42e
2 changed files with 82 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

162
dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/scripts/step16-createIndicatorsTables.sql
View File

@ -84,87 +84,87 @@ from project_results r
compute stats indi_funded_result_with_fundref; compute stats indi_funded_result_with_fundref;
create table indi_result_org_collab stored as parquet as -- create table indi_result_org_collab stored as parquet as
select o1.organization org1, o2.organization org2, count(distinct o1.id) as collaborations -- select o1.organization org1, o2.organization org2, count(distinct o1.id) as collaborations
from result_organization as o1 -- from result_organization as o1
join result_organization as o2 on o1.id=o2.id and o1.organization!=o2.organization -- join result_organization as o2 on o1.id=o2.id and o1.organization!=o2.organization
group by o1.organization, o2.organization; -- group by o1.organization, o2.organization;
--
compute stats indi_result_org_collab; -- compute stats indi_result_org_collab;
--
create table indi_result_org_country_collab stored as parquet as -- create table indi_result_org_country_collab stored as parquet as
with tmp as -- with tmp as
(select o.id as id, o.country , ro.id as result,r.type from organization o -- (select o.id as id, o.country , ro.id as result,r.type from organization o
join result_organization ro on o.id=ro.organization -- join result_organization ro on o.id=ro.organization
join result r on r.id=ro.id where o.country <> 'UNKNOWN') -- join result r on r.id=ro.id where o.country <> 'UNKNOWN')
select o1.id org1,o2.country country2, o1.type, count(distinct o1.result) as collaborations -- select o1.id org1,o2.country country2, o1.type, count(distinct o1.result) as collaborations
from tmp as o1 -- from tmp as o1
join tmp as o2 on o1.result=o2.result -- join tmp as o2 on o1.result=o2.result
where o1.id<>o2.id and o1.country<>o2.country -- where o1.id<>o2.id and o1.country<>o2.country
group by o1.id, o1.type,o2.country; -- group by o1.id, o1.type,o2.country;
--
compute stats indi_result_org_country_collab; -- compute stats indi_result_org_country_collab;
--
create table indi_result_org_collab stored as parquet as -- create table indi_result_org_collab stored as parquet as
with tmp as -- with tmp as
(select o.id, ro.id as result,r.type from organization o -- (select o.id, ro.id as result,r.type from organization o
join result_organization ro on o.id=ro.organization -- join result_organization ro on o.id=ro.organization
join result r on r.id=ro.id) -- join result r on r.id=ro.id)
select o1.id org1,o2.id org2, o1.type, count(distinct o1.result) as collaborations -- select o1.id org1,o2.id org2, o1.type, count(distinct o1.result) as collaborations
from tmp as o1 -- from tmp as o1
join tmp as o2 on o1.result=o2.result -- join tmp as o2 on o1.result=o2.result
where o1.id<>o2.id -- where o1.id<>o2.id
group by o1.id, o2.id, o1.type; -- group by o1.id, o2.id, o1.type;
--
compute stats indi_result_org_collab; -- compute stats indi_result_org_collab;
--
create table indi_project_collab_org stored as parquet as -- create table indi_project_collab_org stored as parquet as
select o1.id org1,o2.id org2, count(distinct o1.project) as collaborations -- select o1.id org1,o2.id org2, count(distinct o1.project) as collaborations
from organization_projects as o1 -- from organization_projects as o1
join organization_projects as o2 on o1.project=o2.project -- join organization_projects as o2 on o1.project=o2.project
where o1.id!=o2.id -- where o1.id!=o2.id
group by o1.id, o2.id; -- group by o1.id, o2.id;
--
compute stats indi_project_collab_org; -- compute stats indi_project_collab_org;
--
create table indi_project_collab_org_country stored as parquet as -- create table indi_project_collab_org_country stored as parquet as
with tmp as -- with tmp as
(select o.id organization, o.country , ro.project as project from organization o -- (select o.id organization, o.country , ro.project as project from organization o
join organization_projects ro on o.id=ro.id -- join organization_projects ro on o.id=ro.id
and o.country <> 'UNKNOWN') -- and o.country <> 'UNKNOWN')
select o1.organization org1,o2.country country2, count(distinct o1.project) as collaborations -- select o1.organization org1,o2.country country2, count(distinct o1.project) as collaborations
from tmp as o1 -- from tmp as o1
join tmp as o2 on o1.project=o2.project -- join tmp as o2 on o1.project=o2.project
where o1.organization<>o2.organization and o1.country<>o2.country -- where o1.organization<>o2.organization and o1.country<>o2.country
group by o1.organization, o2.country; -- group by o1.organization, o2.country;
--
compute stats indi_project_collab_org_country; -- compute stats indi_project_collab_org_country;
--
create table indi_funder_country_collab stored as parquet as -- create table indi_funder_country_collab stored as parquet as
with tmp as (select funder, project, country from organization_projects op -- with tmp as (select funder, project, country from organization_projects op
join organization o on o.id=op.id -- join organization o on o.id=op.id
join project p on p.id=op.project -- join project p on p.id=op.project
where country <> 'UNKNOWN') -- where country <> 'UNKNOWN')
select f1.funder, f1.country as country1, f2.country as country2, count(distinct f1.project) as collaborations -- select f1.funder, f1.country as country1, f2.country as country2, count(distinct f1.project) as collaborations
from tmp as f1 -- from tmp as f1
join tmp as f2 on f1.project=f2.project -- join tmp as f2 on f1.project=f2.project
where f1.country<>f2.country -- where f1.country<>f2.country
group by f1.funder, f2.country, f1.country; -- group by f1.funder, f2.country, f1.country;
--
compute stats indi_funder_country_collab; -- compute stats indi_funder_country_collab;
--
create table indi_result_country_collab stored as parquet as -- create table indi_result_country_collab stored as parquet as
with tmp as -- with tmp as
(select country, ro.id as result,r.type from organization o -- (select country, ro.id as result,r.type from organization o
join result_organization ro on o.id=ro.organization -- join result_organization ro on o.id=ro.organization
join result r on r.id=ro.id where country <> 'UNKNOWN') -- join result r on r.id=ro.id where country <> 'UNKNOWN')
select o1.country country1, o2.country country2, o1.type, count(distinct o1.result) as collaborations -- select o1.country country1, o2.country country2, o1.type, count(distinct o1.result) as collaborations
from tmp as o1 -- from tmp as o1
join tmp as o2 on o1.result=o2.result -- join tmp as o2 on o1.result=o2.result
where o1.country<>o2.country -- where o1.country<>o2.country
group by o1.country, o2.country, o1.type; -- group by o1.country, o2.country, o1.type;
--
compute stats indi_result_country_collab; -- compute stats indi_result_country_collab;
---- Sprint 4 ---- ---- Sprint 4 ----
create table indi_pub_diamond stored as parquet as create table indi_pub_diamond stored as parquet as

2
dhp-workflows/dhp-stats-update/src/main/resources/eu/dnetlib/dhp/oa/graph/stats/oozie_app/scripts/step20-createMonitorDB.sql
View File

@ -170,7 +170,7 @@ compute stats TARGET.indi_result_has_cc_licence;
create table TARGET.indi_result_has_cc_licence_url stored as parquet as select * from SOURCE.indi_result_has_cc_licence_url orig where exists (select 1 from TARGET.result r where r.id=orig.id); create table TARGET.indi_result_has_cc_licence_url stored as parquet as select * from SOURCE.indi_result_has_cc_licence_url orig where exists (select 1 from TARGET.result r where r.id=orig.id);
compute stats TARGET.indi_result_has_cc_licence_url; compute stats TARGET.indi_result_has_cc_licence_url;
create view TARGET.indi_funder_country_collab as select * from SOURCE.indi_funder_country_collab; -- create view TARGET.indi_funder_country_collab as select * from SOURCE.indi_funder_country_collab;
create table TARGET.indi_result_with_orcid stored as parquet as select * from SOURCE.indi_result_with_orcid orig where exists (select 1 from TARGET.result r where r.id=orig.id); create table TARGET.indi_result_with_orcid stored as parquet as select * from SOURCE.indi_result_with_orcid orig where exists (select 1 from TARGET.result r where r.id=orig.id);
compute stats TARGET.indi_result_with_orcid; compute stats TARGET.indi_result_with_orcid;