T → EndpointSink Operator for Typed Stream Processing
Sends a pipeline value to an external endpoint.
When to use
Use Sink to terminate a branch or call another service. valueType describes the response fed back into a symmetric request/response pipeline.
Behavior
- Consumes the source message and invokes the endpoint adapter.
- May produce a response value and a transport Error stream.
- Multiple Sink streams may use the same logical endpoint, with a separate runtime consumer for each Sink. Keep callers in independent pipelines as separate Sink nodes; the endpoint and its physical transport are reused.
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.
RequiredendpointEndpointExternal entry or exit point used by Input or Sink.
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:UnknownTypeExecution 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.
Position 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: Sink
source: mappedOrder
endpoint: publishOrders
valueType: PublishResult