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 <S,T> ProcessorMetaSupplier |
SourceProcessors.convenientSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn,
DistributedBiConsumer<? super S,? super SourceBuilder.SourceBuffer<T>> fillBufferFn,
DistributedConsumer<? super S> destroyFn,
int preferredLocalParallelism)
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(DistributedBiConsumer<? super S,? 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(DistributedBiConsumer<? super S,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn) |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.