## Uses of Interface
com.hazelcast.jet.pipeline.SourceBuilder.TimestampedSourceBuffer

- Packages that use SourceBuilder.TimestampedSourceBuffer
  Package | Description
  --- | ---
  com.hazelcast.jet.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

- - ### Uses of SourceBuilder.TimestampedSourceBuffer in com.hazelcast.jet.core.processor

    Method parameters in com.hazelcast.jet.core.processor with type arguments of type SourceBuilder.TimestampedSourceBuffer
    Modifier and Type | Method and Description
    --- | ---
    `static <S,T> ProcessorMetaSupplier` | SourceProcessors.`convenientTimestampedSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn, DistributedBiConsumer<? super S,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn, WatermarkGenerationParams<? super com.hazelcast.jet.impl.JetEvent<T>> wmParams, DistributedConsumer<? super S> destroyFn, int preferredLocalParallelism)` Returns a supplier of processors for a source that the user can create using the `SourceBuilder`.

  - ### Uses of SourceBuilder.TimestampedSourceBuffer in com.hazelcast.jet.pipeline

    Method parameters in com.hazelcast.jet.pipeline with type arguments of type SourceBuilder.TimestampedSourceBuffer
    Modifier and Type | Method and Description
    --- | ---
    `<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.

Copyright © 2018. All rights reserved.