p

pl.touk.nussknacker.engine

schemedkafka

package schemedkafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class AllTopicsSelectionStrategy extends TopicSelectionStrategy
  2. class AvroDefaultExpressionDeterminer extends AnyRef

  3. trait AvroSchemaDeterminer extends AnyRef
  4. trait KafkaUniversalComponentTransformer[T] extends SingleInputGenericNodeTransformation[T] with WithCachedTopicsExistenceValidator
  5. class LogicalTypesGenericRecordBuilder extends RecordBuilderBase[Record]

    A RecordBuilder for generic records.

    A RecordBuilder for generic records. GenericRecordBuilder fills in default values for fields if they are not specified.

  6. case class RuntimeSchemaData[T <: ParsedSchema](serializableSchema: NkSerializableParsedSchema[T], schemaIdOpt: Option[Int]) extends Product with Serializable

    This class holds data that will be passed to Flink's tasks for records processing in runtime.

    This class holds data that will be passed to Flink's tasks for records processing in runtime.

    serializableSchema

    Serializable Avro schema

    schemaIdOpt

    optional schema id fetched from schema registry - for further optimizations of record processing in runtime

  7. class SchemaDeterminerError extends RuntimeException
  8. class TopicPatternSelectionStrategy extends TopicSelectionStrategy
  9. trait TopicSelectionStrategy extends Serializable

Value Members

  1. object AvroDefaultExpressionDeterminer
  2. object AvroUtils extends LazyLogging
  3. object KafkaUniversalComponentTransformer extends Serializable
  4. object RuntimeSchemaData extends Serializable
  5. object SchemaDeterminerErrorHandler

Ungrouped