org.apache.flink.runtime.taskexecutor.rpc

Class RpcGlobalAggregateManager

java.lang.Object

org.apache.flink.runtime.taskexecutor.rpc.RpcGlobalAggregateManager

All Implemented Interfaces:

GlobalAggregateManager

public class RpcGlobalAggregateManager
extends Object
implements GlobalAggregateManager

Constructor Summary

Constructors

Constructor and Description
RpcGlobalAggregateManager(JobMasterGateway jobMasterGateway)

Method Summary

Modifier and Type	Method and Description
<IN,ACC,OUT> OUT	updateGlobalAggregate(String aggregateName, Object aggregand, AggregateFunction<IN,ACC,OUT> aggregateFunction) Update the global aggregate and return the new value.

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcGlobalAggregateManager

public RpcGlobalAggregateManager(JobMasterGateway jobMasterGateway)

Method Detail

updateGlobalAggregate

public <IN,ACC,OUT> OUT updateGlobalAggregate(String aggregateName,
                                              Object aggregand,
                                              AggregateFunction<IN,ACC,OUT> aggregateFunction)
                                       throws IOException

Description copied from interface: GlobalAggregateManager

Update the global aggregate and return the new value.

Specified by:

updateGlobalAggregate in interface GlobalAggregateManager

Parameters:

aggregateName - The name of the aggregate to update

aggregand - The value to add to the aggregate

aggregateFunction - The function to apply to the current aggregate and aggregand to obtain the new aggregate value

Returns:

The updated aggregate

Throws:

IOException