Class RmdSchemaEntry


  • public class RmdSchemaEntry
    extends GeneratedSchemaEntry
    This holds the schema to perform conflict resolution on records when samza produces data in active active replication mode. More information can be found here RmdSchemaGenerator about the structure of the schema.
    • Constructor Detail

      • RmdSchemaEntry

        public RmdSchemaEntry​(int valueSchemaId,
                              int protocolVersion,
                              java.lang.String schemaStr)
      • RmdSchemaEntry

        public RmdSchemaEntry​(int valueSchemaId,
                              int protocolVersion,
                              org.apache.avro.Schema schema)
      • RmdSchemaEntry

        public RmdSchemaEntry​(int valueSchemaId,
                              int protocolVersion,
                              byte[] bytes)