io.simplesource.saga.serialization.utils

Class SerdeUtils

java.lang.Object

io.simplesource.saga.serialization.utils.SerdeUtils

public class SerdeUtils
extends Object

A utility class with methods that enable the derivation of a serde from a serde from an another type.

Constructor Summary

Constructors

Constructor and Description
SerdeUtils()

Method Summary

Modifier and Type	Method and Description
static <S,V> org.apache.kafka.common.serialization.Serde<V>	iMap(org.apache.kafka.common.serialization.Serde<S> sSerde, java.util.function.BiFunction<String,V,S> toGeneric, java.util.function.BiFunction<String,S,V> fromGeneric)
static <S,V> org.apache.kafka.common.serialization.Serde<V>	iMap(org.apache.kafka.common.serialization.Serde<S> sSerde, java.util.function.Function<V,S> toGeneric, java.util.function.Function<S,V> fromGeneric)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SerdeUtils

public SerdeUtils()

Method Detail

iMap

public static <S,V> org.apache.kafka.common.serialization.Serde<V> iMap(org.apache.kafka.common.serialization.Serde<S> sSerde,
                                                                        java.util.function.Function<V,S> toGeneric,
                                                                        java.util.function.Function<S,V> fromGeneric)

iMap

public static <S,V> org.apache.kafka.common.serialization.Serde<V> iMap(org.apache.kafka.common.serialization.Serde<S> sSerde,
                                                                        java.util.function.BiFunction<String,V,S> toGeneric,
                                                                        java.util.function.BiFunction<String,S,V> fromGeneric)