源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.runtime.iterative.concurrent.IterationAggregatorBroker

示例1
public RuntimeAggregatorRegistry getIterationAggregators() {
	if (this.iterationAggregators == null) {
		this.iterationAggregators = IterationAggregatorBroker.instance().get(brokerKey());
	}
	return this.iterationAggregators;
}
示例2
public RuntimeAggregatorRegistry getIterationAggregators() {
	if (this.iterationAggregators == null) {
		this.iterationAggregators = IterationAggregatorBroker.instance().get(brokerKey());
	}
	return this.iterationAggregators;
}
示例3
public RuntimeAggregatorRegistry getIterationAggregators() {
	if (this.iterationAggregators == null) {
		this.iterationAggregators = IterationAggregatorBroker.instance().get(brokerKey());
	}
	return this.iterationAggregators;
}