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 WindowDefinition |
WindowDefinition.slidingWindowDef(long windowLength,
long slideBy)
Returns the definition of a sliding window of length
windowLength that slides by slideBy . |
WindowDefinition |
WindowDefinition.toTumblingByFrame()
Converts this definition to one defining a tumbling window of the
same length as this definition's frame.
|
static WindowDefinition |
WindowDefinition.tumblingWindowDef(long windowLength)
Returns the definition of a tumbling window of length
windowLength . |
WindowDefinition |
WindowDefinition.withOffset(long offset)
Returns a new window definition where all the frames are shifted by the
given offset.
|
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 . |
Modifier and Type | Method and Description |
---|---|
static <T,K,A> DistributedSupplier<Processor> |
Processors.accumulateByFrameP(DistributedFunction<? super T,K> getKeyFn,
DistributedToLongFunction<? super T> getTimestampFn,
TimestampKind timestampKind,
WindowDefinition windowDef,
AggregateOperation1<? super T,A,?> aggrOp)
Returns a supplier of processors for the first-stage vertex in a
two-stage sliding window aggregation setup (see the
class Javadoc for an explanation of aggregation stages). |
static <T,K,A,R> DistributedSupplier<Processor> |
Processors.aggregateToSlidingWindowP(DistributedFunction<? super T,K> getKeyFn,
DistributedToLongFunction<? super T> getTimestampFn,
TimestampKind timestampKind,
WindowDefinition windowDef,
AggregateOperation1<? super T,A,R> aggrOp)
Returns a supplier of processors for a vertex that aggregates events
into a sliding window in a single stage (see the
class Javadoc for an explanation of aggregation stages). |
static <K,A,R> DistributedSupplier<Processor> |
Processors.combineToSlidingWindowP(WindowDefinition windowDef,
AggregateOperation1<?,A,R> aggrOp)
Returns a supplier of processors for the second-stage vertex in a
two-stage sliding window aggregation setup (see the
class Javadoc for an explanation of aggregation stages). |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.