Package io.confluent.kafka.schemaregistry.type.logical.common

Class FromLogicalContext<T>

java.lang.Object
io.confluent.kafka.schemaregistry.type.logical.common.FromLogicalContext<T>
Type Parameters:
T - the format-specific schema type (e.g., org.apache.avro.Schema)
public final class FromLogicalContext<T> extends Object
Mutable context for converting logical type Schema to a format-specific schema. Wraps the input LogicalType and accumulates conversion-time state (converted named types cache, external file descriptor dependencies for Protobuf).

  • Constructor Details

  • Method Details

    • getLogicalType

      public LogicalType getLogicalType()

    • getVersion

      public LogicalTypeVersion getVersion()

    • isV1

      public boolean isV1()

    • getNamedTypes

      public Map<String,Schema> getNamedTypes()

    • getReferences

      public List<SchemaReference> getReferences()

    • getResolvedReferences

      public Map<String,String> getResolvedReferences()

    • hasNamedType

      public boolean hasNamedType(String name)

    • getNamedType

      public Schema getNamedType(String name)

    • getConvertedNamedTypes

      public Map<String,T> getConvertedNamedTypes()

    • isAlreadyConverted

      public boolean isAlreadyConverted(String name)

    • getConverted

      public T getConverted(String name)

    • putConverted

      public void putConverted(String name, T converted)

    • isInProgress

      public boolean isInProgress(String name)

    • markInProgress

      public void markInProgress(String name)

    • unmarkInProgress

      public void unmarkInProgress(String name)

    • getExternalDependencies

      public List<com.google.protobuf.Descriptors.FileDescriptor> getExternalDependencies()

    • addExternalDependency

      public void addExternalDependency(com.google.protobuf.Descriptors.FileDescriptor dependency)

    • externalImportNameFor

      public String externalImportNameFor(String fqn)
      Return the import name to use for fqn, or null if the FQN was not registered as an external (callers fall back to the FQN). For the proto writer, this is the SR ref name used as the import "..." string in the emitted file.

    • registerExternalImport

      public void registerExternalImport(String fqn, String importName)

    • externalFileAlreadyRenamedTo

      public String externalFileAlreadyRenamedTo(String sourceFileName)

    • markExternalFileRenamed

      public void markExternalFileRenamed(String sourceFileName, String renameTo)