public class TaskConfig extends Object implements Serializable
| Modifier and Type | Field and Description |
|---|---|
protected Configuration |
config |
| Constructor and Description |
|---|
TaskConfig(Configuration config)
Creates a new Task Config that wraps the given configuration.
|
protected final Configuration config
public TaskConfig(Configuration config)
config - The configuration holding the actual values.public Configuration getConfiguration()
public void setTaskName(String name)
public String getTaskName()
public boolean hasStubWrapper()
public void setStubWrapper(UserCodeWrapper<?> wrapper)
public <T> UserCodeWrapper<T> getStubWrapper(ClassLoader cl)
public void setStubParameters(Configuration parameters)
public Configuration getStubParameters()
public void setDriverStrategy(DriverStrategy strategy)
public DriverStrategy getDriverStrategy()
public void setMutableObjectMode(boolean mode)
public boolean getMutableObjectMode()
public void setDriverComparator(TypeComparatorFactory<?> factory, int inputNum)
public <T> TypeComparatorFactory<T> getDriverComparator(int inputNum, ClassLoader cl)
public void setDriverPairComparator(TypePairComparatorFactory<?,?> factory)
public <T1,T2> TypePairComparatorFactory<T1,T2> getPairComparatorFactory(ClassLoader cl)
public void setInputLocalStrategy(int inputNum,
LocalStrategy strategy)
public LocalStrategy getInputLocalStrategy(int inputNum)
public void setInputSerializer(TypeSerializerFactory<?> factory, int inputNum)
public void setBroadcastInputSerializer(TypeSerializerFactory<?> factory, int inputNum)
public <T> TypeSerializerFactory<T> getInputSerializer(int inputNum, ClassLoader cl)
public <T> TypeSerializerFactory<T> getBroadcastInputSerializer(int inputNum, ClassLoader cl)
public void setInputComparator(TypeComparatorFactory<?> factory, int inputNum)
public <T> TypeComparatorFactory<T> getInputComparator(int inputNum, ClassLoader cl)
public int getNumInputs()
public int getNumBroadcastInputs()
public int getGroupSize(int groupIndex)
public int getBroadcastGroupSize(int groupIndex)
public void addInputToGroup(int groupIndex)
public void addBroadcastInputToGroup(int groupIndex)
public void setInputAsynchronouslyMaterialized(int inputNum,
boolean temp)
public boolean isInputAsynchronouslyMaterialized(int inputNum)
public void setInputCached(int inputNum,
boolean persistent)
public boolean isInputCached(int inputNum)
public void setRelativeInputMaterializationMemory(int inputNum,
double relativeMemory)
public double getRelativeInputMaterializationMemory(int inputNum)
public void setBroadcastInputName(String name, int groupIndex)
public String getBroadcastInputName(int groupIndex)
public void addOutputShipStrategy(ShipStrategyType strategy)
public int getNumOutputs()
public ShipStrategyType getOutputShipStrategy(int outputNum)
public void setOutputSerializer(TypeSerializerFactory<?> factory)
public <T> TypeSerializerFactory<T> getOutputSerializer(ClassLoader cl)
public void setOutputComparator(TypeComparatorFactory<?> factory, int outputNum)
public <T> TypeComparatorFactory<T> getOutputComparator(int outputNum, ClassLoader cl)
public void setOutputDataDistribution(DataDistribution distribution, int outputNum)
public DataDistribution getOutputDataDistribution(int outputNum, ClassLoader cl) throws ClassNotFoundException
ClassNotFoundExceptionpublic void setOutputPartitioner(Partitioner<?> partitioner, int outputNum)
public Partitioner<?> getOutputPartitioner(int outputNum, ClassLoader cl) throws ClassNotFoundException
ClassNotFoundExceptionpublic void setRelativeMemoryDriver(double relativeMemorySize)
public double getRelativeMemoryDriver()
public void setRelativeMemoryInput(int inputNum,
double relativeMemorySize)
public double getRelativeMemoryInput(int inputNum)
public void setFilehandlesDriver(int filehandles)
public int getFilehandlesDriver()
public void setFilehandlesInput(int inputNum,
int filehandles)
public int getFilehandlesInput(int inputNum)
public void setSpillingThresholdDriver(float threshold)
public float getSpillingThresholdDriver()
public void setSpillingThresholdInput(int inputNum,
float threshold)
public float getSpillingThresholdInput(int inputNum)
public void setUseLargeRecordHandler(boolean useLargeRecordHandler)
public boolean getUseLargeRecordHandler()
public int getNumberOfChainedStubs()
public void addChainedTask(Class<? extends ChainedDriver> chainedTaskClass, TaskConfig conf, String taskName)
public TaskConfig getChainedStubConfig(int chainPos)
public Class<? extends ChainedDriver<?,?>> getChainedTask(int chainPos)
public String getChainedTaskName(int chainPos)
public void setNumberOfIterations(int numberOfIterations)
public int getNumberOfIterations()
public void setIterationHeadPartialSolutionOrWorksetInputIndex(int inputIndex)
public int getIterationHeadPartialSolutionOrWorksetInputIndex()
public void setIterationHeadSolutionSetInputIndex(int inputIndex)
public int getIterationHeadSolutionSetInputIndex()
public void setRelativeBackChannelMemory(double relativeMemory)
public double getRelativeBackChannelMemory()
public void setRelativeSolutionSetMemory(double relativeMemory)
public double getRelativeSolutionSetMemory()
public boolean isIterativeInputGate(int inputGateIndex)
public void setGateIterativeWithNumberOfEventsUntilInterrupt(int inputGateIndex,
int numEvents)
public int getNumberOfEventsUntilInterruptInIterativeGate(int inputGateIndex)
public void setBroadcastGateIterativeWithNumberOfEventsUntilInterrupt(int bcGateIndex,
int numEvents)
public int getNumberOfEventsUntilInterruptInIterativeBroadcastGate(int bcGateIndex)
public void setIterationId(int id)
public int getIterationId()
public void setIsWorksetIteration()
public boolean getIsWorksetIteration()
public void setIterationHeadIndexOfSyncOutput(int outputIndex)
public int getIterationHeadIndexOfSyncOutput()
public void setIterationHeadFinalOutputConfig(TaskConfig conf)
public TaskConfig getIterationHeadFinalOutputConfig()
public void setSolutionSetSerializer(TypeSerializerFactory<?> factory)
public <T> TypeSerializerFactory<T> getSolutionSetSerializer(ClassLoader cl)
public void setSolutionSetComparator(TypeComparatorFactory<?> factory)
public <T> TypeComparatorFactory<T> getSolutionSetComparator(ClassLoader cl)
public void addIterationAggregator(String name, Aggregator<?> aggregator)
public void addIterationAggregators(Collection<AggregatorWithName<?>> aggregators)
public Collection<AggregatorWithName<?>> getIterationAggregators(ClassLoader cl)
public void setConvergenceCriterion(String aggregatorName, ConvergenceCriterion<?> convCriterion)
public void setImplicitConvergenceCriterion(String aggregatorName, ConvergenceCriterion<?> convCriterion)
DeltaIterationaggregatorName - convCriterion - public <T extends Value> ConvergenceCriterion<T> getConvergenceCriterion(ClassLoader cl)
public boolean usesConvergenceCriterion()
public String getConvergenceCriterionAggregatorName()
public <T extends Value> ConvergenceCriterion<T> getImplicitConvergenceCriterion(ClassLoader cl)
public boolean usesImplicitConvergenceCriterion()
public String getImplicitConvergenceCriterionAggregatorName()
public void setIsSolutionSetUpdate()
public boolean getIsSolutionSetUpdate()
public void setIsSolutionSetUpdateWithoutReprobe()
public boolean getIsSolutionSetUpdateWithoutReprobe()
public void setWaitForSolutionSetUpdate()
public boolean getWaitForSolutionSetUpdate()
public void setIsWorksetUpdate()
public boolean getIsWorksetUpdate()
public void setSolutionSetUnmanaged(boolean unmanaged)
public boolean isSolutionSetUnmanaged()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.