@Test(expected = ValidationException.class) public void testBadSchemaMultipleOCCVersions() { parser.parseEntitySchema(AvroUtils .inputStreamToString(AvroKeyEntitySchemaParser.class .getResourceAsStream("/BadSchemaMultipleOCCVersions.avsc"))); }
@Override public AvroEntitySchema parseEntitySchema(String rawSchema) { DatasetDescriptor descriptor = new DatasetDescriptor.Builder() .schemaLiteral(rawSchema) .build(); return new AvroEntitySchema( descriptor.getSchema(), rawSchema, descriptor.getColumnMapping()); }
AvroKeyEntitySchemaParser implements
    KeyEntitySchemaParser<AvroKeySchema, AvroEntitySchema> { @Override public AvroEntitySchema parseEntitySchema(String rawSchema) { DatasetDescriptor descriptor = new DatasetDescriptor.Builder() .schemaLiteral(rawSchema) .build(); return new AvroEntitySchema( descriptor.getSchema(), rawSchema, descriptor.getColumnMapping()); } }
AvroKeyEntitySchemaParser implements
    KeyEntitySchemaParser<AvroKeySchema, AvroEntitySchema> { @Override public AvroEntitySchema parseEntitySchema(String rawSchema) { DatasetDescriptor descriptor = new DatasetDescriptor.Builder() .schemaLiteral(rawSchema) .build(); return new AvroEntitySchema( descriptor.getSchema(), rawSchema, descriptor.getColumnMapping()); }  }
AvroKeyEntitySchemaParser implements
    KeyEntitySchemaParser<AvroKeySchema, AvroEntitySchema> { @Override public AvroEntitySchema parseEntitySchema(String rawSchema) { DatasetDescriptor descriptor = new DatasetDescriptor.Builder() .schemaLiteral(rawSchema) .build(); return new AvroEntitySchema( descriptor.getSchema(), rawSchema, descriptor.getColumnMapping()); }  @Override AvroKeySchema parseKeySchema(String rawSchema); @Override AvroKeySchema parseKeySchema(String rawSchema,
      PartitionStrategy partitionStrategy); @Override AvroEntitySchema parseEntitySchema(String rawSchema); @Override AvroEntitySchema parseEntitySchema(String rawSchema,
      ColumnMapping columnMapping); }
AvroKeyEntitySchemaParser implements
    KeyEntitySchemaParser<AvroKeySchema, AvroEntitySchema> { @Override public AvroEntitySchema parseEntitySchema(String rawSchema) { DatasetDescriptor descriptor = new DatasetDescriptor.Builder() .schemaLiteral(rawSchema) .build(); return new AvroEntitySchema( descriptor.getSchema(), rawSchema, descriptor.getColumnMapping()); }  @Override AvroKeySchema parseKeySchema(String rawSchema); @Override AvroKeySchema parseKeySchema(String rawSchema,
      PartitionStrategy partitionStrategy); @Override AvroEntitySchema parseEntitySchema(String rawSchema); @Override AvroEntitySchema parseEntitySchema(String rawSchema,
      ColumnMapping columnMapping);  }