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 DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingLagAndDelay(long lag,
long maxDelayMs)
Maintains watermark that lags behind the top observed timestamp by at
most the given amount and is additionally guaranteed to reach the
timestamp of any given event within
maxDelayMs after observing
it. |
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingLagAndLull(long lag,
long maxLullMs)
Maintains watermark that lags behind the top timestamp by the amount
specified with
lag . |
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingTimestampAndWallClockLag(long timestampLag,
long wallClockLag)
Maintains watermark that lags behind the top timestamp by at most
timestampLag and behind wall-clock time by at most wallClockLag . |
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.withFixedLag(long lag)
Maintains watermark that lags behind the top observed timestamp by the
given amount.
|
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.