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.TimestampedStream<T> |
SourceBuilder.TimestampedStream.destroyFn(ConsumerEx<? super C> pDestroyFn) |
SourceBuilder.TimestampedStream<T> |
SourceBuilder.TimestampedStream.distributed(int preferredLocalParallelism) |
<T_NEW> SourceBuilder.TimestampedStream<T_NEW> |
SourceBuilder.TimestampedStream.fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.TimestampedSourceBuffer<T_NEW>> fillBufferFn)
Sets the function that Jet will call whenever it needs more data from
your source.
|
SourceBuilder.TimestampedStream<T> |
SourceBuilder.TimestampedStream.permission(Permission permission) |
static <C> SourceBuilder.TimestampedStream<Void> |
SourceBuilder.timestampedStream(String name,
FunctionEx<? super Processor.Context,? extends C> createFn)
Returns a fluent-API builder with which you can create an unbounded stream source for a Jet pipeline.
|
Modifier and Type | Method and Description |
---|---|
<S> SourceBuilder.FaultTolerant<SourceBuilder.TimestampedStream<T>,S> |
SourceBuilder.TimestampedStream.createSnapshotFn(FunctionEx<? super C,? extends S> createSnapshotFn) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.