Modifier and Type | Class and Description |
---|---|
class |
DoubleSumAggregator
An
Aggregator that sums up DoubleValue values. |
class |
LongSumAggregator
An
Aggregator that sums up long values. |
Modifier and Type | Method and Description |
---|---|
Aggregator<T> |
AggregatorWithName.getAggregator()
Gets the aggregator.
|
Modifier and Type | Method and Description |
---|---|
<T extends Value> |
AggregatorRegistry.registerAggregationConvergenceCriterion(String name,
Aggregator<T> aggregator,
ConvergenceCriterion<T> convergenceCheck) |
void |
AggregatorRegistry.registerAggregator(String name,
Aggregator<?> aggregator) |
Constructor and Description |
---|
AggregatorWithName(String name,
Aggregator<T> aggregator)
Creates a new instance for the given aggregator and name.
|
Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
IterationRuntimeContext.getIterationAggregator(String name) |
Modifier and Type | Class and Description |
---|---|
static class |
BulkIterationBase.TerminationCriterionAggregator
Aggregator that basically only adds 1 for every output tuple of the termination criterion branch
|
Modifier and Type | Method and Description |
---|---|
<X extends Value> |
DeltaIteration.registerAggregationConvergenceCriterion(String name,
Aggregator<X> aggregator,
ConvergenceCriterion<X> convergenceCheck)
Registers an
Aggregator for the iteration together with a ConvergenceCriterion . |
<X extends Value> |
IterativeDataSet.registerAggregationConvergenceCriterion(String name,
Aggregator<X> aggregator,
ConvergenceCriterion<X> convergenceCheck)
Registers an
Aggregator for the iteration together with a ConvergenceCriterion . |
DeltaIteration<ST,WT> |
DeltaIteration.registerAggregator(String name,
Aggregator<?> aggregator)
Registers an
Aggregator for the iteration. |
IterativeDataSet<T> |
IterativeDataSet.registerAggregator(String name,
Aggregator<?> aggregator)
Registers an
Aggregator for the iteration. |
Modifier and Type | Method and Description |
---|---|
Map<String,Aggregator<?>> |
IterationConfiguration.getAggregators()
Gets the set of aggregators that are registered for this vertex-centric iteration.
|
Modifier and Type | Method and Description |
---|---|
void |
IterationConfiguration.registerAggregator(String name,
Aggregator<?> aggregator)
Registers a new aggregator.
|
Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
GatherFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
<T extends Aggregator<?>> |
ApplyFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
<T extends Aggregator<?>> |
SumFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
ComputeFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
GatherFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
<T extends Aggregator<?>> |
ScatterFunction.getIterationAggregator(String name)
Gets the iteration aggregator registered under the given name.
|
Constructor and Description |
---|
AllWorkersDoneEvent(Map<String,Aggregator<?>> aggregators) |
IterationEventWithAggregators(Map<String,Aggregator<?>> aggregators) |
WorkerDoneEvent(int workerIndex,
Map<String,Aggregator<?>> aggregators) |
Modifier and Type | Method and Description |
---|---|
<T extends Aggregator<?>> |
RuntimeAggregatorRegistry.getAggregator(String name) |
Modifier and Type | Method and Description |
---|---|
Map<String,Aggregator<?>> |
RuntimeAggregatorRegistry.getAllAggregators() |
Constructor and Description |
---|
SyncEventHandler(int numberOfEventsUntilEndOfSuperstep,
Map<String,Aggregator<?>> aggregators,
ClassLoader userCodeClassLoader) |
Modifier and Type | Method and Description |
---|---|
void |
TaskConfig.addIterationAggregator(String name,
Aggregator<?> aggregator) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.