AvroTableScan.java

  @Override
  public Result implement(EnumerableRelImplementor implementor, Prefer pref) {
    PhysType physType = PhysTypeImpl.of(implementor.getTypeFactory(), getRowType(), pref.preferArray());
    return implementor.result(physType, Blocks.toBlock(
      Expressions.call(
        this.table.getExpression(AvroTable.class),
        "project",
        implementor.getRootExpression(),
        Expressions.constant(this.fields)
      )
    ));