View Source Skitter.BIS.StreamSource (Skitter v0.7.1)

Strategy for stream-based source operations.

This strategy can be used to create a source operation. It is designed for operations which generate a stream of data that is to be sent into the workflow.

When the operation is deployed, this strategy will spawn a single worker and call the operations stream callback. This callback should return a stream. Once deployed, the elements of this stream will be emitted by one by one. The strategy ensures these values are shuffled over the available worker nodes.

Operation Properties

• in ports: none
• out ports: a single out port.
• callbacks:
  • stream: Called at deployment time. This callback should return a stream, which will be emitted once the operation has been deployed.