Refs #576: removes unnecessary filter

bpn1 · Oct 1, 2017 · a243e45 · a243e45
1 parent c72387d
commit a243e45
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/main/scala/de/hpi/ingestion/dataimport/kompass/KompassDataLakeImport.scala b/src/main/scala/de/hpi/ingestion/dataimport/kompass/KompassDataLakeImport.scala
@@ -52,11 +52,8 @@ object KompassDataLakeImport extends DataLakeImportImplementation[KompassEntity]
 		values: List[String],
 		strategies: Map[String, List[String]]
 	): List[String] = {
-		var normalized = KompassNormalizationStrategy(attribute)(values)
-		if(attribute == "gen_sectors") {
-			normalized = normalized.flatMap(x => strategies.getOrElse(x, List(x)))
-		}
-		normalized.filter(_.nonEmpty)
+		val normalized = KompassNormalizationStrategy(attribute)(values)
+		if(attribute == "gen_sectors") normalized.flatMap(x => strategies.getOrElse(x, List(x))) else normalized
 	}
 
 	override def translateToSubject(