class AvroReaderWithEmbeddedSchema extends AvroRecordReader {

    @Override
    public RecordSchema getSchema() throws MalformedRecordException {
        return recordSchema;
    }

    public  AvroReaderWithEmbeddedSchema(final InputStream in);

}