class BeamSqlInputRefExpression extends BeamSqlExpression {

  @Override
  public BeamSqlPrimitive evaluate(
      Row inputRow, BoundedWindow window, BeamSqlExpressionEnvironment env) {
    return BeamSqlPrimitive.of(outputType, inputRow.getValue(inputRef));
  }

  public  BeamSqlInputRefExpression(SqlTypeName sqlTypeName, int inputRef);

}