Package | Description |
---|---|
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 |
---|---|
SourceBuilder.Stream<T> |
SourceBuilder.Stream.destroyFn(DistributedConsumer<? super S> pDestroyFn) |
SourceBuilder.Stream<T> |
SourceBuilder.Stream.distributed(int preferredLocalParallelism) |
<T_NEW> SourceBuilder.Stream<T_NEW> |
SourceBuilder.Stream.fillBufferFn(DistributedBiConsumer<? super S,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn) |
static <S> SourceBuilder.Stream<Void> |
SourceBuilder.stream(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 Hazelcast, Inc.. All rights reserved.