Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
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 <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.noWatermarks()
Returns watermark generation parameters that result in no watermarks
being emitted.
|
WatermarkGenerationParams<T> |
WatermarkGenerationParams.withEmitPolicy(WatermarkEmissionPolicy emitPolicy)
Returns new instance with emit policy replaced with the given argument.
|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn,
DistributedObjLongBiFunction<? super T,?> wrapFn,
DistributedSupplier<WatermarkPolicy> wmPolicy,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns new watermark generation parameters.
|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<T> timestampFn,
DistributedSupplier<WatermarkPolicy> wmPolicy,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns a watermark generation parameters object.
|
Constructor and Description |
---|
WatermarkSourceUtil(WatermarkGenerationParams<? super T> params)
A constructor.
|
Modifier and Type | Method and Description |
---|---|
static <T> StreamSource<T> |
Sources.streamFromProcessorWithWatermarks(String sourceName,
Function<WatermarkGenerationParams<T>,ProcessorMetaSupplier> metaSupplierFn)
Returns an unbounded (event stream) source that will use the supplied
function to create processor meta-suppliers as required by the Core API.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.