## Uses of Class
com.hazelcast.jet.pipeline.SourceBuilder.TimestampedStream

- Packages that use SourceBuilder.TimestampedStream
  Package | Description
  --- | ---
  com.hazelcast.jet.pipeline | 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

    Methods in com.hazelcast.jet.pipeline that return SourceBuilder.TimestampedStream
    Modifier and Type | Method and Description
    --- | ---
    `SourceBuilder.TimestampedStream<T>` | SourceBuilder.TimestampedStream.`allowedLateness(long allowedLateness)` Sets the limit on the amount of disorder (skew) present in the timestamps of the events this source will emit.
    `SourceBuilder.TimestampedStream<T>` | SourceBuilder.TimestampedStream.`destroyFn(DistributedConsumer<? super S> pDestroyFn)`
    `SourceBuilder.TimestampedStream<T>` | SourceBuilder.TimestampedStream.`distributed(int preferredLocalParallelism)`
    `<T_NEW> SourceBuilder.TimestampedStream<T_NEW>` | SourceBuilder.TimestampedStream.`fillBufferFn(DistributedBiConsumer<? super S,? super SourceBuilder.TimestampedSourceBuffer<T_NEW>> fillBufferFn)` Sets the function that Jet will call whenever it needs more data from your source.
    `static <S> SourceBuilder.TimestampedStream<Void>` | SourceBuilder.`timestampedStream(String name, DistributedFunction<? super Processor.Context,? extends S> createFn)` Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.

Copyright © 2018. All rights reserved.