T → 0..N R + EProcess Operator for Typed Stream Processing
Runs stateful or side-effecting business processing with an optional dedicated error path.
When to use
Use Process when Map is too restrictive: the handler may emit zero, one, or multiple results and report typed errors.
Behavior
- Execute invokes the process handler for each admitted value and lets it emit through its result collectors.
- An Error stream can consume the side output when failure changes the business flow; an explicit Error branch is not mandatory for every Process.
General properties
Identity, ownership and operator-specific mode.
typeTransformationTypeOperator kind. It controls available properties, valid sources and generated interfaces.
RequiredAllowed:Input, SubStream, Map, Filter, Join, MultiJoin, Process, FlatMap, FlatMapIterable, KeyBy, Merge, Split, Case, Sink, CycleLink, Error, Delay, WhennamestringHuman-readable stream name shown in the designer and used to derive default generated symbols.
RequiredserviceServiceService that owns the stream. Connected streams must belong to the same service.
RequiredConnections properties
Upstream graph references accepted by this operator.
sourceStreamSingle upstream stream. The designer only offers structurally and type-compatible candidates.
RequiredData Types properties
Message contracts visible at this node.
valueTypeTypeOutput or response message contract. The exact meaning is operator-specific.
RequiredDefault:UnknownTypeFunction properties
Generated business-logic implementation and its placement.
functionNamesymbolGenerated business-logic type or function name.
RequiredfunctionPackagerelative pathOptional placement below the target-language functions root. Leave empty to use that root directly. A value such as folder/sub-folder is relative to the private or public functions root selected by publicFunction; nested-path handling is language-specific and is documented in Code Generation / Packages and Modules.
empty (functions root)publicFunctionbooleanPlaces the generated function in a shared package instead of the service-internal package.
Default:falsefunctionDescriptiontextDocumentation comment emitted with the generated function.
functionInitializerGroupstringDependency-injection initialization group for the generated function.
functionModuleModuleOptional owner of a public function; when absent, the public function remains owned by its service.
Visible when publicFunction is true.Execution properties
Pipeline placement and runtime policy.
pipelinestringNamed business-flow grouping inside the owning service; retained in generated configuration and runtime grouping metadata. It does not create connections.
patternExecuteProcess handler contract. Execute is the only pattern currently exposed by the designer.
ExecuteAllowed: ExecutePosition properties
Designer-only canvas coordinates.
xPosnumberHorizontal designer coordinate. It has no runtime effect; missing positions can be supplied by layout.
yPosnumberVertical designer coordinate. It has no runtime effect; missing positions can be supplied by layout.
Configuration example
type: Process
source: validatedOrder
valueType: SavedOrder
pattern: Execute
functionName: SaveOrder