Uses of Interface
com.hazelcast.jet.pipeline.StreamSourceStage

Packages that use StreamSourceStage

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of StreamSourceStage in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return StreamSourceStage

Modifier and Type	Method and Description
<T> StreamSourceStage<T>	Pipeline.readFrom(StreamSource<? extends T> source) Returns a pipeline stage that represents an unbounded data source (i.e., an event stream).