Uses of Class
com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of SourceBuilder.TimestampedStream in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionSourceBuilder.TimestampedStream.destroyFn
(ConsumerEx<? super C> pDestroyFn) SourceBuilder.TimestampedStream.distributed
(int preferredLocalParallelism) <T_NEW> SourceBuilder<C>.TimestampedStream<T_NEW>
SourceBuilder.TimestampedStream.fillBufferFn
(BiConsumerEx<? super C, ? super SourceBuilder.TimestampedSourceBuffer<T_NEW>> fillBufferFn) Sets the function that Jet will call whenever it needs more data from your source.SourceBuilder.TimestampedStream.permission
(Permission permission) static <C> SourceBuilder<C>.TimestampedStream<Void>
SourceBuilder.timestampedStream
(String name, FunctionEx<? super Processor.Context, ? extends C> createFn) Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.Modifier and TypeMethodDescription<S> SourceBuilder<C>.FaultTolerant<SourceBuilder<C>.TimestampedStream<T>,
S> SourceBuilder.TimestampedStream.createSnapshotFn
(FunctionEx<? super C, ? extends S> createSnapshotFn)