Skip to content

Commit c86207f

Browse files
#179: Small simplification
1 parent df3b6cc commit c86207f

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

ingestor-default/src/test/scala/za/co/absa/hyperdrive/ingestor/implementation/transformer/column/copy/TestColumnCopyStreamTransformer.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,7 @@ class TestColumnCopyStreamTransformer extends FlatSpec with SparkTestBase with M
3636
.add("Field2", StringType)
3737
.add("Field3", new ArrayType(IntegerType, containsNull = true)))
3838
.add("col3Top", StringType)
39-
val input = spark.createDataFrame(spark.sparkContext.parallelize(Seq[Row]()), inputSchema)
40-
val memoryStream = new MemoryStream[Row](1, spark.sqlContext)(RowEncoder(input.schema))
39+
val memoryStream = new MemoryStream[Row](1, spark.sqlContext)(RowEncoder(inputSchema))
4140
val df = memoryStream.toDF()
4241

4342
val config = new DynamicCombinedConfiguration()

0 commit comments

Comments
 (0)