Package | Description |
---|---|
org.apache.flink.api.common.aggregators | |
org.apache.flink.runtime.iterative.task | |
org.apache.flink.runtime.operators.util |
Modifier and Type | Method and Description |
---|---|
Collection<AggregatorWithName<?>> |
AggregatorRegistry.getAllRegisteredAggregators() |
Constructor and Description |
---|
RuntimeAggregatorRegistry(Collection<AggregatorWithName<?>> aggs) |
Modifier and Type | Method and Description |
---|---|
Collection<AggregatorWithName<?>> |
TaskConfig.getIterationAggregators(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
TaskConfig.addIterationAggregators(Collection<AggregatorWithName<?>> aggregators) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.