#174: Cosmetic refactoring

kevinwallimann · kevinwallimann · commit c3e0edfa837f · 2020-11-16T09:02:18.000+01:00
diff --git a/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/transformer/avro/confluent/ConfluentAvroEncodingTransformer.scala b/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/transformer/avro/confluent/ConfluentAvroEncodingTransformer.scala
@@ -66,11 +66,10 @@ private[transformer] class ConfluentAvroEncodingTransformer(
   }
 
   private def getValueDataFrame(dataFrame: DataFrame): DataFrame = {
-    val allColumns = dataFrame.columns.map(c => dataFrame(c))
-    val allColumnsStruct = struct(allColumns: _*)
-    val toAvroConfig = getValueAvroConfig(config, allColumnsStruct.expr)
+    val allColumns = struct(dataFrame.columns.map(c => dataFrame(c)): _*)
+    val toAvroConfig = getValueAvroConfig(config, allColumns.expr)
     logger.info(s"ToAvro settings: $toAvroConfig")
-    dataFrame.select(to_avro(allColumnsStruct, toAvroConfig) as 'value)
+    dataFrame.select(to_avro(allColumns, toAvroConfig) as 'value)
   }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -66,11 +66,10 @@ private[transformer] class ConfluentAvroEncodingTransformer(`
`66`	`66`	`}`
`67`	`67`
`68`	`68`	`private def getValueDataFrame(dataFrame: DataFrame): DataFrame = {`
`69`		`- val allColumns = dataFrame.columns.map(c => dataFrame(c))`
`70`		`- val allColumnsStruct = struct(allColumns: _*)`
`71`		`- val toAvroConfig = getValueAvroConfig(config, allColumnsStruct.expr)`
	`69`	`+ val allColumns = struct(dataFrame.columns.map(c => dataFrame(c)): _*)`
	`70`	`+ val toAvroConfig = getValueAvroConfig(config, allColumns.expr)`
`72`	`71`	`logger.info(s"ToAvro settings: $toAvroConfig")`
`73`		`- dataFrame.select(to_avro(allColumnsStruct, toAvroConfig) as 'value)`
	`72`	`+ dataFrame.select(to_avro(allColumns, toAvroConfig) as 'value)`
`74`	`73`	`}`
`75`	`74`	`}`
`76`	`75`