Package io.confluent.kafka.schemaregistry.encryption

Class FieldEncryptionExecutor.FieldEncryptionExecutorTransform

java.lang.Object

io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor.FieldEncryptionExecutorTransform

All Implemented Interfaces:

FieldTransform, AutoCloseable

Enclosing class:

FieldEncryptionExecutor

public class FieldEncryptionExecutor.FieldEncryptionExecutorTransform
extends Object
implements FieldTransform

Constructor Summary

Constructors

Constructor	Description
FieldEncryptionExecutorTransform()

Method Summary

Modifier and Type	Method	Description
void	init(RuleContext ctx)
Object	transform(RuleContext ctx, RuleContext.FieldContext fieldCtx, Object fieldValue)

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.FieldTransform

close

Constructor Details

FieldEncryptionExecutorTransform

public FieldEncryptionExecutorTransform()

Method Details

init

public void init(RuleContext ctx)
          throws RuleException

Specified by:

init in interface FieldTransform

Throws:

RuleException

transform

public Object transform(RuleContext ctx,
 RuleContext.FieldContext fieldCtx,
 Object fieldValue)
                 throws RuleException

Specified by:

transform in interface FieldTransform

Throws:

RuleException