public abstract class IterationConfiguration extends Object
Constructor and Description |
---|
IterationConfiguration() |
Modifier and Type | Method and Description |
---|---|
Map<String,Aggregator<?>> |
getAggregators()
Gets the set of aggregators that are registered for this vertex-centric iteration.
|
String |
getName(String defaultName)
Gets the name of the iteration.
|
int |
getParallelism()
Gets the iteration's parallelism.
|
boolean |
isOptNumVertices()
Gets whether the number of vertices option is set.
|
boolean |
isSolutionSetUnmanagedMemory()
Gets whether the solution set is kept in managed memory (Flink's internal way of keeping object
in serialized form) or as a simple object map.
|
void |
registerAggregator(String name,
Aggregator<?> aggregator)
Registers a new aggregator.
|
void |
setName(String name)
Sets the name for the iteration.
|
void |
setOptNumVertices(boolean optNumVertices)
Sets the number of vertices option.
|
void |
setParallelism(int parallelism)
Sets the parallelism for the iteration.
|
void |
setSolutionSetUnmanagedMemory(boolean unmanaged)
Defines whether the solution set is kept in managed memory (Flink's internal way of keeping object
in serialized form) or as a simple object map.
|
public void setName(String name)
name
- The name for the iteration.public String getName(String defaultName)
defaultName
- public void setParallelism(int parallelism)
parallelism
- The parallelism.public int getParallelism()
public void setSolutionSetUnmanagedMemory(boolean unmanaged)
unmanaged
- True, to keep the solution set in unmanaged memory, false otherwise.public boolean isSolutionSetUnmanagedMemory()
public boolean isOptNumVertices()
public void setOptNumVertices(boolean optNumVertices)
optNumVertices
- True, to set this option, false otherwise.public void registerAggregator(String name, Aggregator<?> aggregator)
GatherFunction.getIterationAggregator(String)
and
GatherFunction.getPreviousIterationAggregate(String)
.name
- The name of the aggregator, used to retrieve it and its aggregates during execution.aggregator
- The aggregator.public Map<String,Aggregator<?>> getAggregators()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.