code: private void initializeEntityVersionEntityMapper() {
      AvroEntitySchema avroEntitySchema = schemaParser
          .parseEntitySchema(managedSchemaEntityVersionSchema);
      avroEntitySchema = AvroUtils.mergeSpecificStringTypes(
          ManagedSchemaEntityVersion.class, avroEntitySchema);
      AvroEntityComposer<ManagedSchemaEntityVersion> entityComposer = new AvroEntityComposer<ManagedSchemaEntityVersion>(
          avroEntitySchema, true);
      AvroEntitySerDe<ManagedSchemaEntityVersion> entitySerDe = new AvroEntitySerDe<ManagedSchemaEntityVersion>(
          entityComposer, avroEntitySchema, avroEntitySchema, true);
      this.managedSchemaEntityVersionEntityMapper = new BaseEntityMapper<ManagedSchemaEntityVersion>(
          avroEntitySchema, entitySerDe);
    }
docs: Initialize the entity mapper we'll use to convert the schema version
  metadata in each row to a ManagedSchemaEntityVersion record.