Interface Transformation<R extends ConnectRecord<R>>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      R apply​(R record)
      Apply transformation to the record and return another record object (which may be record itself) or null, corresponding to a map or filter operation respectively.
      void close()
      Signal that this transformation instance will no longer will be used.
      ConfigDef config()
      Configuration specification for this transformation.
    • Method Detail

      • apply

        R apply​(R record)
        Apply transformation to the record and return another record object (which may be record itself) or null, corresponding to a map or filter operation respectively. A transformation must not mutate objects reachable from the given record (including, but not limited to, Headers, Structs, Lists, and Maps). If such objects need to be changed, a new ConnectRecord should be created and returned. The implementation must be thread-safe.
      • config

        ConfigDef config()
        Configuration specification for this transformation.
      • close

        void close()
        Signal that this transformation instance will no longer will be used.
        Specified by:
        close in interface AutoCloseable
        Specified by:
        close in interface Closeable