Package org.apache.flink.api.common.functions

Class RichReduceFunction<T>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichReduceFunction<T>

Type Parameters:

T - Type of the elements that this function processes.

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.ReduceFunction<T>, RichFunction

@Public
public abstract class RichReduceFunction<T>
extends AbstractRichFunction
implements org.apache.flink.api.common.functions.ReduceFunction<T>

Rich variant of the ReduceFunction. As a RichFunction, it gives access to the RuntimeContext and provides setup and teardown methods: RichFunction.open(OpenContext) and RichFunction.close().

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RichReduceFunction()

Method Summary

Modifier and Type	Method	Description
abstract T	reduce(T value1, T value2)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

open

Constructor Detail

RichReduceFunction

public RichReduceFunction()

Method Detail

reduce

public abstract T reduce(T value1,
                         T value2)
                  throws Exception

Specified by:

reduce in interface org.apache.flink.api.common.functions.ReduceFunction<T>

Throws:

Exception