Package com.hazelcast.enterprise.jet.cdc

Interface RecordMappingFunction<R>

Type Parameters:
R -
All Superinterfaces:
Function<org.apache.kafka.connect.source.SourceRecord,R>, com.hazelcast.function.FunctionEx<org.apache.kafka.connect.source.SourceRecord,R>, com.hazelcast.security.impl.function.SecuredFunction, Serializable
public interface RecordMappingFunction<R> extends com.hazelcast.function.FunctionEx<org.apache.kafka.connect.source.SourceRecord,R>
Function that maps given SourceRecord to some particular R type.
Since:
5.5

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    init(Properties properties, ClassLoader classLoader)
    Initializes this mapping function

    Methods inherited from interface java.util.function.Function

    andThen, compose

    Methods inherited from interface com.hazelcast.function.FunctionEx

    andThen, apply, applyEx, compose

    Methods inherited from interface com.hazelcast.security.impl.function.SecuredFunction

    permissions

  • Method Details

    • init

      default void init(Properties properties, ClassLoader classLoader)
      Initializes this mapping function