Package org.apache.flink.runtime.operators.util

Class TaskConfig

    • Constructor Detail

      • TaskConfig

        public TaskConfig​(Configuration config)
        Creates a new Task Config that wraps the given configuration.
        Parameters:
        config - The configuration holding the actual values.

    • Method Detail

      • getConfiguration

        public Configuration getConfiguration()
        Gets the configuration that holds the actual values encoded.
        Returns:
        The configuration that holds the actual values

      • setTaskName

        public void setTaskName​(String name)

      • getTaskName

        public String getTaskName()

      • hasStubWrapper

        public boolean hasStubWrapper()

      • setStubWrapper

        public void setStubWrapper​(UserCodeWrapper<?> wrapper)

      • setStubParameters

        public void setStubParameters​(Configuration parameters)

      • setStubParameter

        public void setStubParameter​(String key,
                             String value)

      • setDriver

        public void setDriver​(Class<? extends Driver> driver)

      • setDriverStrategy

        public void setDriverStrategy​(DriverStrategy strategy)

      • setDriverComparator

        public void setDriverComparator​(TypeComparatorFactory<?> factory,
                                int inputNum)

      • setInputLocalStrategy

        public void setInputLocalStrategy​(int inputNum,
                                  LocalStrategy strategy)

      • getInputLocalStrategy

        public LocalStrategy getInputLocalStrategy​(int inputNum)

      • setInputSerializer

        public void setInputSerializer​(TypeSerializerFactory<?> factory,
                               int inputNum)

      • setBroadcastInputSerializer

        public void setBroadcastInputSerializer​(TypeSerializerFactory<?> factory,
                                        int inputNum)

      • setInputComparator

        public void setInputComparator​(TypeComparatorFactory<?> factory,
                               int inputNum)

      • getNumInputs

        public int getNumInputs()

      • getNumBroadcastInputs

        public int getNumBroadcastInputs()

      • getGroupSize

        public int getGroupSize​(int groupIndex)

      • getBroadcastGroupSize

        public int getBroadcastGroupSize​(int groupIndex)

      • addInputToGroup

        public void addInputToGroup​(int groupIndex)

      • addBroadcastInputToGroup

        public void addBroadcastInputToGroup​(int groupIndex)

      • setInputAsynchronouslyMaterialized

        public void setInputAsynchronouslyMaterialized​(int inputNum,
                                               boolean temp)

      • isInputAsynchronouslyMaterialized

        public boolean isInputAsynchronouslyMaterialized​(int inputNum)

      • setInputCached

        public void setInputCached​(int inputNum,
                           boolean persistent)

      • isInputCached

        public boolean isInputCached​(int inputNum)

      • setRelativeInputMaterializationMemory

        public void setRelativeInputMaterializationMemory​(int inputNum,
                                                  double relativeMemory)

      • getRelativeInputMaterializationMemory

        public double getRelativeInputMaterializationMemory​(int inputNum)

      • setBroadcastInputName

        public void setBroadcastInputName​(String name,
                                  int groupIndex)

      • getBroadcastInputName

        public String getBroadcastInputName​(int groupIndex)

      • addOutputShipStrategy

        public void addOutputShipStrategy​(ShipStrategyType strategy)

      • getNumOutputs

        public int getNumOutputs()

      • getOutputShipStrategy

        public ShipStrategyType getOutputShipStrategy​(int outputNum)

      • setOutputComparator

        public void setOutputComparator​(TypeComparatorFactory<?> factory,
                                int outputNum)

      • setOutputDataDistribution

        public void setOutputDataDistribution​(DataDistribution distribution,
                                      int outputNum)

      • setOutputPartitioner

        public void setOutputPartitioner​(Partitioner<?> partitioner,
                                 int outputNum)

      • setRelativeMemoryDriver

        public void setRelativeMemoryDriver​(double relativeMemorySize)

      • getRelativeMemoryDriver

        public double getRelativeMemoryDriver()

      • setRelativeMemoryInput

        public void setRelativeMemoryInput​(int inputNum,
                                   double relativeMemorySize)

      • getRelativeMemoryInput

        public double getRelativeMemoryInput​(int inputNum)

      • setFilehandlesDriver

        public void setFilehandlesDriver​(int filehandles)

      • getFilehandlesDriver

        public int getFilehandlesDriver()

      • setFilehandlesInput

        public void setFilehandlesInput​(int inputNum,
                                int filehandles)

      • getFilehandlesInput

        public int getFilehandlesInput​(int inputNum)

      • setSpillingThresholdDriver

        public void setSpillingThresholdDriver​(float threshold)

      • getSpillingThresholdDriver

        public float getSpillingThresholdDriver()

      • setSpillingThresholdInput

        public void setSpillingThresholdInput​(int inputNum,
                                      float threshold)

      • getSpillingThresholdInput

        public float getSpillingThresholdInput​(int inputNum)

      • setUseLargeRecordHandler

        public void setUseLargeRecordHandler​(boolean useLargeRecordHandler)

      • getUseLargeRecordHandler

        public boolean getUseLargeRecordHandler()

      • getNumberOfChainedStubs

        public int getNumberOfChainedStubs()

      • getChainedStubConfig

        public TaskConfig getChainedStubConfig​(int chainPos)

      • getChainedTask

        public Class<? extends ChainedDriver<?,​?>> getChainedTask​(int chainPos)

      • getChainedTaskName

        public String getChainedTaskName​(int chainPos)

      • setNumberOfIterations

        public void setNumberOfIterations​(int numberOfIterations)

      • getNumberOfIterations

        public int getNumberOfIterations()

      • setIterationHeadPartialSolutionOrWorksetInputIndex

        public void setIterationHeadPartialSolutionOrWorksetInputIndex​(int inputIndex)

      • getIterationHeadPartialSolutionOrWorksetInputIndex

        public int getIterationHeadPartialSolutionOrWorksetInputIndex()

      • setIterationHeadSolutionSetInputIndex

        public void setIterationHeadSolutionSetInputIndex​(int inputIndex)

      • getIterationHeadSolutionSetInputIndex

        public int getIterationHeadSolutionSetInputIndex()

      • setRelativeBackChannelMemory

        public void setRelativeBackChannelMemory​(double relativeMemory)

      • getRelativeBackChannelMemory

        public double getRelativeBackChannelMemory()

      • setRelativeSolutionSetMemory

        public void setRelativeSolutionSetMemory​(double relativeMemory)

      • getRelativeSolutionSetMemory

        public double getRelativeSolutionSetMemory()

      • isIterativeInputGate

        public boolean isIterativeInputGate​(int inputGateIndex)

      • setGateIterativeWithNumberOfEventsUntilInterrupt

        public void setGateIterativeWithNumberOfEventsUntilInterrupt​(int inputGateIndex,
                                                             int numEvents)

      • getNumberOfEventsUntilInterruptInIterativeGate

        public int getNumberOfEventsUntilInterruptInIterativeGate​(int inputGateIndex)

      • setBroadcastGateIterativeWithNumberOfEventsUntilInterrupt

        public void setBroadcastGateIterativeWithNumberOfEventsUntilInterrupt​(int bcGateIndex,
                                                                      int numEvents)

      • getNumberOfEventsUntilInterruptInIterativeBroadcastGate

        public int getNumberOfEventsUntilInterruptInIterativeBroadcastGate​(int bcGateIndex)

      • setIterationId

        public void setIterationId​(int id)

      • getIterationId

        public int getIterationId()

      • setIsWorksetIteration

        public void setIsWorksetIteration()

      • getIsWorksetIteration

        public boolean getIsWorksetIteration()

      • setIterationHeadIndexOfSyncOutput

        public void setIterationHeadIndexOfSyncOutput​(int outputIndex)

      • getIterationHeadIndexOfSyncOutput

        public int getIterationHeadIndexOfSyncOutput()

      • setIterationHeadFinalOutputConfig

        public void setIterationHeadFinalOutputConfig​(TaskConfig conf)

      • getIterationHeadFinalOutputConfig

        public TaskConfig getIterationHeadFinalOutputConfig()

      • addIterationAggregator

        public void addIterationAggregator​(String name,
                                   Aggregator<?> aggregator)

      • setConvergenceCriterion

        public void setConvergenceCriterion​(String aggregatorName,
                                    ConvergenceCriterion<?> convCriterion)

      • setImplicitConvergenceCriterion

        public void setImplicitConvergenceCriterion​(String aggregatorName,
                                            ConvergenceCriterion<?> convCriterion)
        Sets the default convergence criterion of a DeltaIteration
        Parameters:
        aggregatorName -
        convCriterion -

      • usesConvergenceCriterion

        public boolean usesConvergenceCriterion()

      • getConvergenceCriterionAggregatorName

        public String getConvergenceCriterionAggregatorName()

      • usesImplicitConvergenceCriterion

        public boolean usesImplicitConvergenceCriterion()

      • getImplicitConvergenceCriterionAggregatorName

        public String getImplicitConvergenceCriterionAggregatorName()

      • setIsSolutionSetUpdate

        public void setIsSolutionSetUpdate()

      • getIsSolutionSetUpdate

        public boolean getIsSolutionSetUpdate()

      • setIsSolutionSetUpdateWithoutReprobe

        public void setIsSolutionSetUpdateWithoutReprobe()

      • setWaitForSolutionSetUpdate

        public void setWaitForSolutionSetUpdate()

      • getWaitForSolutionSetUpdate

        public boolean getWaitForSolutionSetUpdate()

      • setIsWorksetUpdate

        public void setIsWorksetUpdate()

      • getIsWorksetUpdate

        public boolean getIsWorksetUpdate()

      • setSolutionSetUnmanaged

        public void setSolutionSetUnmanaged​(boolean unmanaged)

      • isSolutionSetUnmanaged

        public boolean isSolutionSetUnmanaged()