Uses of Interface
com.hazelcast.function.ToLongFunctionEx

Packages that use 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 its several 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 and Description
static <T> ComparatorEx<T>	ComparatorEx.comparingLong(ToLongFunctionEx<? super T> toKeyFn) Serializable variant of java.util.Comparator#comparingLong(ToLongFunction).
default ComparatorEx<T>	ComparatorEx.thenComparingLong(ToLongFunctionEx<? super T> toKeyFn) Serializable variant of java.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 and 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,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 the long values it obtains by applying getLongValueFn to each item.

Uses of ToLongFunctionEx in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core that return ToLongFunctionEx

Modifier and Type	Method and 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 and Description
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.
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.

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 and 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 and 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 the class Javadoc for an explanation of aggregation stages).
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.
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 the class Javadoc for an explanation of aggregation stages).

Uses of ToLongFunctionEx in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline with parameters of type ToLongFunctionEx

Modifier and Type	Method and 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.