org.apache.flink.runtime.iterative.task

Class IterationIntermediatePactTask<S extends org.apache.flink.api.common.functions.Function,OT>

java.lang.Object

org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

org.apache.flink.runtime.operators.RegularPactTask<S,OT>

org.apache.flink.runtime.iterative.task.AbstractIterativePactTask<S,OT>

org.apache.flink.runtime.iterative.task.IterationIntermediatePactTask<S,OT>

All Implemented Interfaces:

Terminable, PactTaskContext<S,OT>

public class IterationIntermediatePactTask<S extends org.apache.flink.api.common.functions.Function,OT>
extends AbstractIterativePactTask<S,OT>

An intermediate iteration task, which runs a Driver}inside.

It will propagate EndOfSuperstepEvents and TerminationEvents to it's connected tasks. Furthermore intermediate tasks can also update the iteration state, either the workset or the solution set.

If the iteration state is updated, the output of this task will be send back to the IterationHeadPactTask via a BlockingBackChannel for the workset -XOR- a eHashTable for the solution set. In this case this task must be scheduled on the same instance as the head.

Field Summary

Fields inherited from class org.apache.flink.runtime.iterative.task.AbstractIterativePactTask

isSolutionSetUpdate, isWorksetIteration, isWorksetUpdate, worksetAggregator, worksetBackChannel

Fields inherited from class org.apache.flink.runtime.operators.RegularPactTask

broadcastInputReaders, broadcastInputSerializers, chainedTasks, config, driver, eventualOutputs, inputComparators, inputIterators, inputReaders, inputs, inputSerializers, iterativeBroadcastInputs, iterativeInputs, localStrategies, LOG, output, resettableInputs, running, runtimeUdfContext, stub, tempBarriers

Constructor Summary

Constructors

Constructor and Description
IterationIntermediatePactTask()

Method Summary

Modifier and Type	Method and Description
protected void	initialize()
void	run()

Methods inherited from class org.apache.flink.runtime.iterative.task.AbstractIterativePactTask

brokerKey, cancel, closeLocalStrategiesAndCaches, createRuntimeContext, createSolutionSetUpdateOutputCollector, createWorksetUpdateOutputCollector, createWorksetUpdateOutputCollector, currentIteration, getIterationAggregators, incrementIterationCounter, inFirstIteration, requestTermination, terminationRequested, verifyEndOfSuperstepState

Methods inherited from class org.apache.flink.runtime.operators.RegularPactTask

cancelChainedTasks, clearReaders, clearWriters, closeChainedTasks, closeUserCode, constructLogString, createInputIterator, excludeFromReset, formatLogString, getDriverComparator, getInput, getInputSerializer, getIOManager, getLastOutputCollector, getLastTasksConfig, getMemoryManager, getNumTaskInputs, getOutputCollector, getOutputCollector, getOwningNepheleTask, getStub, getTaskConfig, initBroadcastInputReaders, initBroadcastInputsSerializers, initInputReaders, initInputsSerializersAndComparators, initLocalStrategies, initOutputs, initOutputs, initStub, instantiateUserCode, invoke, logAndThrowException, openChainedTasks, openUserCode, readAndSetBroadcastInput, registerInputOutput, releaseBroadcastVariables, reportAndClearAccumulators, resetAllInputs, setLastOutputCollector

Methods inherited from class org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable

getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.operators.PactTaskContext

getExecutionConfig, getUserCodeClassLoader

Constructor Detail

IterationIntermediatePactTask

public IterationIntermediatePactTask()

Method Detail

initialize

protected void initialize()
                   throws Exception

Overrides:

initialize in class AbstractIterativePactTask<S extends org.apache.flink.api.common.functions.Function,OT>

Throws:

Exception

run

public void run()
         throws Exception

Overrides:

run in class AbstractIterativePactTask<S extends org.apache.flink.api.common.functions.Function,OT>

Throws:

Exception