Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Apache Kafka reader/writer support for Hazelcast Jet.
|
Modifier and Type | Method and Description |
---|---|
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.emitByFrame(WindowDefinition wDef)
Returns a watermark emission policy that ensures that the value of
the emitted watermark belongs to a frame higher than the previous
watermark's frame, as per the supplied
WindowDefinition . |
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.emitByMinStep(long minStep)
Returns a watermark emission policy that ensures that each emitted
watermark's value is at least
minStep more than the previous
one. |
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.suppressDuplicates()
Returns a policy that ensures that each emitted watermark has a higher
timestamp than the last one.
|
Modifier and Type | Method and Description |
---|---|
static <T> DistributedSupplier<Processor> |
Processors.insertWatermarksP(DistributedToLongFunction<T> getTimestampF,
DistributedSupplier<WatermarkPolicy> newWmPolicyF,
WatermarkEmissionPolicy wmEmitPolicy)
Returns a supplier of processors for a vertex that inserts
watermark items into the stream. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.