@Test public void testGroovyFunctionSyntax() { Schema pinotSchema; pinotSchema = new Schema(); DimensionFieldSpec dimensionFieldSpec = new DimensionFieldSpec("dim1", DataType.STRING, true); dimensionFieldSpec.setTransformFunction("Groovy(function, argument3)"); pinotSchema.addField(dimensionFieldSpec); checkValidationFails(pinotSchema); pinotSchema = new Schema(); dimensionFieldSpec = new DimensionFieldSpec("dim1", DataType.STRING, true); dimensionFieldSpec.setTransformFunction("Groovy({function})"); pinotSchema.addField(dimensionFieldSpec); SchemaUtils.validate(pinotSchema); pinotSchema = new Schema.SchemaBuilder().addSingleValueDimension("dim1", DataType.STRING).addMetric("m1", DataType.LONG) .addTime(new TimeGranularitySpec(DataType.LONG, TimeUnit.MILLISECONDS, "time"), null).build(); pinotSchema.getFieldSpecFor("dim1").setTransformFunction("Groovy({function}, argument1, argument2, argument3)"); pinotSchema.getFieldSpecFor("m1").setTransformFunction("Groovy({function}, m2, m3)"); pinotSchema.getFieldSpecFor("time").setTransformFunction("Groovy({function}, millis)"); SchemaUtils.validate(pinotSchema); }
public static void validate(Schema schema, List<TableConfig> tableConfigs) { for (TableConfig tableConfig : tableConfigs) { validateCompatibilityWithTableConfig(schema, tableConfig); } validate(schema); }
SchemaUtils { public static void validate(Schema schema, List<TableConfig> tableConfigs) { for (TableConfig tableConfig : tableConfigs) { validateCompatibilityWithTableConfig(schema, tableConfig); } validate(schema); } }
SchemaUtils { public static void validate(Schema schema, List<TableConfig> tableConfigs) { for (TableConfig tableConfig : tableConfigs) { validateCompatibilityWithTableConfig(schema, tableConfig); } validate(schema); }  }
SchemaUtils { public static void validate(Schema schema, List<TableConfig> tableConfigs) { for (TableConfig tableConfig : tableConfigs) { validateCompatibilityWithTableConfig(schema, tableConfig); } validate(schema); }  static void validate(Schema schema, List<TableConfig> tableConfigs); static void validate(Schema schema); }
SchemaUtils { public static void validate(Schema schema, List<TableConfig> tableConfigs) { for (TableConfig tableConfig : tableConfigs) { validateCompatibilityWithTableConfig(schema, tableConfig); } validate(schema); }  static void validate(Schema schema, List<TableConfig> tableConfigs); static void validate(Schema schema); static final String MAP_KEY_COLUMN_SUFFIX; static final String MAP_VALUE_COLUMN_SUFFIX; }