From 3f9fe9a6c8e73118ac39a5430a108c4405948bd9 Mon Sep 17 00:00:00 2001 From: Tim Fox Date: Sat, 26 Oct 2019 10:47:05 -0700 Subject: [PATCH] chore: a coupleof tweaks --- .../ksql/execution/function/udtf/TableFunctionApplier.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ksql-execution/src/main/java/io/confluent/ksql/execution/function/udtf/TableFunctionApplier.java b/ksql-execution/src/main/java/io/confluent/ksql/execution/function/udtf/TableFunctionApplier.java index 312f46766f59..c872db939081 100644 --- a/ksql-execution/src/main/java/io/confluent/ksql/execution/function/udtf/TableFunctionApplier.java +++ b/ksql-execution/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 apply(final GenericRow row) { - final Object val = expressionMetadata.evaluate(row); - return tableFunction.flatMap(val); + final Object unexplodedVal = expressionMetadata.evaluate(row); + return tableFunction.flatMap(unexplodedVal); } }