chore: a coupleof tweaks

confluentinc · Oct 28, 2019 · 3f9fe9a · 3f9fe9a
1 parent bef9b95
commit 3f9fe9a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ecution/src/main/java/io/confluent/ksql/execution/function/udtf/TableFunctionApplier.java b/...ecution/src/main/java/io/confluent/ksql/execution/function/udtf/TableFunctionApplier.java
@@ -32,12 +32,12 @@ public class TableFunctionApplier {
   public TableFunctionApplier(final KsqlTableFunction tableFunction,
       final ExpressionMetadata expressionMetadata) {
     this.tableFunction = Objects.requireNonNull(tableFunction);
-    this.expressionMetadata = expressionMetadata;
+    this.expressionMetadata = Objects.requireNonNull(expressionMetadata);
   }
 
   @SuppressWarnings("unchecked")
   List<Object> apply(final GenericRow row) {
-    final Object val = expressionMetadata.evaluate(row);
-    return tableFunction.flatMap(val);
+    final Object unexplodedVal = expressionMetadata.evaluate(row);
+    return tableFunction.flatMap(unexplodedVal);
   }
 }