Uses of Class
com.hazelcast.jet.core.TimestampKind
Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
-
Uses of TimestampKind in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return TimestampKind Modifier and Type Method Description static TimestampKind
TimestampKind. valueOf(String name)
Returns the enum constant of this type with the specified name.static TimestampKind[]
TimestampKind. values()
Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of TimestampKind in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type TimestampKind Modifier and Type Method Description static <K, A> SupplierEx<Processor>
Processors. accumulateByFrameP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> 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 theclass Javadoc
for an explanation of aggregation stages).static <K, A, R, OUT>
SupplierEx<Processor>Processors. aggregateToSlidingWindowP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, long earlyResultsPeriod, AggregateOperation<A,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn)
Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see theclass Javadoc
for an explanation of aggregation stages).