Package io.confluent.kafka.schemaregistry.rules.cel

Class CelExecutor

java.lang.Object

io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

All Implemented Interfaces:

RuleBase, RuleExecutor, AutoCloseable, org.apache.kafka.common.Configurable

public class CelExecutor
extends Object
implements RuleExecutor

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CEL_IGNORE_GUARD_SEPARATOR
static final String	TYPE

Fields inherited from interface io.confluent.kafka.schemaregistry.rules.RuleBase

DEFAULT_NAME

Constructor Summary

Constructors

Constructor	Description
CelExecutor()

Method Summary

Modifier and Type	Method	Description
protected Object	execute(RuleContext ctx, Object obj, Map<String,Object> args)
Object	transform(RuleContext ctx, Object message)
String	type()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.kafka.schemaregistry.rules.RuleBase

addOriginalConfigs, close, configure, setSchemaRegistryClient

Field Details

TYPE

public static final String TYPE

See Also:

• Constant Field Values

CEL_IGNORE_GUARD_SEPARATOR

public static final String CEL_IGNORE_GUARD_SEPARATOR

See Also:

• Constant Field Values

Constructor Details

CelExecutor

public CelExecutor()

Method Details

type

public String type()

Specified by:

type in interface RuleBase

transform

public Object transform(RuleContext ctx,
 Object message)
                 throws RuleException

Specified by:

transform in interface RuleExecutor

Throws:

RuleException

execute

protected Object execute(RuleContext ctx,
 Object obj,
 Map<String,Object> args)
                  throws RuleException

Throws:

RuleException