Index

C D G H I J K L M P R S T V
All Classes and Interfaces|All Packages|Serialized Form

C

ch.memobase.kafka.utils - package ch.memobase.kafka.utils

ch.memobase.kafka.utils.errors - package ch.memobase.kafka.utils.errors

ch.memobase.kafka.utils.models - package ch.memobase.kafka.utils.models

ch.memobase.kafka.utils.serdes - package ch.memobase.kafka.utils.serdes

ConfigJoiner<T,U> - Class in ch.memobase.kafka.utils

Helper class to join two KStreams, the first one providing metadata records, the latter a configuration object to be applied on the record at hand.

ConfigJoiner(ImportService, Serde<T>, Serde<U>, Function<byte[], U>) - Constructor for class ch.memobase.kafka.utils.ConfigJoiner

Helper class to join two Kafka streams

D

deserialize(String, byte[]) - Method in class ch.memobase.kafka.utils.serdes.JoinedValuesDeserializer

deserialize(String, byte[]) - Method in class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionDeserializer

deserialize(String, byte[]) - Method in class ch.memobase.kafka.utils.serdes.ValueWithExceptionDeserializer

deserialize(String, byte[]) - Method in class ch.memobase.kafka.utils.serdes.ValueWithKeyDeserializer

deserializer() - Method in class ch.memobase.kafka.utils.serdes.JoinedValuesSerde

deserializer() - Method in class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionSerde

deserializer() - Method in class ch.memobase.kafka.utils.serdes.ValueWithExceptionSerde

deserializer() - Method in class ch.memobase.kafka.utils.serdes.ValueWithKeySerde

G

get() - Method in class ch.memobase.kafka.utils.RecordIdSupplier

getException() - Method in class ch.memobase.kafka.utils.models.ValueWithException

getKey() - Method in class ch.memobase.kafka.utils.models.ValueWithKey

getLeft() - Method in class ch.memobase.kafka.utils.models.JoinedValues

getMessage() - Method in exception class ch.memobase.kafka.utils.errors.KafkaUtilsException

getRight() - Method in class ch.memobase.kafka.utils.models.JoinedValues

getValue() - Method in class ch.memobase.kafka.utils.models.ValueWithException

getValue() - Method in class ch.memobase.kafka.utils.models.ValueWithKey

H

hasException() - Method in class ch.memobase.kafka.utils.models.ValueWithException

hasKey() - Method in class ch.memobase.kafka.utils.models.ValueWithKey

hasLeft() - Method in class ch.memobase.kafka.utils.models.JoinedValues

hasRight() - Method in class ch.memobase.kafka.utils.models.JoinedValues

hasValue() - Method in class ch.memobase.kafka.utils.models.ValueWithException

hasValue() - Method in class ch.memobase.kafka.utils.models.ValueWithKey

I

ImportService - Enum Class in ch.memobase.kafka.utils.models

Represents a specific service in the import process

J

join(KStream<String, T>, KStream<byte[], byte[]>) - Method in class ch.memobase.kafka.utils.ConfigJoiner

Joins Kafka streams

JoinedValues<T,U> - Class in ch.memobase.kafka.utils.models

Helper class to represent two values matched by key.

JoinedValues(T, U) - Constructor for class ch.memobase.kafka.utils.models.JoinedValues

JoinedValuesDeserializer<T,U> - Class in ch.memobase.kafka.utils.serdes

JoinedValuesDeserializer(Deserializer<T>, Deserializer<U>) - Constructor for class ch.memobase.kafka.utils.serdes.JoinedValuesDeserializer

JoinedValuesSerde<T,U> - Class in ch.memobase.kafka.utils.serdes

JoinedValuesSerde(Serde<T>, Serde<U>) - Constructor for class ch.memobase.kafka.utils.serdes.JoinedValuesSerde

JoinedValuesSerializer<T,U> - Class in ch.memobase.kafka.utils.serdes

JoinedValuesSerializer(Serializer<T>, Serializer<U>) - Constructor for class ch.memobase.kafka.utils.serdes.JoinedValuesSerializer

K

KafkaUtilsException - Exception Class in ch.memobase.kafka.utils.errors

KafkaUtilsException(String) - Constructor for exception class ch.memobase.kafka.utils.errors.KafkaUtilsException

KafkaUtilsExceptionDeserializer - Class in ch.memobase.kafka.utils.serdes

KafkaUtilsExceptionDeserializer() - Constructor for class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionDeserializer

KafkaUtilsExceptionSerde - Class in ch.memobase.kafka.utils.serdes

KafkaUtilsExceptionSerde() - Constructor for class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionSerde

KafkaUtilsExceptionSerializer - Class in ch.memobase.kafka.utils.serdes

KafkaUtilsExceptionSerializer() - Constructor for class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionSerializer

L

LocalTransform - Enum constant in enum class ch.memobase.kafka.utils.models.ImportService

M

Mapping - Enum constant in enum class ch.memobase.kafka.utils.models.ImportService

P

PythonTransform - Enum constant in enum class ch.memobase.kafka.utils.models.ImportService

PythonTransformConfig - Enum constant in enum class ch.memobase.kafka.utils.models.ImportService

R

RecordIdSupplier<T> - Class in ch.memobase.kafka.utils

RecordIdSupplier() - Constructor for class ch.memobase.kafka.utils.RecordIdSupplier

S

serialize(String, KafkaUtilsException) - Method in class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionSerializer

serialize(String, JoinedValues<T, U>) - Method in class ch.memobase.kafka.utils.serdes.JoinedValuesSerializer

serialize(String, ValueWithException<T>) - Method in class ch.memobase.kafka.utils.serdes.ValueWithExceptionSerializer

serialize(String, ValueWithKey<T>) - Method in class ch.memobase.kafka.utils.serdes.ValueWithKeySerializer

serializer() - Method in class ch.memobase.kafka.utils.serdes.JoinedValuesSerde

serializer() - Method in class ch.memobase.kafka.utils.serdes.KafkaUtilsExceptionSerde

serializer() - Method in class ch.memobase.kafka.utils.serdes.ValueWithExceptionSerde

serializer() - Method in class ch.memobase.kafka.utils.serdes.ValueWithKeySerde

setException(KafkaUtilsException) - Method in class ch.memobase.kafka.utils.models.ValueWithException

setValue(T) - Method in class ch.memobase.kafka.utils.models.ValueWithException

setValue(T) - Method in class ch.memobase.kafka.utils.models.ValueWithKey

T

Transform - Enum constant in enum class ch.memobase.kafka.utils.models.ImportService

V

valueOf(String) - Static method in enum class ch.memobase.kafka.utils.models.ImportService

Returns the enum constant of this class with the specified name.

values() - Static method in enum class ch.memobase.kafka.utils.models.ImportService

Returns an array containing the constants of this enum class, in the order they are declared.

ValueWithException<T> - Class in ch.memobase.kafka.utils.models

ValueWithException(T) - Constructor for class ch.memobase.kafka.utils.models.ValueWithException

ValueWithException(T, KafkaUtilsException) - Constructor for class ch.memobase.kafka.utils.models.ValueWithException

ValueWithExceptionDeserializer<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithExceptionDeserializer(Deserializer<T>, Deserializer<KafkaUtilsException>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithExceptionDeserializer

ValueWithExceptionSerde<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithExceptionSerde(Serde<T>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithExceptionSerde

ValueWithExceptionSerializer<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithExceptionSerializer(Serializer<T>, Serializer<KafkaUtilsException>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithExceptionSerializer

ValueWithKey<T> - Class in ch.memobase.kafka.utils.models

Helper class used when a message key should replaced with another key without loosing the value of the original key

ValueWithKey(String, T) - Constructor for class ch.memobase.kafka.utils.models.ValueWithKey

ValueWithKeyDeserializer<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithKeyDeserializer(Deserializer<T>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithKeyDeserializer

ValueWithKeySerde<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithKeySerde(Serde<T>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithKeySerde

ValueWithKeySerializer<T> - Class in ch.memobase.kafka.utils.serdes

ValueWithKeySerializer(Serializer<T>) - Constructor for class ch.memobase.kafka.utils.serdes.ValueWithKeySerializer

C D G H I J K L M P R S T V
All Classes and Interfaces|All Packages|Serialized Form