Packages

package serialization

Type Members

  1. trait KafkaSchemaBasedDeserializationSchemaFactory extends Serializable

    Factory class for Flink's KeyedDeserializationSchema.

    Factory class for Flink's KeyedDeserializationSchema. It is extracted for purpose when for creation of KeyedDeserializationSchema are needed additional avro related information.

  2. abstract class KafkaSchemaBasedKeyValueDeserializationSchemaFactory extends KafkaSchemaBasedDeserializationSchemaFactory

    Abstract base implementation of KafkaSchemaBasedDeserializationSchemaFactory which uses Kafka's Deserializer in returned Flink's KeyedDeserializationSchema.

    Abstract base implementation of KafkaSchemaBasedDeserializationSchemaFactory which uses Kafka's Deserializer in returned Flink's KeyedDeserializationSchema. It deserializes both key and value and wrap it in ConsumerRecord object (transforms raw event represented as ConsumerRecord from Array[Byte] domain to Key-Value-type domain).

  3. abstract class KafkaSchemaBasedKeyValueSerializationSchemaFactory extends KafkaSchemaBasedSerializationSchemaFactory

    Abstract base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaSerializationSchemaFactory which uses Kafka's Serializer in returned Flink's KafkaSerializationSchema for both key and value.

  4. trait KafkaSchemaBasedSerializationSchemaFactory extends Serializable

    Factory class for Flink's KeyedSerializationSchema.

    Factory class for Flink's KeyedSerializationSchema. It is extracted for purpose when for creation of KafkaSerializationSchema are needed additional avro related information. SerializationSchema will take KafkaSerializationSchema with key extracted in the step before serialization

  5. abstract class KafkaSchemaBasedValueSerializationSchemaFactory extends KafkaSchemaBasedSerializationSchemaFactory

    Abstract base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaSerializationSchemaFactory which uses Kafka's Serializer in returned Flink's KafkaSerializationSchema for value - key will be taken from step before serialization

Ungrouped