Package org.apache.giraph.function

Package for interfaces representing different functions, that all extends Serializable in order for Kryo to be able to serialize them.

See: Description

Interface Summary

Interface	Description
Consumer<T>	Function: (T) -> void
Function<F,T>	Function: (F) -> T
Notifier<T>	Allows consumer to subscribe to a supplier.
PairConsumer<T1,T2>	Function: (T1, T2) -> void
PairFunction<F1,F2,T>	Function: (F1, F2) -> T
PairPredicate<T1,T2>	Function: (T) -> boolean
Predicate<T>	Function: (T) -> boolean Specialization of com.google.common.base.Predicate, that is also Serializable.
Supplier<T>	Function: () -> T Specialization of com.google.common.base.Supplier, that is also Serializable.
TripleFunction<F1,F2,F3,T>	Function: (F1, F2, F3) -> T

Class Summary

Class	Description
ObjectHolder<T>	Default object holder, intermediary between producers and consumers.
ObjectNotifier<T>	Allows multiple Consumers to be combined into a single Consumer, by having them all subscribe to this object, and then using this object as a group Consumer.
ObjectTransfer<T>	Default object transfer, intermediary between producers and consumers.

Package org.apache.giraph.function Description

Package for interfaces representing different functions, that all extends Serializable in order for Kryo to be able to serialize them. Even when same interface is present in Guava, we do not extend it due to @Nullable annotations adding requirement of handling nulls.