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 SlidingWindowPolicy |
SlidingWindowPolicy.slidingWinPolicy(long windowSize,
long slideBy)
Returns the definition of a sliding window of length
windowSize that slides by slideBy . |
SlidingWindowPolicy |
SlidingWindowPolicy.toTumblingByFrame()
Converts this definition to one defining a tumbling window of the
same length as this definition's frame.
|
static SlidingWindowPolicy |
SlidingWindowPolicy.tumblingWinPolicy(long windowSize)
Returns the definition of a tumbling window of length
windowSize . |
SlidingWindowPolicy |
SlidingWindowPolicy.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(SlidingWindowPolicy 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 <K,A> DistributedSupplier<Processor> |
Processors.accumulateByFrameP(List<DistributedFunction<?,? extends K>> keyFns,
List<DistributedToLongFunction<?>> timestampFns,
TimestampKind timestampKind,
SlidingWindowPolicy winPolicy,
AggregateOperation<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 <K,A,R,OUT> |
Processors.aggregateToSlidingWindowP(List<DistributedFunction<?,? extends K>> keyFns,
List<DistributedToLongFunction<?>> timestampFns,
TimestampKind timestampKind,
SlidingWindowPolicy winPolicy,
AggregateOperation<A,R> aggrOp,
KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)
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,OUT> |
Processors.combineToSlidingWindowP(SlidingWindowPolicy winPolicy,
AggregateOperation<A,R> aggrOp,
KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)
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). |
Modifier and Type | Method and Description |
---|---|
SlidingWindowPolicy |
SlidingWindowDef.toSlidingWindowPolicy()
Returns the policy object used by the Core API processors to drive the
sliding window logic.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.