Package io.delta.kernel.defaults.internal.expressions

Class DefaultExpressionEvaluator

Object
io.delta.kernel.defaults.internal.expressions.DefaultExpressionEvaluator
All Implemented Interfaces:
io.delta.kernel.expressions.ExpressionEvaluator, AutoCloseable
public class DefaultExpressionEvaluator extends Object implements io.delta.kernel.expressions.ExpressionEvaluator
Implementation of ExpressionEvaluator for default ExpressionHandler. It takes care of validating, adding necessary implicit casts and evaluating the Expression on given ColumnarBatch.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultExpressionEvaluator(io.delta.kernel.types.StructType inputSchema, io.delta.kernel.expressions.Expression expression, io.delta.kernel.types.DataType outputType)
    Create a DefaultExpressionEvaluator instance bound to the given expression and inputSchem.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    io.delta.kernel.data.ColumnVector
    eval(io.delta.kernel.data.ColumnarBatch input)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • DefaultExpressionEvaluator

      public DefaultExpressionEvaluator(io.delta.kernel.types.StructType inputSchema, io.delta.kernel.expressions.Expression expression, io.delta.kernel.types.DataType outputType)
      Create a DefaultExpressionEvaluator instance bound to the given expression and inputSchem.
      Parameters:
      inputSchema - Input data schema
      expression - Expression to evaluate.
      outputType - Expected result data type.

  • Method Details

    • eval

      public io.delta.kernel.data.ColumnVector eval(io.delta.kernel.data.ColumnarBatch input)
      Specified by:
      eval in interface io.delta.kernel.expressions.ExpressionEvaluator

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable