## Uses of Interface
com.hazelcast.jet.function.ToLongFunctionEx

- Packages that use ToLongFunctionEx
  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.

- - ### 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.function

    Methods in com.hazelcast.jet.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.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.

Copyright © 2019. All rights reserved.