Uses of Interface
com.hazelcast.function.ToLongFunctionEx
Package | Description |
---|---|
com.hazelcast.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
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.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of ToLongFunctionEx in com.hazelcast.function
Methods in com.hazelcast.function with parameters of type ToLongFunctionEx Modifier and Type Method Description static <T> ComparatorEx<T>
ComparatorEx. comparingLong(ToLongFunctionEx<? super T> toKeyFn)
Serializable
variant ofjava.util.Comparator#comparingLong(ToLongFunction)
.default ComparatorEx<T>
ComparatorEx. thenComparingLong(ToLongFunctionEx<? super T> toKeyFn)
Serializable
variant ofjava.util.Comparator#thenComparingLong(ToLongFunction)
. -
Uses of ToLongFunctionEx in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate with parameters of type ToLongFunctionEx Modifier and Type Method Description static <T> AggregateOperation1<T,LongLongAccumulator,Double>
AggregateOperations. averagingLong(ToLongFunctionEx<? super T> getLongValueFn)
Returns an aggregate operation that finds the arithmetic mean (aka.static <T> AggregateOperation1<T,LinTrendAccumulator,Double>
AggregateOperations. linearTrend(ToLongFunctionEx<T> getXFn, ToLongFunctionEx<T> getYFn)
Returns an aggregate operation that computes a linear trend over the items.static <T> AggregateOperation1<T,LongAccumulator,Long>
AggregateOperations. summingLong(ToLongFunctionEx<? super T> getLongValueFn)
Returns an aggregate operation that computes the sum of thelong
values it obtains by applyinggetLongValueFn
to each item. -
Uses of ToLongFunctionEx in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return ToLongFunctionEx Modifier and Type Method Description ToLongFunctionEx<? super T>
EventTimePolicy. timestampFn()
Returns the function that extracts the timestamp from the event.Methods in com.hazelcast.jet.core with parameters of type ToLongFunctionEx Modifier and Type Method Description static <T> EventTimePolicy<T>
EventTimePolicy. eventTimePolicy(ToLongFunctionEx<? super T> timestampFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis)
Creates and returns a new event time policy.static <T> EventTimePolicy<T>
EventTimePolicy. eventTimePolicy(ToLongFunctionEx<? super T> timestampFn, ObjLongBiFunction<? super T,?> wrapFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis)
Creates and returns a new event time policy. -
Uses of ToLongFunctionEx in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type ToLongFunctionEx Modifier and Type Method Description static <T, K, S, R> SupplierEx<Processor>
Processors. flatMapStatefulP(long ttl, FunctionEx<? super T,? extends K> keyFn, ToLongFunctionEx<? super T> timestampFn, Supplier<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends Traverser<R>> statefulFlatMapFn, TriFunction<? super S,? super K,? super Long,? extends Traverser<R>> onEvictFn)
Returns a supplier of processors for a vertex that performs a stateful flat-mapping of its input.static <T, K, S, R> SupplierEx<Processor>
Processors. mapStatefulP(long ttl, FunctionEx<? super T,? extends K> keyFn, ToLongFunctionEx<? super T> timestampFn, Supplier<? extends S> createFn, TriFunction<? super S,? super K,? super T,? extends R> statefulMapFn, TriFunction<? super S,? super K,? super Long,? extends R> onEvictFn)
Returns a supplier of processors for a vertex that performs a stateful mapping of its input.Method parameters in com.hazelcast.jet.core.processor with type arguments of type ToLongFunctionEx Modifier and Type Method Description static <K, A, R, OUT>
SupplierEx<Processor>Processors. aggregateToSessionWindowP(long sessionTimeout, long earlyResultsPeriod, List<ToLongFunctionEx<?>> timestampFns, List<FunctionEx<?,? extends K>> keyFns, 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 session windows. -
Uses of ToLongFunctionEx in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline with parameters of type ToLongFunctionEx Modifier and Type Method Description StreamStage<T>
GeneralStage. addTimestamps(ToLongFunctionEx<? 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.StreamStage<T>
StreamSourceStage. withTimestamps(ToLongFunctionEx<? super T> timestampFn, long allowedLag)
Declares that the source will extract timestamps from the stream items.