public RelDataType getRowType(RelDataTypeFactory typeFactory) { final RelDataType mapType = typeFactory.createMapType( typeFactory.createSqlType(SqlTypeName.VARCHAR), typeFactory.createTypeWithNullability( typeFactory.createSqlType(SqlTypeName.ANY), true)); return typeFactory.builder().add("_MAP", mapType).build(); }