com.hazelcast.jet.pipeline

Interface StreamSource<T>

Type Parameters:

T - the stream item type

public interface StreamSource<T>

Represents an infinite source of data for a Jet pipeline. To aggregate the data from an infinite source, you must specify how to window it into finite subsets over which Jet will perform the aggregation.

See Also:

source factory methods

Method Summary

Modifier and Type	Method and Description
String	name() Returns a descriptive name of this source.

Method Detail

name

@Nonnull
String name()

Returns a descriptive name of this source.