Uses of Interface
com.hazelcast.jet.pipeline.SourceBuilder.SourceBuffer
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.SourceBuffer in com.hazelcast.jet.core.processor
Method parameters in com.hazelcast.jet.core.processor with type arguments of type SourceBuilder.SourceBuffer Modifier and Type Method Description static <C, T, S> ProcessorMetaSupplier
SourceProcessors. convenientSourceP(FunctionEx<? super Processor.Context,? extends C> createFn, BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T>> fillBufferFn, FunctionEx<? super C,? extends S> createSnapshotFn, BiConsumerEx<? super C,? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism, boolean isBatch)
Returns a supplier of processors for a source that the user can create using theSourceBuilder
. -
Uses of SourceBuilder.SourceBuffer in com.hazelcast.jet.pipeline
Subinterfaces of SourceBuilder.SourceBuffer in com.hazelcast.jet.pipeline Modifier and Type Interface Description static interface
SourceBuilder.TimestampedSourceBuffer<T>
The buffer object that thefillBufferFn
gets on each call.Method parameters in com.hazelcast.jet.pipeline with type arguments of type SourceBuilder.SourceBuffer Modifier and Type Method Description <T_NEW> SourceBuilder.Batch<T_NEW>
SourceBuilder.Batch. fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn)
Sets the function that Jet will call whenever it needs more data from your source.<T_NEW> SourceBuilder.Stream<T_NEW>
SourceBuilder.Stream. fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn)