Package io.confluent.connect.schema

Class ConnectVariant

java.lang.Object
io.confluent.connect.schema.ConnectVariant
public class ConnectVariant extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    LOGICAL_NAME
     
    static final String
    METADATA_FIELD
     
    static final String
    VALUE_FIELD
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ConnectVariant()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.kafka.connect.data.SchemaBuilder
    builder()
    Returns a SchemaBuilder for a Variant.
    static com.fasterxml.jackson.databind.JsonNode
    fromLogical(org.apache.kafka.connect.data.Schema schema, org.apache.kafka.connect.data.Struct value)
    Convert a Variant Connect Struct to a JsonNode.
    static boolean
    isVariant(org.apache.kafka.connect.data.Schema schema)
    Returns whether a schema represents a Variant.
    static org.apache.kafka.connect.data.Struct
    toLogical(org.apache.kafka.connect.data.Schema schema, com.fasterxml.jackson.databind.JsonNode value)
    Convert a JsonNode to a Variant Connect Struct.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

  • Constructor Details

    • ConnectVariant

      public ConnectVariant()

  • Method Details

    • builder

      public static org.apache.kafka.connect.data.SchemaBuilder builder()
      Returns a SchemaBuilder for a Variant.
      Returns:
      a SchemaBuilder

    • isVariant

      public static boolean isVariant(org.apache.kafka.connect.data.Schema schema)
      Returns whether a schema represents a Variant.
      Parameters:
      schema - the schema
      Returns:
      whether the schema represents a Variant

    • fromLogical

      public static com.fasterxml.jackson.databind.JsonNode fromLogical(org.apache.kafka.connect.data.Schema schema, org.apache.kafka.connect.data.Struct value)
      Convert a Variant Connect Struct to a JsonNode. Used by JSON Schema converter to serialize variant values.
      Parameters:
      schema - the schema
      value - the Variant Struct with metadata and value byte arrays
      Returns:
      the JSON representation of the variant value

    • toLogical

      public static org.apache.kafka.connect.data.Struct toLogical(org.apache.kafka.connect.data.Schema schema, com.fasterxml.jackson.databind.JsonNode value)
      Convert a JsonNode to a Variant Connect Struct. Used by JSON Schema converter to deserialize variant values.
      Parameters:
      schema - the schema
      value - the JSON value to convert
      Returns:
      a Struct with metadata and value byte arrays