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.processor |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.function |
Serializable variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static <T> AggregateOperation1<T,LongLongAccumulator,Double> |
AggregateOperations.averagingLong(DistributedToLongFunction<T> getLongValueFn)
Returns an operation that calculates the arithmetic mean of
long
values returned by the getLongValueFn function. |
static <T> AggregateOperation1<T,LinTrendAccumulator,Double> |
AggregateOperations.linearTrend(DistributedToLongFunction<T> getXFn,
DistributedToLongFunction<T> getYFn)
Returns an operation that computes a linear trend on the items in the
window.
|
static <T> AggregateOperation1<T,LinTrendAccumulator,Double> |
AggregateOperations.linearTrend(DistributedToLongFunction<T> getXFn,
DistributedToLongFunction<T> getYFn)
Returns an operation that computes a linear trend on the items in the
window.
|
static <T> AggregateOperation1<T,LongAccumulator,Long> |
AggregateOperations.summingLong(DistributedToLongFunction<T> getLongValueFn)
Returns an operation that tracks the sum of the quantity returned by
getLongValueFn applied to each item in the window. |
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.aggregateToSessionWindowP(long sessionTimeout,
DistributedToLongFunction<? super T> getTimestampFn,
DistributedFunction<? super T,K> getKeyFn,
AggregateOperation1<? super T,A,R> aggrOp)
Returns a supplier of processors for a vertex that aggregates events into
session windows.
|
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 <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. |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedComparator<T> |
DistributedComparator.comparingLong(DistributedToLongFunction<? super T> keyExtractor) |
default DistributedComparator<T> |
DistributedComparator.thenComparingLong(DistributedToLongFunction<? super T> keyExtractor) |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedCollector<T,?,Double> |
DistributedCollectors.averagingLong(DistributedToLongFunction<? super T> mapper)
Returns a
DistributedCollector that produces the arithmetic mean of a long-valued
function applied to the input elements. |
default DistributedLongStream |
DistributedStream.mapToLong(DistributedToLongFunction<? super T> mapper)
Returns a
DistributedLongStream consisting of the results of applying the
given function to the elements of this stream. |
static <T> DistributedCollector<T,?,LongSummaryStatistics> |
DistributedCollectors.summarizingLong(DistributedToLongFunction<? super T> mapper)
Returns a
DistributedCollector which applies an long -producing
mapping function to each input element, and returns summary statistics
for the resulting values. |
static <T> DistributedCollector<T,?,Long> |
DistributedCollectors.summingLong(DistributedToLongFunction<? super T> mapper)
Returns a
DistributedCollector that produces the sum of a long-valued
function applied to the input elements. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.