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.
|
Modifier and Type | Method and 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,
Permission permission)
Returns a supplier of processors for a source that the user can create
using the
SourceBuilder . |
Modifier and Type | Interface and Description |
---|---|
static interface |
SourceBuilder.TimestampedSourceBuffer<T>
The buffer object that the
fillBufferFn gets on each call. |
Modifier and Type | Method and 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) |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.