Index (kafka-schema-rules 8.4.0 API)

A B C D E F H I J M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values

A

AVRO - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType
AvroCelTypeProvider - Class in io.confluent.kafka.schemaregistry.rules.cel.avro: A CelTypeProvider that surfaces Avro Schema record types as CEL StructTypes.
AvroResultWriter - Class in io.confluent.kafka.schemaregistry.rules.cel.avro: Converts a CEL evaluation result (typically a Map literal or scalar) back into the Avro representation matching a target Schema.

B

bind(RuleContext, Object, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: Inspect the bound message to decide ScriptType, then convert every arg to its CEL-friendly shape.
boundMessage() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings: The value bound for the message variable, used by the identity short-circuit in CelExecutor.transform(io.confluent.kafka.schemaregistry.rules.RuleContext, java.lang.Object).
buildCompiledRule(CelUtils.ScriptType, String, Object, List<CelVarDecl>, CelUtils.RegexEngine) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Like CelUtils.buildProgram(io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType, java.lang.String, java.lang.Object, java.util.List<dev.cel.common.CelVarDecl>) but exposes the compiled AST's result-type CelKind alongside the runnable program.
buildProgram(CelUtils.ScriptType, String, Object, List<CelVarDecl>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Build a CEL CelRuntime.Program for (type, expr, schemaHint, varDecls).
buildProgram(CelUtils.ScriptType, String, Object, List<CelVarDecl>, CelUtils.RegexEngine) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils
BuiltinDeclarations - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin
BuiltinLibrary - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin: Schema Registry's built-in CEL function library.
BuiltinLibrary() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary

C

CEL_IGNORE_GUARD_SEPARATOR - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
CEL_REGEX_ENGINE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: Selects the regex engine used by the CEL matches / matches_string overloads.
CEL_UNSIGNED_FIELD_TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: How an unsigned protobuf field is presented to a CEL_FIELD rule — "int" or "uint", see CelExecutor.UnsignedFieldType.
celArgs() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings: Read-only view of the converted CEL args.
CelDecimal - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin: The runtime Java representation of the CEL confluent.type.Decimal type (CelTypeLabels.DECIMAL): a BigDecimal whose equals is numeric.
CelExecutor - Class in io.confluent.kafka.schemaregistry.rules.cel
CelExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
CelExecutor.Bindings - Class in io.confluent.kafka.schemaregistry.rules.cel: Pre-converted CEL invocation context.
CelExecutor.UnsignedFieldType - Enum Class in io.confluent.kafka.schemaregistry.rules.cel: How a protobuf unsigned integer field is presented to CEL by CelFieldExecutor, selected by CelExecutor.CEL_UNSIGNED_FIELD_TYPE.
CelFieldExecutor - Class in io.confluent.kafka.schemaregistry.rules.cel
CelFieldExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor
CelTypeLabels - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin: Canonical CEL type-name labels for the extended types (Decimal, Timestamp, Variant) plus their Java cel-java type decls.
CelUtils - Class in io.confluent.kafka.schemaregistry.rules.cel: Shared CEL helpers used by both the transform-path executor (CelExecutor) and the validation-path executor (CelValidator).
CelUtils.CompiledRule - Class in io.confluent.kafka.schemaregistry.rules.cel: Compiled rule output: the runnable CelRuntime.Program plus the compile-time result-type CelKind.
CelUtils.RegexEngine - Enum Class in io.confluent.kafka.schemaregistry.rules.cel: Regex engine used by the CEL matches / matches_string overloads.
CelUtils.ScriptType - Enum Class in io.confluent.kafka.schemaregistry.rules.cel
CelValidator - Class in io.confluent.kafka.schemaregistry.rules.cel: Validation-rule executor backed by CEL.
CelValidator() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelValidator
CelValidator(int) - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelValidator
compareTo(CelDecimal) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal
configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor
configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
convert(Object, Descriptors.Descriptor) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.protobuf.ProtobufResultWriter: Converts result against descriptor.
convert(Object, Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroResultWriter: Convert celValue into the Avro shape required by schema.
create() - Static method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinDeclarations: Function declarations for the extension family the schema-rules CEL surface exposes: the seven string-validation members (isEmail, isHostname, isIpv4, isIpv6, isUri, isUriRef, isUuid), the Decimal / Timestamp / Variant function families.

D

DECIMAL - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels: Java cel-java type declaration for CelTypeLabels.DECIMAL_NAME.
DECIMAL_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels: CEL type label for confluent.type.Decimal.
DECIMAL_TYPE_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.protobuf.ProtobufResultWriter
DEFAULT - Static variable in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType: The mode when none is declared.
DEFAULT - Static variable in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine: The default engine when none is configured.

E

engine() - Static method in class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern: Factory for use with Expressions.parse/Expression.jsonata, e.g.
equals(Object) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal: Numeric, scale-insensitive — the same answer decimals.eq gives.
evaluate(RuleContext, String, CelExecutor.Bindings) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: Look up (or compile) the program for rule and run it against the pre-converted args in b.
evaluateWithGuard(RuleContext, CelExecutor.Bindings) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: Apply the optional guard (everything before the first ; in the rule expression) and then evaluate the body.
execute(RuleContext, Object, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor: Entry point used by CelFieldExecutor and any subclass that wants the full guard-then-body flow.
execute(ValidationRule, Object, Object) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelValidator

F

findAll(String) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern
findCelType(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Infer the CelType for a runtime value.
findCelTypeForAvroSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Map an Avro Schema to a CelType.
findCelTypeForClass(Class<?>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Map a Java Class to a CelType.
findCelTypeForProtobufField(Descriptors.FieldDescriptor) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Map a protobuf field's declared type to a CelType.
findFirst(String, int) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern
findType(String) - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider
forSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider: Build a provider that registers all record schemas reachable from root.
fromString(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType
fromString(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

H

hasAnyType() - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider: Returns true iff there's at least one record we can describe.
hashCode() - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal

I

INT - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType
io.confluent.kafka.schemaregistry.rules.cel - package io.confluent.kafka.schemaregistry.rules.cel
io.confluent.kafka.schemaregistry.rules.cel.avro - package io.confluent.kafka.schemaregistry.rules.cel.avro
io.confluent.kafka.schemaregistry.rules.cel.builtin - package io.confluent.kafka.schemaregistry.rules.cel.builtin
io.confluent.kafka.schemaregistry.rules.cel.protobuf - package io.confluent.kafka.schemaregistry.rules.cel.protobuf
io.confluent.kafka.schemaregistry.rules.jsonata - package io.confluent.kafka.schemaregistry.rules.jsonata

J

JSON - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType
JSONATA_MAX_DEPTH - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
JSONATA_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
JsonataExecutor - Class in io.confluent.kafka.schemaregistry.rules.jsonata
JsonataExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

M

MAX_DEPTH - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor: Deprecated.

N

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

O

obj() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings
of(BigDecimal) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal
ofUnscaled(byte[], int) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal: From unscaled two's-complement big-endian bytes plus a scale — the encoding an Avro decimal logical type and a confluent.type.Decimal message both use.
overriddenStandardFunctions() - Static method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary: The standard functions this library takes over, which the caller must exclude from the runtime's standard functions.

P

PCRE - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine
program - Variable in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.CompiledRule
PROTOBUF - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType
ProtobufResultWriter - Class in io.confluent.kafka.schemaregistry.rules.cel.protobuf: Re-shapes a CEL result so that Jackson renders it as protobuf JSON, the counterpart of AvroResultWriter on the Avro path.

R

RE2 - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine
RE2RegexPattern - Class in io.confluent.kafka.schemaregistry.rules.jsonata: A JSONata regex engine implementation backed by Google's RE2/J
RE2RegexPattern(String, RegexFlags) - Constructor for class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern
resultKind - Variable in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.CompiledRule

S

setCheckerOptions(CelCheckerBuilder) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary
setRuntimeOptions(CelRuntimeBuilder) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary: Plain-CelRuntimeLibrary entry point.
setRuntimeOptions(CelRuntimeBuilder, RuntimeEquality, CelOptions) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary
split(String) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern

T

test(String) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.RE2RegexPattern
TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor: Deprecated.
TIMESTAMP_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels: CEL type label for google.protobuf.Timestamp (= CEL built-in timestamp).
TIMESTAMP_TYPE_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.protobuf.ProtobufResultWriter
toCelUnsigned(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: The value as CEL wants an unsigned integer: an UnsignedLong, which is what cel-java's uint overloads dispatch on.
toCelValue(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Convert a native value to a CEL-compatible shape: IndexedRecord (covers both GenericRecord and SpecificRecord) → JDK Map (Google cel-java's runtime selects fields on Maps natively) Utf8 / GenericEnumSymbol → String Narrow numeric types (Integer, Short, Byte, Float) widened to CEL's natural widths (long / double) byte[] / ByteString → CelByteString (CEL bytes literals only compare equal to other CelByteStrings) Lists/maps recursively converted Other values (proto Messages, BigDecimal, primitives at correct width, etc.) pass through unchanged.
toCelValue(Object, Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: CelUtils.toCelValue(Object) for a value whose Avro schema is known, so a timestamp logical type can be presented with the unit the schema declares.
toCelValueForJson(Object, ObjectMapper) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: JSON-flavored variant of CelUtils.toCelValue(Object): additionally converts Jackson JsonNode and arbitrary POJOs to maps via the supplied ObjectMapper.
toCelValueForProtobufField(Descriptors.FieldDescriptor, Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: The value a protobuf field should be bound to, in the terms its declared type implies: an unsigned integer as an UnsignedLong, an enum as its number.
toDeclTypes(Map<String, Object>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Build a name→CelType map by inferring each value's type.
toString() - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal
toVarDecls(Map<String, CelType>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Convenience wrapper to construct CelVarDecl list from a name→type map, preserving insertion order.
transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings
type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor
type() - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor
TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor
TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor
types() - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider

U

UINT - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType
unwrapCelDecimals(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils: Recursively replace every CelDecimal in a CEL evaluation result with the BigDecimal it wraps — the logical-type Java rep the result writers, Jackson and the field setters all expect.

V

value() - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelDecimal: The wrapped BigDecimal — the logical-type Java rep.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.UnsignedFieldType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType: Returns an array containing the constants of this enum class, in the order they are declared.
VARIANT - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels: Java cel-java type declaration for CelTypeLabels.VARIANT_NAME.
VARIANT_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels: CEL type label for confluent.type.Variant.
VARIANT_TYPE_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.protobuf.ProtobufResultWriter

A B C D E F H I J M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values