Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
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.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
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 <T> AggregateOperation1<T,LongLongAccumulator,Double> |
AggregateOperations.averagingLong(DistributedToLongFunction<? super T> getLongValueFn)
Returns an aggregate operation that computes the arithmetic mean of the
long values it obtains by applying getLongValueFn to
each item. |
static <T> AggregateOperation1<T,LinTrendAccumulator,Double> |
AggregateOperations.linearTrend(DistributedToLongFunction<T> getXFn,
DistributedToLongFunction<T> getYFn)
Returns an aggregate operation that computes a linear trend on the items.
|
static <T> AggregateOperation1<T,LinTrendAccumulator,Double> |
AggregateOperations.linearTrend(DistributedToLongFunction<T> getXFn,
DistributedToLongFunction<T> getYFn)
Returns an aggregate operation that computes a linear trend on the items.
|
static <T> AggregateOperation1<T,LongAccumulator,Long> |
AggregateOperations.summingLong(DistributedToLongFunction<? super T> getLongValueFn)
Returns an aggregate operation that computes the sum of the
long
values it obtains by applying getLongValueFn to each item. |
Modifier and Type | Method and Description |
---|---|
DistributedToLongFunction<? super T> |
WatermarkGenerationParams.timestampFn()
Returns the function that extracts the timestamp from the event.
|
Modifier and Type | Method and Description |
---|---|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn,
DistributedObjLongBiFunction<? super T,?> wrapFn,
DistributedSupplier<? extends WatermarkPolicy> newWmPolicyFn,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns new watermark generation parameters.
|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn,
DistributedSupplier<? extends WatermarkPolicy> wmPolicy,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns a watermark generation parameters object.
|
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.aggregateToSessionWindowP(long sessionTimeout,
List<DistributedToLongFunction<?>> timestampFns,
List<DistributedFunction<?,? extends K>> keyFns,
AggregateOperation<A,R> aggrOp,
KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)
Returns a supplier of processors for a vertex that aggregates events into
session windows.
|
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). |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedComparator<T> |
DistributedComparator.comparingLong(DistributedToLongFunction<? super T> toKeyFn)
Serializable variant of java.util.Comparator#comparingLong(ToLongFunction) . |
default DistributedComparator<T> |
DistributedComparator.thenComparingLong(DistributedToLongFunction<? super T> toKeyFn)
Serializable variant of java.util.Comparator#thenComparingLong(ToLongFunction) . |
Modifier and Type | Method and Description |
---|---|
StreamStage<T> |
GeneralStage.addTimestamps(DistributedToLongFunction<? super T> timestampFn,
long allowedLag)
Adds a timestamp to each item in the stream using the supplied function
and specifies the allowed amount of disorder between them.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.