Avro模式中的多态性和继承

Question

有没有可能编写一个Avro schema/IDL来生成一个Java类，或者扩展一个基类，或者实现一个接口？似乎生成的Java类扩展了< code > org . Apache . avro . specific . specificrecordbase 。所以，工具可能是正确的选择。但是，我不知道这是否可能。

我看过一些示例，其中包含在每个特定架构中定义显式“类型”字段的建议，其关联性大于继承语义。

我在工厂类和代码的其他部分大量使用基类，比如< code >

另一个次要问题：您可以使用IDL仅定义没有协议定义的记录吗？我认为答案是否定的，因为编译器抱怨缺少协议关键字。

感谢帮助！谢谢。

Answer 1

我发现这个问题也有类似的问题。在我的例子中，我只需要将标记接口强加给某些类型（以便以后区分特定的类）。感谢您的回答，我更深入地研究了record.vm模板的结构。我发现可以在. avsc定义JSON中定义"javaAnnoection"："my.full.AnnotationName"key。然后将@my.full.AnnotationName添加到生成的类中。

诚然，这个解决方案最终并不是建立在标记界面上的，尽管对于我来说已经足够好了，保持模板不变是一个很大的优势。

Answer 2

我希望这将有助于其他人，如果我写在这里，我已经为这个案例创建了maven插件-https://github.com/tunguski/interfacer.

它检查自动生成的类，并检查它们是否符合特定包中类路径上的接口。如果是，接口将被添加到该类中。它与通用接口一起工作，至少在我必须处理的基本例子中是这样。

该插件不是avro特定的，可以作为生成的代码后处理器使用，因此也可以在其他情况下使用。

<!-- 
  post process avro generated sources and add interfaces from package
  pl.matsuo.interfacer.showcase to every generated class that has 
  all methods from specific interface
 -->
<plugin>
    <groupId>pl.matsuo.interfacer</groupId>
    <artifactId>interfacer-maven-plugin</artifactId>
    <version>0.0.6</version>
    <executions>
        <execution>
            <configuration>
                <interfacesDirectory>${project.basedir}/src/main/java</interfacesDirectory>
                <interfacePackage>pl.matsuo.interfacer.showcase</interfacePackage>
            </configuration>
            <goals>
                <goal>add-interfaces</goal>
            </goals>
        </execution>
    </executions>
</plugin>

// src/main/java manually defined interface
public interface HasName {
  String getName();
}

// target/generated-sources/avro
public class Person {

  String name;

  public String getName() {
    return name;
  }
  // [...]
}

public class Company {

  String name;

  public String getName() {
    return name;
  }
  // [...]
}

// after this plugin run

// target/generated-sources/avro
public class Person implements HasName {

  String name;

  public String getName() {
    return name;
  }
  // [...]
}

public class Company implements HasName {

  String name;

  public String getName() {
    return name;
  }
  // [...]
}

Answer 3

我找到了一个更好的方法来解决这个问题。查看Avro中的Schema生成源，我发现内部类生成逻辑使用Velocity模式来生成类。

我修改了< code>record.vm模板来实现我的特定接口。有一种方法可以使用maven构建插件中的< code>templateDirectory配置来指定velocity目录的位置。

我还改用了< code>SpecificDatumWriter而不是< code>reflectDatumWriter。

<plugin>
  <groupId>org.apache.avro</groupId>
  <artifactId>avro-maven-plugin</artifactId>
   <version>${avro.version}</version>
   <executions>
    <execution>
      <phase>generate-sources</phase>
      <goals>
        <goal>schema</goal>
      </goals>
      <configuration>
         <sourceDirectory>${basedir}/src/main/resources/avro/schema</sourceDirectory>
         <outputDirectory>${basedir}/target/java-gen</outputDirectory>
         <fieldVisibility>private</fieldVisibility>
         <stringType>String</stringType>
         <templateDirectory>${basedir}/src/main/resources/avro/velocity-templates/</templateDirectory>
       </configuration>
    </execution>
  </executions>
</plugin>