package serialization
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
case class
FixedKafkaDeserializationSchemaFactory[T](deserializationSchema: KafkaDeserializationSchema[T]) extends KafkaDeserializationSchemaFactory[T] with Product with Serializable
Base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaDeserializationSchemaFactory Factory which always return the same schema based on Flink's deserialization schema.
Base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaDeserializationSchemaFactory Factory which always return the same schema based on Flink's deserialization schema.
- T
type of deserialized object
- deserializationSchema
schema which will be returned.
-
class
NKKafkaDeserializationSchemaWrapper[T] extends KafkaDeserializationSchemaWrapper[T]
- Annotations
- @SerialVersionUID()
Value Members
- object FixedKafkaDeserializationSchemaFactory extends Serializable
- object FlinkSerializationSchemaConversions extends LazyLogging