Packages

abstract class KafkaUniversalComponentTransformer[T, TN <: TopicName] extends SingleInputDynamicComponent[T] with WithCachedTopicsExistenceValidator

Self Type
KafkaUniversalComponentTransformer[T, TN] with Component
Linear Supertypes
WithCachedTopicsExistenceValidator, TopicsExistenceValidator, SingleInputDynamicComponent[T], DynamicComponent[T], Component, Serializable, AnyRef, Any
Known Subclasses
UniversalKafkaSinkFactory, UniversalKafkaSourceFactory, DelayedUniversalKafkaSourceFactory
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaUniversalComponentTransformer
  2. WithCachedTopicsExistenceValidator
  3. TopicsExistenceValidator
  4. SingleInputDynamicComponent
  5. DynamicComponent
  6. Component
  7. Serializable
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new KafkaUniversalComponentTransformer()(implicit arg0: TopicValidationType[TN])

Type Members

  1. type ContextTransformationDefinition = PartialFunction[(KafkaUniversalComponentTransformer.this)#TransformationStep, (KafkaUniversalComponentTransformer.this)#TransformationStepResult]
    Definition Classes
    DynamicComponent
  2. type DefinedParameter = DefinedSingleParameter
    Definition Classes
    SingleInputDynamicComponent → DynamicComponent
  3. case class FinalResults extends TransformationStepResult with Product with Serializable
    Definition Classes
    DynamicComponent
  4. type InputContext = ValidationContext
    Definition Classes
    SingleInputDynamicComponent → DynamicComponent
  5. case class NextParameters extends TransformationStepResult with Product with Serializable
    Definition Classes
    DynamicComponent
  6. abstract type State
    Definition Classes
    DynamicComponent
  7. case class TransformationStep extends Product with Serializable
    Definition Classes
    DynamicComponent
  8. sealed trait TransformationStepResult extends AnyRef
    Definition Classes
    DynamicComponent
  9. type WithError[V] = WriterT[Id, List[ProcessCompilationError], V]

Abstract Value Members

  1. abstract def allowedProcessingModes: AllowedProcessingModes
    Definition Classes
    Component
  2. abstract def contextTransformation(context: (KafkaUniversalComponentTransformer.this)#InputContext, dependencies: List[NodeDependencyValue])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#ContextTransformationDefinition
    Definition Classes
    DynamicComponent
  3. abstract def implementation(params: Params, dependencies: List[NodeDependencyValue], finalState: Option[(KafkaUniversalComponentTransformer.this)#State]): T
    Definition Classes
    DynamicComponent
  4. abstract def modelDependencies: ProcessObjectDependencies
  5. abstract def nodeDependencies: List[NodeDependency]
    Definition Classes
    DynamicComponent
  6. abstract def paramsDeterminedAfterSchema: List[Parameter]
  7. abstract def schemaRegistryClientFactory: SchemaRegistryClientFactory
  8. abstract def topicFrom(value: String): TN
    Attributes
    protected

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def extractPreparedTopic(params: Params): PreparedKafkaTopic[TN]
    Attributes
    protected
  9. def fallbackFinalResult(step: (KafkaUniversalComponentTransformer.this)#TransformationStep, inputContext: (KafkaUniversalComponentTransformer.this)#InputContext, outputVariable: Option[String])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#FinalResults
    Attributes
    protected
    Definition Classes
    DynamicComponent
  10. lazy val fallbackVersionOptionParam: ParameterCreatorWithNoDependency with ParameterExtractor[String]
    Attributes
    protected
    Annotations
    @transient()
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  12. def getTopicParam(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#WithError[ParameterCreatorWithNoDependency with ParameterExtractor[String]]
    Attributes
    protected
  13. def getVersionParam(versions: List[Integer]): ParameterCreatorWithNoDependency with ParameterExtractor[String]
    Attributes
    protected
  14. def getVersionParam(preparedTopic: PreparedKafkaTopic[TN])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#WithError[ParameterCreatorWithNoDependency with ParameterExtractor[String]]
    Attributes
    protected
  15. def handleExceptionDuringTransformation(step: (KafkaUniversalComponentTransformer.this)#TransformationStep, inputContext: (KafkaUniversalComponentTransformer.this)#InputContext, outputVariable: Option[String], ex: Throwable)(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#FinalResults
    Definition Classes
    DynamicComponent
  16. def handleUnmatchedTransformationStep(step: (KafkaUniversalComponentTransformer.this)#TransformationStep, inputContext: (KafkaUniversalComponentTransformer.this)#InputContext, outputVariable: Option[String])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#FinalResults
    Definition Classes
    DynamicComponent
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. lazy val kafkaConfig: KafkaConfig
    Attributes
    protected
    Definition Classes
    KafkaUniversalComponentTransformer → WithCachedTopicsExistenceValidator
    Annotations
    @transient()
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  22. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  23. def parseVersionOption(versionOptionName: String): SchemaVersionOption
    Attributes
    protected
  24. final def prepareFinalResultWithOptionalVariable(inputContext: (KafkaUniversalComponentTransformer.this)#InputContext, outputVariable: Option[(String, TypingResult)], state: Option[(KafkaUniversalComponentTransformer.this)#State])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#FinalResults
    Attributes
    protected
    Definition Classes
    DynamicComponent
  25. def prepareKafkaConfig: KafkaConfig
    Attributes
    protected
  26. def prepareKeySchemaDeterminer(preparedTopic: PreparedKafkaTopic[TN]): AvroSchemaDeterminer
    Attributes
    protected
  27. def prepareTopic(topicString: String): PreparedKafkaTopic[TN]
    Attributes
    protected
  28. def prepareUniversalKeySchemaDeterminer(preparedTopic: PreparedKafkaTopic[TN]): ParsedSchemaDeterminer
    Attributes
    protected
  29. def prepareUniversalValueSchemaDeterminer(preparedTopic: PreparedKafkaTopic[TN], version: SchemaVersionOption): ParsedSchemaDeterminer
    Attributes
    protected
  30. def prepareValueSchemaDeterminer(preparedTopic: PreparedKafkaTopic[TN], version: SchemaVersionOption): AvroSchemaDeterminer
    Attributes
    protected
  31. def schemaParamStep(nextParams: List[Parameter])(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#ContextTransformationDefinition
    Attributes
    protected
  32. lazy val schemaRegistryClient: SchemaRegistryClient
    Attributes
    protected
    Annotations
    @transient()
  33. lazy val schemaSupportDispatcher: UniversalSchemaSupportDispatcher
    Attributes
    protected
    Annotations
    @transient()
  34. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  35. def toString(): String
    Definition Classes
    AnyRef → Any
  36. lazy val topicParamName: ParameterName
    Attributes
    protected
    Annotations
    @transient()
  37. def topicParamStep(implicit nodeId: NodeId): (KafkaUniversalComponentTransformer.this)#ContextTransformationDefinition
    Attributes
    protected
  38. def topicSelectionStrategy: TopicSelectionStrategy
    Attributes
    protected
  39. final def validateTopic[T <: TopicName](topic: T)(implicit arg0: TopicValidationType[T]): Validated[TopicExistenceValidationException[T], T]
    Definition Classes
    TopicsExistenceValidator
  40. final def validateTopics[T <: TopicName](topics: NonEmptyList[T])(implicit arg0: TopicValidationType[T]): Validated[TopicExistenceValidationException[T], NonEmptyList[T]]
    Definition Classes
    WithCachedTopicsExistenceValidator → TopicsExistenceValidator
  41. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  42. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  43. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  44. object FinalResults extends Serializable
    Definition Classes
    DynamicComponent

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from WithCachedTopicsExistenceValidator

Inherited from TopicsExistenceValidator

Inherited from SingleInputDynamicComponent[T]

Inherited from DynamicComponent[T]

Inherited from Component

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped