Package io.debezium.transforms.scripting

Class WasmEngine

java.lang.Object
io.debezium.transforms.scripting.WasmEngine
All Implemented Interfaces:
Engine
public class WasmEngine extends Object implements Engine
An implementation of the expression language evaluator based on Chicory.

  • Field Details

    • compiler

      private boolean compiler

    • expression

      private String expression

    • engine

      private ChicoryEngine engine

  • Constructor Details

    • WasmEngine

      public WasmEngine()

  • Method Details

    • configure

      public void configure(String language, String expression)
      Description copied from interface: Engine
      Pre-compiles the expression for repeated execution. The method is called once upon the engine initialization.
      Specified by:
      configure in interface Engine
      Parameters:
      expression -

    • getBindings

      protected Map<String,Object> getBindings(org.apache.kafka.connect.connector.ConnectRecord<?> record)

    • key

      protected Object key(org.apache.kafka.connect.connector.ConnectRecord<?> record)

    • value

      protected Object value(org.apache.kafka.connect.connector.ConnectRecord<?> record)

    • header

      protected RecordHeader header(org.apache.kafka.connect.header.Header header)

    • headers

      protected Object headers(org.apache.kafka.connect.connector.ConnectRecord<?> record)

    • doHeaders

      protected Map<String,RecordHeader> doHeaders(org.apache.kafka.connect.connector.ConnectRecord<?> record)

    • eval

      public <T> T eval(org.apache.kafka.connect.connector.ConnectRecord<?> record, Class<T> type)
      Description copied from interface: Engine
      Calculate a value out of the record.
      Specified by:
      eval in interface Engine
      Parameters:
      record - to be used
      Returns:
      result of calculation