com.hazelcast.jet

Class KeyExtractors

java.lang.Object

com.hazelcast.jet.KeyExtractors

public final class KeyExtractors
extends Object

Factory methods for several common key extractor functions, to be used in Edge.partitioned(...) calls.

Method Summary

Modifier and Type	Method and Description
static <K> Distributed.Function<Map.Entry<K,?>,K>	entryKey() Extractor that returns the key of a Map.Entry.
static <T> Distributed.Function<T,T>	wholeItem() Transparent key extractor: returns its argument.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

wholeItem

public static <T> Distributed.Function<T,T> wholeItem()

Transparent key extractor: returns its argument.

entryKey

public static <K> Distributed.Function<Map.Entry<K,?>,K> entryKey()

Extractor that returns the key of a Map.Entry.

Type Parameters:

K - type of entry's key