Uses of Class
io.confluent.kafka.schemaregistry.type.logical.Schema
Packages that use Schema
Package
Description
SQL CHECK → CEL translator.
-
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical
Methods in io.confluent.kafka.schemaregistry.type.logical that return SchemaModifier and TypeMethodDescriptionstatic SchemaSchema.create(Schema.Type type) static SchemaSchema.createArray(Schema elementType) static SchemaSchema.createBinary(int length) static SchemaSchema.createBytes()Creates an unbounded bytes type (alias for VARBINARY(MAX_LENGTH)).static SchemaSchema.createChar(int length) static SchemaSchema.createDecimal(int precision, int scale) static SchemaSchema.createEnum(List<Schema.EnumValue> values) static Schemastatic SchemaSchema.createMultiset(Schema elementType) static SchemaSchema.createNamedTypeRef(String qualifiedName) static SchemaSchema.createString()Creates an unbounded string type (alias for VARCHAR(MAX_LENGTH)).static SchemaSchema.createStruct(List<Schema.Field> fields) static SchemaSchema.createTime(int precision) static SchemaSchema.createTimestamp(int precision) static SchemaSchema.createTimestampLtz(int precision) static SchemaSchema.createUnion(List<Schema.UnionBranch> branches) static SchemaSchema.createVarbinary(int length) static SchemaSchema.createVarchar(int length) Schema.getElementType()Schema.getKeyType()LogicalType.getRootSchema()LogicalType.RootUnwrap.getRootSchema()LogicalTypesSchemaVisitor.getRootSchema()Schema.Field.getSchema()Schema.UnionBranch.getSchema()Schema.getValueType()Schema.setNullable(boolean nullable) LogicalTypesSchemaVisitor.visitMapType(LogicalTypesParser.MapTypeContext ctx) LogicalTypesSchemaVisitor.visitMapTypeExpr(LogicalTypesParser.MapTypeExprContext ctx) LogicalTypesSchemaVisitor.visitPostfixArray(LogicalTypesParser.PostfixArrayContext ctx) LogicalTypesSchemaVisitor.visitPostfixMultiset(LogicalTypesParser.PostfixMultisetContext ctx) LogicalTypesSchemaVisitor.visitPrefixArray(LogicalTypesParser.PrefixArrayContext ctx) LogicalTypesSchemaVisitor.visitPrefixMultiset(LogicalTypesParser.PrefixMultisetContext ctx) LogicalTypesSchemaVisitor.visitPrimitiveType(LogicalTypesParser.PrimitiveTypeContext ctx) LogicalTypesSchemaVisitor.visitPrimitiveTypeExpr(LogicalTypesParser.PrimitiveTypeExprContext ctx) LogicalTypesSchemaVisitor.visitQualifiedNameExpr(LogicalTypesParser.QualifiedNameExprContext ctx) LogicalTypesSchemaVisitor.visitRowType(LogicalTypesParser.RowTypeContext ctx) LogicalTypesSchemaVisitor.visitRowTypeExpr(LogicalTypesParser.RowTypeExprContext ctx) LogicalTypesSchemaVisitor.visitUnionType(LogicalTypesParser.UnionTypeContext ctx) LogicalTypesSchemaVisitor.visitUnionTypeExpr(LogicalTypesParser.UnionTypeExprContext ctx) LogicalTypesSchemaVisitor.visitVariantTypeExpr(LogicalTypesParser.VariantTypeExprContext ctx) Methods in io.confluent.kafka.schemaregistry.type.logical that return types with arguments of type SchemaModifier and TypeMethodDescriptionLogicalType.getLocalNamedTypes()Subset ofLogicalType.getNamedTypes()that are NOT inLogicalType.getExternalTypes()— the entries the user authored locally.LogicalType.getNamedTypes()Locally-defined named types, keyed by their qualified name.LogicalTypesSchemaVisitor.getNamedTypes()Methods in io.confluent.kafka.schemaregistry.type.logical with parameters of type SchemaModifier and TypeMethodDescriptionstatic voidLogicalType.collectNamedRefs(Schema schema, Set<String> sink) Walkschemaand collect the qualified names of everyNAMED_TYPE_REFencountered.static SchemaSchema.createArray(Schema elementType) static Schemastatic SchemaSchema.createMultiset(Schema elementType) static LogicalType.RootUnwrapLogicalType.unwrapLeafNamedRoot(Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, String namespace) IfrootSchemais aNAMED_TYPE_REFto a local leaf named type, unwrap it to the bareSTRUCT/ENUMbody carrying its simple name, mirroring the canonical named-root shape shared by every format reader and the DDL visitor.Method parameters in io.confluent.kafka.schemaregistry.type.logical with type arguments of type SchemaModifier and TypeMethodDescriptionstatic booleanStatic form ofLogicalType.isCyclic(String)for use during conversion when a builder map is being populated and theLogicalTypeinstance does not yet exist.static booleanLogicalType.isReferencedByPeer(String fqn, Map<String, Schema> namedTypes) True iff a named type other thanfqncarries aNAMED_TYPE_REFtofqn.static LogicalType.RootUnwrapLogicalType.unwrapLeafNamedRoot(Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, String namespace) IfrootSchemais aNAMED_TYPE_REFto a local leaf named type, unwrap it to the bareSTRUCT/ENUMbody carrying its simple name, mirroring the canonical named-root shape shared by every format reader and the DDL visitor.Constructors in io.confluent.kafka.schemaregistry.type.logical with parameters of type SchemaModifierConstructorDescriptionField(String name, Schema schema, int position, Object defaultValue, boolean hasDefault, boolean derivedDefault, String doc, List<String> tags, Map<String, Object> params, List<Rule> rules) Field(String name, Schema schema, int position, Object defaultValue, boolean hasDefault, String doc, List<String> tags, Map<String, Object> params) Field(String name, Schema schema, int position, Object defaultValue, boolean hasDefault, String doc, List<String> tags, Map<String, Object> params, List<Rule> rules) LogicalType(Schema rootSchema) LogicalType(Schema rootSchema, Map<String, Schema> namedTypes) LogicalType(Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, Map<String, String> externalImports, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String name, String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, Map<String, String> externalImports, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) Canonical constructor.UnionBranch(String name, Schema schema) Constructor parameters in io.confluent.kafka.schemaregistry.type.logical with type arguments of type SchemaModifierConstructorDescriptionLogicalType(Schema rootSchema, Map<String, Schema> namedTypes) LogicalType(Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, Map<String, String> externalImports, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) LogicalType(String name, String namespace, Schema rootSchema, Map<String, Schema> namedTypes, Set<String> externalTypes, Map<String, String> externalImports, List<SchemaReference> references, Map<String, String> resolvedReferences, Map<List<Integer>, Object> defaultValues) Canonical constructor. -
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical.avro
Methods in io.confluent.kafka.schemaregistry.type.logical.avro that return SchemaModifier and TypeMethodDescriptionstatic SchemaAvroToLogicalTypeConverter.toRootSchema(AvroSchema avroSchema) Methods in io.confluent.kafka.schemaregistry.type.logical.avro with parameters of type SchemaModifier and TypeMethodDescriptionstatic ObjectAvroDefaultValueConverter.toAvroData(Schema type, Object value) Encode a typed Java default value into the Avro-friendly form expected by org.apache.avro.Schema.Field's defaultVal argument.static ObjectAvroDefaultValueConverter.toJavaData(Schema type, Object defaultValue) Converts an Avro default value to a Java data object based on the logical type schema. -
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical.common
Methods in io.confluent.kafka.schemaregistry.type.logical.common that return SchemaMethods in io.confluent.kafka.schemaregistry.type.logical.common that return types with arguments of type SchemaModifier and TypeMethodDescriptionFromLogicalContext.getNamedTypes()ToLogicalContext.getNamedTypes()Methods in io.confluent.kafka.schemaregistry.type.logical.common with parameters of type Schema -
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical.constraint
Methods in io.confluent.kafka.schemaregistry.type.logical.constraint that return SchemaModifier and TypeMethodDescriptionConstraintValidationContext.resolveNamedType(Schema schema) Resolve aNAMED_TYPE_REF's qualified name to its underlying STRUCT/ENUM body, or null if not registered.Schema for a known column or typed binding.Methods in io.confluent.kafka.schemaregistry.type.logical.constraint with parameters of type SchemaModifier and TypeMethodDescriptionstatic ConstraintValidationContextConstraintValidationContext.columnLevel(String fieldName, Schema fieldSchema) Context for a column-level CHECK: only the attached field is in scope.ConstraintValidationContext.resolveNamedType(Schema schema) Resolve aNAMED_TYPE_REF's qualified name to its underlying STRUCT/ENUM body, or null if not registered.ConstraintValidationContext.withBinding(String name, Schema type) Returns a derived context withnamebound totype— e.g., a CEL macro iteration variable typed as the collection's element type.Method parameters in io.confluent.kafka.schemaregistry.type.logical.constraint with type arguments of type SchemaModifier and TypeMethodDescriptionConstraintValidationContext.withNamedTypes(Map<String, Schema> types) Returns a derived context withnamedTypesattached. -
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical.json
Methods in io.confluent.kafka.schemaregistry.type.logical.json that return SchemaModifier and TypeMethodDescriptionstatic SchemaJsonToLogicalTypeConverter.toRootSchema(JsonSchema schema) Methods in io.confluent.kafka.schemaregistry.type.logical.json with parameters of type SchemaModifier and TypeMethodDescriptionstatic ObjectJsonDefaultValueConverter.toJavaData(Schema type, Object value) Decode a JSON-schema default value back into a typed Java value.static ObjectJsonDefaultValueConverter.toJsonValue(Schema type, Object value) Encode a typed Java default value into a JSON-schema-friendly form. -
Uses of Schema in io.confluent.kafka.schemaregistry.type.logical.protobuf
Methods in io.confluent.kafka.schemaregistry.type.logical.protobuf that return SchemaModifier and TypeMethodDescriptionstatic SchemaProtoToLogicalTypeConverter.toRootSchema(ProtobufSchema schema) Methods in io.confluent.kafka.schemaregistry.type.logical.protobuf with parameters of type SchemaModifier and TypeMethodDescriptionstatic ObjectProtoDefaultValueConverter.toJavaData(Schema type, String value) Decode a Meta.params default string back into a typed Java value.static StringProtoDefaultValueConverter.toProtoValue(Schema type, Object value) Encode a typed Java default value into a string for storage in Meta.params.