io.confluent.kafka.schemaregistry.rules.jsonata

Class JsonataExecutor

java.lang.Object

io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

All Implemented Interfaces:

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

public class JsonataExecutor
extends Object
implements RuleExecutor

Field Summary

Fields

Modifier and Type	Field and Description
static String	JSONATA_MAX_DEPTH
static String	JSONATA_TIMEOUT_MS
static String	MAX_DEPTH Deprecated.
static String	TIMEOUT_MS Deprecated.
static String	TYPE

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

DEFAULT_NAME

Constructor Summary

Constructors

Constructor and Description
JsonataExecutor()

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> configs)
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

Field Detail

TYPE

public static final String TYPE

See Also:

Constant Field Values

JSONATA_TIMEOUT_MS

public static final String JSONATA_TIMEOUT_MS

See Also:

Constant Field Values

JSONATA_MAX_DEPTH

public static final String JSONATA_MAX_DEPTH

See Also:

Constant Field Values

TIMEOUT_MS

@Deprecated
public static final String TIMEOUT_MS

Deprecated.

See Also:

Constant Field Values

MAX_DEPTH

@Deprecated
public static final String MAX_DEPTH

Deprecated.

See Also:

Constant Field Values

Constructor Detail

JsonataExecutor

public JsonataExecutor()

Method Detail

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface RuleBase

Specified by:

configure in interface org.apache.kafka.common.Configurable

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