Type Members

1.  class AdditionalVariable extends Annotation with Annotation with ClassfileAnnotation
2.  class AdditionalVariables extends Annotation with Annotation with ClassfileAnnotation
3.  class BranchParamName extends Annotation with Annotation with ClassfileAnnotation
4.  case class Context(id: String, variables: Map[String, Any], parentContext: Option[Context]) extends Product with Serializable

   Context is container for variables used in expression evaluation

   Context is container for variables used in expression evaluation

   id

   correlation id/trace id used for tracing (logs, error presentation) and for tests mechanism, it should be always defined

   variables

   variables available in evaluation

   parentContext

   context used for scopes handling, mainly for subprocess invocation purpose

5.  case class ContextId(value: String) extends Product with Serializable
6.  abstract class CustomStreamTransformer extends Component

   Hook for using Apache Flink API directly.

   Hook for using Apache Flink API directly. See examples in pl.touk.nussknacker.engine.example.custom

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

7.  class DefaultValue extends Annotation with Annotation with ClassfileAnnotation
8.  class Documentation extends Annotation with Annotation with ClassfileAnnotation
9.  abstract class EagerService extends Service
10.  class Hidden extends Annotation with Annotation with ClassfileAnnotation
11.  trait HideToString extends AnyRef

    Implementing this interface results in hiding toString method in code completion

12.  trait LazyParameter[+T <: AnyRef] extends AnyRef

    Lazy parameter is representation of parameter of custom node which should be evaluated for each record: def execute(@ParamName("groupBy") groupBy: LazyParameter[String], @ParamName ("length") length: String) In this case, length is computed as constant during process compilation, while groupBy is evaluated for each event Cannot be evaluated directly (no method like 'evaluate'), as evaluation may need lifecycle handling, to use it see LazyParameterInterpreter

    Lazy parameter is representation of parameter of custom node which should be evaluated for each record: def execute(@ParamName("groupBy") groupBy: LazyParameter[String], @ParamName ("length") length: String) In this case, length is computed as constant during process compilation, while groupBy is evaluated for each event Cannot be evaluated directly (no method like 'evaluate'), as evaluation may need lifecycle handling, to use it see LazyParameterInterpreter

    T

    type of evaluated parameter. It has upper bound AnyRef because currently we don't support correctly extraction of primitive types from generic parameters

13.  trait LazyParameterInterpreter extends AnyRef
14.  trait Lifecycle extends AutoCloseable
15.  class MethodToInvoke extends Annotation with Annotation with ClassfileAnnotation
16.  class OutputVariableName extends Annotation with Annotation with ClassfileAnnotation
17.  class ParamName extends Annotation with Annotation with ClassfileAnnotation
18.  class QueryableStateNames extends Annotation with Annotation with ClassfileAnnotation
19.  abstract class Service extends Lifecycle with Component

    Interface of Enricher/Processor.

    Interface of Enricher/Processor. It has to have one method annotated with pl.touk.nussknacker.engine.api.MethodToInvoke. This method is called for every service invocation.

    This could be scala-trait, but we leave it as abstract class for now for java compatibility.

    TODO We should consider separate interfaces for java implementation, but right now we convert ProcessConfigCreator from java to scala one and is seems difficult to convert java CustomStreamTransformer, Service etc. into scala ones

    IMPORTANT lifecycle notice: Implementations of this class *must not* allocate resources (connections, file handles etc.) unless open() *or* appropriate @MethodToInvoke is called

20.  trait ServiceInvoker extends AnyRef
21.  case class ValueWithContext[T](value: T, context: Context) extends Product with Serializable