Set information about current provider
$params.("dataprovider:id")$
$params.("dataprovider:name")$
$params.("dataprovider:interface")$
Decide REFRESH/INCREMENTAL transformation
Fetch records from MDStore
$params.("orig_id")$
$params.("orig_format")$
orig_epr
Fetch records from MDStore
$params.("dataprovider:id")$
Transform original records in DB rows
orig_epr
packed_row_epr
Clean DB rows values according to defined vocabularies
packed_row_epr
cleaned_row_epr
Store mdtore records
$params.("row_id")$
REFRESH
cleaned_row_epr
Update datasouce API extra fields
$params.("row_id")$
$params.("dataprovider:id")$
$params.("dataprovider:interface")$
last_aggregation_total
last_aggregation_date
last_aggregation_mdId