Type Members

1.  class BasicContextInitializer[Raw] extends ContextInitializer[Raw]

   Basic implementation of context initializer.

   Basic implementation of context initializer. Used when raw event produced by source does not need further transformations and should be assigned to default "input" variable directly.

   Raw

   - type of raw event that is generated by source (KafkaDeserializationSchema for kafka) in source function.

2.  class BasicContextInitializingFunction[Raw] extends ContextInitializingFunction[Raw]

   Initialize context of variables based on "input" variable represents the event.

   Initialize context of variables based on "input" variable represents the event.

   Raw

   - type of raw event that is generated by source (KafkaDeserializationSchema for kafka) in source function.

3.  sealed trait ComponentUseCase extends AnyRef

   Specifies the mode a node is used/invoked.

   Specifies the mode a node is used/invoked. It can be one of the following values:

   • EngineRuntime - component is invoked in real engine, eg. Flink.
   • TestRuntime - component is invoked in test mode to collect results for test data. Can be used to stub real implementation.
   • Validation - used when compiling and validating nodes by Designer. Components should not be invoked in this mode.
   • ServiceQuery - used when component (Service) is invoked by Designer in ServiceQuery.
   • TestDataGeneration - used when compiling, but only for purpose of generating test data. Components should not be invoked in this mode.
4.  trait ContextInitializer[Raw] extends Serializable

   ContextInitializer provides implementation of transformation from raw event generated by source to Context.

   ContextInitializer provides implementation of transformation from raw event generated by source to Context.

   Raw

   - type of raw event that is generated by source (KafkaDeserializationSchema for kafka) in source function.

5.  trait ContextInitializingFunction[Raw] extends (Raw) => Context
6.  final case class ProcessObjectDependencies extends Serializable with Product
7.  trait Sink extends AnyRef
8.  trait SinkFactory extends Serializable with Component with AllProcessingModesComponent

   pl.touk.nussknacker.engine.api.process.SinkFactory has to have method annotated with pl.touk.nussknacker.engine.api.MethodToInvoke that returns pl.touk.nussknacker.engine.api.process.Sink

   pl.touk.nussknacker.engine.api.process.SinkFactory has to have method annotated with pl.touk.nussknacker.engine.api.MethodToInvoke that returns pl.touk.nussknacker.engine.api.process.Sink

   IMPORTANT lifecycle notice: Implementations of this class *must not* allocate resources (connections, file handles etc.)

   To make implementation easier, by default, sink factory handle all processing modes. If you have some processing mode specific component, you should override allowedProcessingModes method

9.  trait Source extends AnyRef

   Common trait for source of events.

   Common trait for source of events. For Flink see pl.touk.nussknacker.engine.flink.api.process.FlinkSource

10.  trait SourceFactory extends Serializable with Component

    pl.touk.nussknacker.engine.api.process.SourceFactory has to have method annotated with pl.touk.nussknacker.engine.api.MethodToInvoke that returns pl.touk.nussknacker.engine.api.process.Source IMPORTANT lifecycle notice: Implementations of this class *must not* allocate resources (connections, file handles etc.)

11.  trait SourceTestSupport[+T] extends AnyRef

    Support for test source functionality.

    Support for test source functionality. Uses pl.touk.nussknacker.engine.api.test.TestRecordParser to define how test record is parsed and provided to the source.

    T

    - type of object that is passed to Source in tests. Please note that depending on engine it may be different from actual event type produced by source. See e.g. difference between FlinkKafkaSource and LiteKafkaSourceImpl which is due to the difference between implementation of test sources

12.  trait TestDataGenerator extends AnyRef

    Optional support for test source functionality.

    Optional support for test source functionality. Defines how test data should be prepared, in a way that is recognized further by pl.touk.nussknacker.engine.api.test.TestRecordParser.

13.  trait TestWithParametersSupport[+T] extends AnyRef

    Optional functionality which should provide field definitions based on input schema Based on those fields UI creates a window allowing user to test scenario based on schema.

14.  sealed trait TopicName extends AnyRef