Class JsonToMapTransform<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>

java.lang.Object
org.apache.iceberg.connect.transforms.JsonToMapTransform<R>
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<R>

public class JsonToMapTransform<R extends org.apache.kafka.connect.connector.ConnectRecord<R>> extends Object implements org.apache.kafka.connect.transforms.Transformation<R>
  • Field Details

    • JSON_LEVEL

      public static final String JSON_LEVEL
      See Also:
    • CONFIG_DEF

      public static final org.apache.kafka.common.config.ConfigDef CONFIG_DEF
  • Constructor Details

    • JsonToMapTransform

      public JsonToMapTransform()
  • Method Details

    • apply

      public R apply(R record)
      Specified by:
      apply in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
    • config

      public org.apache.kafka.common.config.ConfigDef config()
      Specified by:
      config in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.kafka.connect.transforms.Transformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>>
    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable