Merge pull request #987 from gbif/la-no-processed-recordedby

ala - ignore processed recordedby
gbif · Dec 7, 2023 · 8802a43 · 8802a43
2 parents 6dc1981 + 6e927e1
commit 8802a43
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 14 deletions.
diff --git a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/ClusteringPipeline.java b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/beam/ClusteringPipeline.java
@@ -137,8 +137,7 @@ public void processElement(
                     List<String> otherCatalogNumbers =
                         source.getMultiValues().get(DwcTerm.otherCatalogNumbers.simpleName());
 
-                    List<String> recordedBy =
-                        source.getMultiValues().get(DwcTerm.recordedBy.simpleName());
+                    String recordedBy = source.getStrings().get(DwcTerm.recordedBy.simpleName());
 
                     Long eventDateL = source.getLongs().get(DwcTerm.eventDate.simpleName());
                     String eventDate = "";
@@ -162,7 +161,7 @@ public void processElement(
                             .withDay(day)
                             .withEventDate(eventDate)
                             .withTypeStatus(typeStatus)
-                            .withRecordedBy(recordedBy)
+                            .withRecordedBy(Collections.singletonList(recordedBy))
                             .withFieldNumber(fieldNumber)
                             .withRecordNumber(recordNumber)
                             .withCatalogNumber(catalogNumber)
@@ -229,9 +228,8 @@ public void processElement(
 
                     // 3. taxonKey|year|recordedBy hashkeys
                     if (Strings.isNotEmpty(taxonKey) && year != null && recordedBy != null) {
-                      for (String r : recordedBy) {
-                        out.output(builder.withHashKey(taxonKey + "|" + year + "|" + r).build());
-                      }
+                      out.output(
+                          builder.withHashKey(taxonKey + "|" + year + "|" + recordedBy).build());
                     }
                   }
                 }));

diff --git a/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/converters/CoreCsvConverter.java b/livingatlas/pipelines/src/main/java/au/org/ala/pipelines/converters/CoreCsvConverter.java
@@ -24,7 +24,7 @@ public class CoreCsvConverter {
           .addKeyTermFn(DwcTerm.institutionCode, getString(DwcTerm.institutionCode))
           .addKeyTermFn(DwcTerm.recordNumber, getString(DwcTerm.recordNumber))
           .addKeyTermFn(DwcTerm.basisOfRecord, getString(DwcTerm.basisOfRecord), "HumanObservation")
-          .addKeyTermFn(DwcTerm.recordedBy, getMultivalue(DwcTerm.recordedBy))
+          .addKeyTermFn(DwcTerm.recordedBy, getString(DwcTerm.recordedBy))
           .addKeyTermFn(DwcTerm.occurrenceStatus, getString(DwcTerm.occurrenceStatus))
           .addKeyTermFn(DwcTerm.individualCount, getInt(DwcTerm.individualCount))
           .addKeyTermFn(DwcTerm.scientificName, getString(DwcTerm.scientificName))

diff --git a/...ngatlas/pipelines/src/main/java/au/org/ala/pipelines/transforms/IndexRecordTransform.java b/...ngatlas/pipelines/src/main/java/au/org/ala/pipelines/transforms/IndexRecordTransform.java
@@ -198,7 +198,7 @@ public static IndexRecord createIndexRecord(
         "degreeOfEstablishment"); // GBIF treats it as a JSON, but ALA needs a String which is
     // defined
     skipKeys.add(DwcTerm.typeStatus.simpleName());
-    skipKeys.add(DwcTerm.recordedBy.simpleName());
+    skipKeys.add(DwcTerm.recordedBy.simpleName()); // Do not use processed recordedBy
     skipKeys.add(DwcTerm.identifiedBy.simpleName());
     skipKeys.add(DwcTerm.preparations.simpleName());
     skipKeys.add(DwcTerm.datasetID.simpleName());
@@ -610,7 +610,6 @@ private static void applyBasicRecord(BasicRecord br, IndexRecord.Builder indexRe
       addTermWithAgentsSafely(
           indexRecord, DwcTerm.identifiedByID.simpleName(), br.getIdentifiedByIds());
       addMultiValueTermSafely(indexRecord, DwcTerm.typeStatus.simpleName(), br.getTypeStatus());
-      addMultiValueTermSafely(indexRecord, DwcTerm.recordedBy.simpleName(), br.getRecordedBy());
       addMultiValueTermSafely(indexRecord, DwcTerm.identifiedBy.simpleName(), br.getIdentifiedBy());
       addMultiValueTermSafely(indexRecord, DwcTerm.preparations.simpleName(), br.getPreparations());
       addMultiValueTermSafely(indexRecord, DwcTerm.datasetID.simpleName(), br.getDatasetID());
@@ -850,6 +849,11 @@ public static Set<String> getAddedValues() {
         .addAll(
             BasicRecord.getClassSchema().getFields().stream()
                 .map(Field::name)
+                .filter(
+                    name ->
+                        !DwcTerm.recordedBy
+                            .simpleName()
+                            .equals(name)) // Do not use the processed recordedBy
                 .collect(Collectors.toList()))
         .addAll(
             TemporalRecord.getClassSchema().getFields().stream()

diff --git a/...ngatlas/pipelines/src/test/java/au/org/ala/pipelines/converters/CoreTsvConverterTest.java b/...ngatlas/pipelines/src/test/java/au/org/ala/pipelines/converters/CoreTsvConverterTest.java
@@ -52,7 +52,7 @@ public void converterTest() {
       "\"raw_er_institutionCode\"", // DwcTerm.institutionCode
       "\"raw_er_recordNumber\"", // DwcTerm.recordNumber
       "\"br_basisOfRecord\"", // DwcTerm.basisOfRecord
-      "\"br_recordedBy_1|br_recordedBy_2\"", // DwcTerm.recordedBy
+      "\"raw_er_recordedBy\"", // DwcTerm.recordedBy
       "\"br_occurrenceStatus\"", // DwcTerm.occurrenceStatus
       "\"222\"", // DwcTerm.individualCount
       "\"atxr_ScientificName\"", // DwcTerm.scientificName
@@ -940,7 +940,7 @@ public void converterDefaultTest() {
       "\"raw_er_institutionCode\"", // DwcTerm.institutionCode
       "\"raw_er_recordNumber\"", // DwcTerm.recordNumber
       "\"HumanObservation\"", // DwcTerm.basisOfRecord
-      "\"\"", // DwcTerm.recordedBy
+      "\"raw_er_recordedBy\"", // DwcTerm.recordedBy
       "\"\"", // DwcTerm.occurrenceStatus
       "\"\"", // DwcTerm.individualCount
       "\"\"", // DwcTerm.scientificName

diff --git a/livingatlas/solr/conf/managed-schema b/livingatlas/solr/conf/managed-schema
@@ -368,7 +368,7 @@
   <field name="preparations"  type="string" docValues="true" indexed="true" multiValued="true"/>
   <field name="previousIdentifications"  type="string" docValues="true" indexed="true"/>
   <field name="recordNumber"  type="string" docValues="true" indexed="true"/>
-  <field name="recordedBy"  type="string" docValues="true" indexed="true" multiValued="true"/>
+  <field name="recordedBy"  type="string" docValues="true" indexed="true"/>
   <field name="relativeOrganismQuantity"  type="double" docValues="true" indexed="true"/>
   <field name="references"  type="string" docValues="true" indexed="true"/>
   <field name="relatedResourceID"  type="string" docValues="true" indexed="true"/>
@@ -661,7 +661,6 @@
   <field name="raw_publishingOrganizationKey"			 type="string"  docValues="true" indexed="true" />
   <field name="raw_taxonRank"					         type="string"  docValues="true" indexed="true" />
   <field name="raw_taxonRankID"					         type="string"  docValues="true" indexed="true" />
-  <field name="raw_recordedBy"					         type="string"  docValues="true" indexed="true" />
   <field name="raw_recordedByID"					     type="string"  docValues="true" indexed="true" />
   <field name="raw_references"					         type="string"  docValues="true" indexed="true" />
   <field name="raw_relativeOrganismQuantity"	         type="string"  docValues="true" indexed="true" />
@@ -751,7 +750,6 @@
   <copyField source="recordedBy" dest="text"/>
   <copyField source="identifiedBy" dest="text_identifiedBy"/>
   <copyField source="recordedBy" dest="text_recordedBy"/>
-  <copyField source="raw_recordedBy" dest="text_recordedBy"/>
   <copyField source="scientificName" dest="matched_name"/>
   <copyField source="scientificName" dest="text"/>
   <copyField source="species" dest="text"/>