org.infinispan.stream

Class StreamMarshalling

java.lang.Object

org.infinispan.stream.StreamMarshalling

public class StreamMarshalling
extends Object

Static factory class containing methods that will provide marshallable instances for very common use cases. Every instance returned from the various static methods uses the Infinispan marshalling to reduce payload sizes considerably and should be used whenever possible.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamMarshalling.StreamMarshallingExternalizer

Method Summary

Modifier and Type	Method and Description
static Predicate<Object>	alwaysTruePredicate() Predicate taht always returns true irrespective of the value provided
static <K,V> Function<Map.Entry<K,V>,K>	entryToKeyFunction() Provides a function that returns the key of the entry when invoked.
static <K,V> Function<Map.Entry<K,V>,V>	entryToValueFunction() Provides a function that returns the value of the entry when invoked.
static Predicate<Object>	equalityPredicate(Object object) Provides a predicate that returns true when the object is equal.
static <K,V> Function<K,CacheEntry<K,V>>	keyToEntryFunction() Provides a function that given a key will return the CacheEntry that maps to this key.
static Predicate<Object>	nonNullPredicate() Predicate that returns true if the object passed to it is not null.

Methods inherited from class java.lang.Object

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

Method Detail

equalityPredicate

public static Predicate<Object> equalityPredicate(Object object)

Provides a predicate that returns true when the object is equal.

Parameters:

object - the instance to test equality on

Returns:

the predicate

nonNullPredicate

public static Predicate<Object> nonNullPredicate()

Predicate that returns true if the object passed to it is not null.

Returns:

the predicate

alwaysTruePredicate

public static Predicate<Object> alwaysTruePredicate()

Predicate taht always returns true irrespective of the value provided

Returns:

the predicate

entryToKeyFunction

public static <K,V> Function<Map.Entry<K,V>,K> entryToKeyFunction()

Provides a function that returns the key of the entry when invoked.

Type Parameters:

K - key type of the entry

V - value type of the entry

Returns:

a function that when applied to a given entry will return the key

entryToValueFunction

public static <K,V> Function<Map.Entry<K,V>,V> entryToValueFunction()

Provides a function that returns the value of the entry when invoked.

Type Parameters:

K - key type of the entry

V - value type of the entry

Returns:

a function that when applied to a given entry will return the value

keyToEntryFunction

public static <K,V> Function<K,CacheEntry<K,V>> keyToEntryFunction()

Provides a function that given a key will return the CacheEntry that maps to this key. This function only works when used with a CacheStream returned from the desired Cache. The entry will be read from the Cache of which the CacheStream was created from.

Type Parameters:

K - the key type

V - the expected value type of the entry

Returns:

a function that when applied returns the entry for the given key