Package com.linkedin.venice.utils

Class AvroSupersetSchemaUtils

java.lang.Object
com.linkedin.venice.utils.AvroSupersetSchemaUtils
public class AvroSupersetSchemaUtils extends Object

  • Method Details

    • isSupersetSchema

      public static boolean isSupersetSchema(org.apache.avro.Schema s1, org.apache.avro.Schema s2)
      Returns:
      True if is 's superset schema and false otherwise.

    • generateSupersetSchema

      public static org.apache.avro.Schema generateSupersetSchema(org.apache.avro.Schema existingSchema, org.apache.avro.Schema newSchema)
      Generate super-set schema of two Schemas. If we have {A,B,C} and {A,B,D} it will generate {A,B,C,D}, where C/D could be nested record change as well eg, array/map of records, or record of records. Prerequisite: The top-level schema are of type RECORD only and each field have default values. ie they are compatible schemas and the generated schema will pick the default value from new value schema.
      Parameters:
      existingSchema - schema existing in the repo
      newSchema - schema to be added.
      Returns:
      super-set schema of existingSchema abd newSchema

    • getSupersetSchemaFromSchemaResponse

      public static MultiSchemaResponse.Schema getSupersetSchemaFromSchemaResponse(MultiSchemaResponse schemaResponse, int supersetSchemaId)

    • getLatestUpdateSchemaFromSchemaResponse

      public static MultiSchemaResponse.Schema getLatestUpdateSchemaFromSchemaResponse(MultiSchemaResponse schemaResponse, int supersetSchemaId)

    • validateSubsetValueSchema

      public static boolean validateSubsetValueSchema(org.apache.avro.Schema subsetValueSchema, String supersetSchemaStr)
      * Validate if the Subset Value Schema is a subset of the Superset Value Schema, here the field props are not used to check if the field is same or not.