test_class.declarator: awaitLatch
test_class.modifier: private static
test_class.original_string: private static OneShotLatch awaitLatch;
test_class.type: OneShotLatch
test_class.var_name: awaitLatch
test_class.declarator: triggerLatch
test_class.modifier: private static
test_class.original_string: private static OneShotLatch triggerLatch;
test_class.type: OneShotLatch
test_class.var_name: triggerLatch
test_class.declarator: taskManagerGateway
test_class.modifier: private
test_class.original_string: private ActorGateway taskManagerGateway;
test_class.type: ActorGateway
test_class.var_name: taskManagerGateway
test_class.declarator: jobManagerGateway
test_class.modifier: private
test_class.original_string: private ActorGateway jobManagerGateway;
test_class.type: ActorGateway
test_class.var_name: jobManagerGateway
test_class.declarator: listenerGateway
test_class.modifier: private
test_class.original_string: private ActorGateway listenerGateway;
test_class.type: ActorGateway
test_class.var_name: listenerGateway
test_class.declarator: taskManagerMessages
test_class.modifier: private
test_class.original_string: private BlockingQueue<Object> taskManagerMessages;
test_class.type: BlockingQueue<Object>
test_class.var_name: taskManagerMessages
test_class.declarator: jobManagerMessages
test_class.modifier: private
test_class.original_string: private BlockingQueue<Object> jobManagerMessages;
test_class.type: BlockingQueue<Object>
test_class.var_name: jobManagerMessages
test_class.declarator: listenerMessages
test_class.modifier: private
test_class.original_string: private BlockingQueue<Object> listenerMessages;
test_class.type: BlockingQueue<Object>
test_class.var_name: listenerMessages
test_class.file: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
test_class.identifier: TaskTest
test_case.body: @Test
  	public void testOnPartitionStateUpdate() throws Exception {
  		IntermediateDataSetID resultId = new IntermediateDataSetID();
  		ResultPartitionID partitionId = new ResultPartitionID();
  
  		SingleInputGate inputGate = mock(SingleInputGate.class);
  		when(inputGate.getConsumedResultId()).thenReturn(resultId);
  
  		final Task task = createTask(InvokableBlockingInInvoke.class);
  
  		// Set the mock input gate
  		setInputGate(task, inputGate);
  
  		// Expected task state for each partition state
  		final Map<ExecutionState, ExecutionState> expected = Maps
  				.newHashMapWithExpectedSize(ExecutionState.values().length);
  
  		// Fail the task for unexpected states
  		for (ExecutionState state : ExecutionState.values()) {
  			expected.put(state, ExecutionState.FAILED);
  		}
  
  		expected.put(ExecutionState.RUNNING, ExecutionState.RUNNING);
  
  		expected.put(ExecutionState.CANCELED, ExecutionState.CANCELING);
  		expected.put(ExecutionState.CANCELING, ExecutionState.CANCELING);
  		expected.put(ExecutionState.FAILED, ExecutionState.CANCELING);
  
  		for (ExecutionState state : ExecutionState.values()) {
  			setState(task, ExecutionState.RUNNING);
  
  			task.onPartitionStateUpdate(resultId, partitionId.getPartitionId(), state);
  
  			ExecutionState newTaskState = task.getExecutionState();
  
  			assertEquals(expected.get(state), newTaskState);
  		}
  
  		verify(inputGate, times(1)).retriggerPartitionRequest(eq(partitionId.getPartitionId()));
  	}
test_case.class_method_signature: TaskTest.testOnPartitionStateUpdate()
test_case.full_signature: @Test public void testOnPartitionStateUpdate()
test_case.identifier: testOnPartitionStateUpdate
test_case.invocations: mock thenReturn when getConsumedResultId createTask setInputGate newHashMapWithExpectedSize values values put put put put put values setState onPartitionStateUpdate getPartitionId getExecutionState assertEquals get retriggerPartitionRequest verify times eq getPartitionId
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testOnPartitionStateUpdate()
focal_class.declarator: LOG = LoggerFactory.getLogger(Task.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(Task.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: TASK_THREADS_GROUP = new ThreadGroup("Flink Task Threads")
focal_class.modifier: private static final
focal_class.original_string: private static final ThreadGroup TASK_THREADS_GROUP = new ThreadGroup("Flink Task Threads");
focal_class.type: ThreadGroup
focal_class.var_name: TASK_THREADS_GROUP
focal_class.declarator: STATE_UPDATER =
  			AtomicReferenceFieldUpdater.newUpdater(Task.class, ExecutionState.class, "executionState")
focal_class.modifier: private static final
focal_class.original_string: private static final AtomicReferenceFieldUpdater<Task, ExecutionState> STATE_UPDATER =
  			AtomicReferenceFieldUpdater.newUpdater(Task.class, ExecutionState.class, "executionState");
focal_class.type: AtomicReferenceFieldUpdater<Task, ExecutionState>
focal_class.var_name: STATE_UPDATER
focal_class.declarator: jobId
focal_class.modifier: private final
focal_class.original_string: private final JobID jobId;
focal_class.type: JobID
focal_class.var_name: jobId
focal_class.declarator: vertexId
focal_class.modifier: private final
focal_class.original_string: private final JobVertexID vertexId;
focal_class.type: JobVertexID
focal_class.var_name: vertexId
focal_class.declarator: executionId
focal_class.modifier: private final
focal_class.original_string: private final ExecutionAttemptID executionId;
focal_class.type: ExecutionAttemptID
focal_class.var_name: executionId
focal_class.declarator: taskInfo
focal_class.modifier: private final
focal_class.original_string: private final TaskInfo taskInfo;
focal_class.type: TaskInfo
focal_class.var_name: taskInfo
focal_class.declarator: taskNameWithSubtask
focal_class.modifier: private final
focal_class.original_string: private final String taskNameWithSubtask;
focal_class.type: String
focal_class.var_name: taskNameWithSubtask
focal_class.declarator: jobConfiguration
focal_class.modifier: private final
focal_class.original_string: private final Configuration jobConfiguration;
focal_class.type: Configuration
focal_class.var_name: jobConfiguration
focal_class.declarator: taskConfiguration
focal_class.modifier: private final
focal_class.original_string: private final Configuration taskConfiguration;
focal_class.type: Configuration
focal_class.var_name: taskConfiguration
focal_class.declarator: requiredJarFiles
focal_class.modifier: private final
focal_class.original_string: private final List<BlobKey> requiredJarFiles;
focal_class.type: List<BlobKey>
focal_class.var_name: requiredJarFiles
focal_class.declarator: requiredClasspaths
focal_class.modifier: private final
focal_class.original_string: private final List<URL> requiredClasspaths;
focal_class.type: List<URL>
focal_class.var_name: requiredClasspaths
focal_class.declarator: nameOfInvokableClass
focal_class.modifier: private final
focal_class.original_string: private final String nameOfInvokableClass;
focal_class.type: String
focal_class.var_name: nameOfInvokableClass
focal_class.declarator: taskManagerConfig
focal_class.modifier: private final
focal_class.original_string: private final TaskManagerRuntimeInfo taskManagerConfig;
focal_class.type: TaskManagerRuntimeInfo
focal_class.var_name: taskManagerConfig
focal_class.declarator: memoryManager
focal_class.modifier: private final
focal_class.original_string: private final MemoryManager memoryManager;
focal_class.type: MemoryManager
focal_class.var_name: memoryManager
focal_class.declarator: ioManager
focal_class.modifier: private final
focal_class.original_string: private final IOManager ioManager;
focal_class.type: IOManager
focal_class.var_name: ioManager
focal_class.declarator: broadcastVariableManager
focal_class.modifier: private final
focal_class.original_string: private final BroadcastVariableManager broadcastVariableManager;
focal_class.type: BroadcastVariableManager
focal_class.var_name: broadcastVariableManager
focal_class.declarator: producedPartitions
focal_class.modifier: private final
focal_class.original_string: private final ResultPartition[] producedPartitions;
focal_class.type: ResultPartition[]
focal_class.var_name: producedPartitions
focal_class.declarator: writers
focal_class.modifier: private final
focal_class.original_string: private final ResultPartitionWriter[] writers;
focal_class.type: ResultPartitionWriter[]
focal_class.var_name: writers
focal_class.declarator: inputGates
focal_class.modifier: private final
focal_class.original_string: private final SingleInputGate[] inputGates;
focal_class.type: SingleInputGate[]
focal_class.var_name: inputGates
focal_class.declarator: inputGatesById
focal_class.modifier: private final
focal_class.original_string: private final Map<IntermediateDataSetID, SingleInputGate> inputGatesById;
focal_class.type: Map<IntermediateDataSetID, SingleInputGate>
focal_class.var_name: inputGatesById
focal_class.declarator: taskManager
focal_class.modifier: private final
focal_class.original_string: private final ActorGateway taskManager;
focal_class.type: ActorGateway
focal_class.var_name: taskManager
focal_class.declarator: jobManager
focal_class.modifier: private final
focal_class.original_string: private final ActorGateway jobManager;
focal_class.type: ActorGateway
focal_class.var_name: jobManager
focal_class.declarator: executionListenerActors
focal_class.modifier: private final
focal_class.original_string: private final List<ActorGateway> executionListenerActors;
focal_class.type: List<ActorGateway>
focal_class.var_name: executionListenerActors
focal_class.declarator: actorAskTimeout
focal_class.modifier: private final
focal_class.original_string: private final FiniteDuration actorAskTimeout;
focal_class.type: FiniteDuration
focal_class.var_name: actorAskTimeout
focal_class.declarator: libraryCache
focal_class.modifier: private final
focal_class.original_string: private final LibraryCacheManager libraryCache;
focal_class.type: LibraryCacheManager
focal_class.var_name: libraryCache
focal_class.declarator: fileCache
focal_class.modifier: private final
focal_class.original_string: private final FileCache fileCache;
focal_class.type: FileCache
focal_class.var_name: fileCache
focal_class.declarator: network
focal_class.modifier: private final
focal_class.original_string: private final NetworkEnvironment network;
focal_class.type: NetworkEnvironment
focal_class.var_name: network
focal_class.declarator: accumulatorRegistry
focal_class.modifier: private final
focal_class.original_string: private final AccumulatorRegistry accumulatorRegistry;
focal_class.type: AccumulatorRegistry
focal_class.var_name: accumulatorRegistry
focal_class.declarator: executingThread
focal_class.modifier: private final
focal_class.original_string: private final Thread executingThread;
focal_class.type: Thread
focal_class.var_name: executingThread
focal_class.declarator: invokableHasBeenCanceled
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean invokableHasBeenCanceled;
focal_class.type: AtomicBoolean
focal_class.var_name: invokableHasBeenCanceled
focal_class.declarator: invokable
focal_class.modifier: private volatile
focal_class.original_string: private volatile AbstractInvokable invokable;
focal_class.type: AbstractInvokable
focal_class.var_name: invokable
focal_class.declarator: executionState = ExecutionState.CREATED
focal_class.modifier: private volatile
focal_class.original_string: private volatile ExecutionState executionState = ExecutionState.CREATED;
focal_class.type: ExecutionState
focal_class.var_name: executionState
focal_class.declarator: failureCause
focal_class.modifier: private volatile
focal_class.original_string: private volatile Throwable failureCause;
focal_class.type: Throwable
focal_class.var_name: failureCause
focal_class.declarator: asyncCallDispatcher
focal_class.modifier: private volatile
focal_class.original_string: private volatile ExecutorService asyncCallDispatcher;
focal_class.type: ExecutorService
focal_class.var_name: asyncCallDispatcher
focal_class.declarator: operatorState
focal_class.modifier: private volatile
focal_class.original_string: private volatile SerializedValue<StateHandle<?>> operatorState;
focal_class.type: SerializedValue<StateHandle<?>>
focal_class.var_name: operatorState
focal_class.declarator: recoveryTs
focal_class.modifier: private volatile
focal_class.original_string: private volatile long recoveryTs;
focal_class.type: long
focal_class.var_name: recoveryTs
focal_class.file: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java
focal_class.identifier: Task
focal_class.interfaces: implements Runnable
focal_class.class_method_signature: Task.Task(TaskDeploymentDescriptor tdd,
  				MemoryManager memManager,
  				IOManager ioManager,
  				NetworkEnvironment networkEnvironment,
  				BroadcastVariableManager bcVarManager,
  				ActorGateway taskManagerActor,
  				ActorGateway jobManagerActor,
  				FiniteDuration actorAskTimeout,
  				LibraryCacheManager libraryCache,
  				FileCache fileCache,
  				TaskManagerRuntimeInfo taskManagerConfig)
focal_class.full_signature: public  Task(TaskDeploymentDescriptor tdd,
  				MemoryManager memManager,
  				IOManager ioManager,
  				NetworkEnvironment networkEnvironment,
  				BroadcastVariableManager bcVarManager,
  				ActorGateway taskManagerActor,
  				ActorGateway jobManagerActor,
  				FiniteDuration actorAskTimeout,
  				LibraryCacheManager libraryCache,
  				FileCache fileCache,
  				TaskManagerRuntimeInfo taskManagerConfig)
focal_class.identifier: Task
focal_class.modifiers: public
focal_class.parameters: (TaskDeploymentDescriptor tdd,
  				MemoryManager memManager,
  				IOManager ioManager,
  				NetworkEnvironment networkEnvironment,
  				BroadcastVariableManager bcVarManager,
  				ActorGateway taskManagerActor,
  				ActorGateway jobManagerActor,
  				FiniteDuration actorAskTimeout,
  				LibraryCacheManager libraryCache,
  				FileCache fileCache,
  				TaskManagerRuntimeInfo taskManagerConfig)
focal_class.signature:  Task(TaskDeploymentDescriptor tdd,
  				MemoryManager memManager,
  				IOManager ioManager,
  				NetworkEnvironment networkEnvironment,
  				BroadcastVariableManager bcVarManager,
  				ActorGateway taskManagerActor,
  				ActorGateway jobManagerActor,
  				FiniteDuration actorAskTimeout,
  				LibraryCacheManager libraryCache,
  				FileCache fileCache,
  				TaskManagerRuntimeInfo taskManagerConfig)
focal_class.class_method_signature: Task.getJobID()
focal_class.full_signature: public JobID getJobID()
focal_class.identifier: getJobID
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: JobID
focal_class.signature: JobID getJobID()
focal_class.class_method_signature: Task.getJobVertexId()
focal_class.full_signature: public JobVertexID getJobVertexId()
focal_class.identifier: getJobVertexId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: JobVertexID
focal_class.signature: JobVertexID getJobVertexId()
focal_class.class_method_signature: Task.getExecutionId()
focal_class.full_signature: public ExecutionAttemptID getExecutionId()
focal_class.identifier: getExecutionId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ExecutionAttemptID
focal_class.signature: ExecutionAttemptID getExecutionId()
focal_class.class_method_signature: Task.getTaskInfo()
focal_class.full_signature: public TaskInfo getTaskInfo()
focal_class.identifier: getTaskInfo
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: TaskInfo
focal_class.signature: TaskInfo getTaskInfo()
focal_class.class_method_signature: Task.getJobConfiguration()
focal_class.full_signature: public Configuration getJobConfiguration()
focal_class.identifier: getJobConfiguration
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Configuration
focal_class.signature: Configuration getJobConfiguration()
focal_class.class_method_signature: Task.getTaskConfiguration()
focal_class.full_signature: public Configuration getTaskConfiguration()
focal_class.identifier: getTaskConfiguration
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Configuration
focal_class.signature: Configuration getTaskConfiguration()
focal_class.class_method_signature: Task.getAllWriters()
focal_class.full_signature: public ResultPartitionWriter[] getAllWriters()
focal_class.identifier: getAllWriters
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ResultPartitionWriter[]
focal_class.signature: ResultPartitionWriter[] getAllWriters()
focal_class.class_method_signature: Task.getAllInputGates()
focal_class.full_signature: public SingleInputGate[] getAllInputGates()
focal_class.identifier: getAllInputGates
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: SingleInputGate[]
focal_class.signature: SingleInputGate[] getAllInputGates()
focal_class.class_method_signature: Task.getProducedPartitions()
focal_class.full_signature: public ResultPartition[] getProducedPartitions()
focal_class.identifier: getProducedPartitions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ResultPartition[]
focal_class.signature: ResultPartition[] getProducedPartitions()
focal_class.class_method_signature: Task.getInputGateById(IntermediateDataSetID id)
focal_class.full_signature: public SingleInputGate getInputGateById(IntermediateDataSetID id)
focal_class.identifier: getInputGateById
focal_class.modifiers: public
focal_class.parameters: (IntermediateDataSetID id)
focal_class.return: SingleInputGate
focal_class.signature: SingleInputGate getInputGateById(IntermediateDataSetID id)
focal_class.class_method_signature: Task.getAccumulatorRegistry()
focal_class.full_signature: public AccumulatorRegistry getAccumulatorRegistry()
focal_class.identifier: getAccumulatorRegistry
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: AccumulatorRegistry
focal_class.signature: AccumulatorRegistry getAccumulatorRegistry()
focal_class.class_method_signature: Task.getExecutingThread()
focal_class.full_signature: public Thread getExecutingThread()
focal_class.identifier: getExecutingThread
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Thread
focal_class.signature: Thread getExecutingThread()
focal_class.class_method_signature: Task.getExecutionState()
focal_class.full_signature: public ExecutionState getExecutionState()
focal_class.identifier: getExecutionState
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: ExecutionState
focal_class.signature: ExecutionState getExecutionState()
focal_class.class_method_signature: Task.isCanceledOrFailed()
focal_class.full_signature: public boolean isCanceledOrFailed()
focal_class.identifier: isCanceledOrFailed
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isCanceledOrFailed()
focal_class.class_method_signature: Task.getFailureCause()
focal_class.full_signature: public Throwable getFailureCause()
focal_class.identifier: getFailureCause
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Throwable
focal_class.signature: Throwable getFailureCause()
focal_class.class_method_signature: Task.startTaskThread()
focal_class.full_signature: public void startTaskThread()
focal_class.identifier: startTaskThread
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startTaskThread()
focal_class.class_method_signature: Task.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.class_method_signature: Task.createUserCodeClassloader(LibraryCacheManager libraryCache)
focal_class.full_signature: private ClassLoader createUserCodeClassloader(LibraryCacheManager libraryCache)
focal_class.identifier: createUserCodeClassloader
focal_class.modifiers: private
focal_class.parameters: (LibraryCacheManager libraryCache)
focal_class.return: ClassLoader
focal_class.signature: ClassLoader createUserCodeClassloader(LibraryCacheManager libraryCache)
focal_class.class_method_signature: Task.loadAndInstantiateInvokable(ClassLoader classLoader, String className)
focal_class.full_signature: private AbstractInvokable loadAndInstantiateInvokable(ClassLoader classLoader, String className)
focal_class.identifier: loadAndInstantiateInvokable
focal_class.modifiers: private
focal_class.parameters: (ClassLoader classLoader, String className)
focal_class.return: AbstractInvokable
focal_class.signature: AbstractInvokable loadAndInstantiateInvokable(ClassLoader classLoader, String className)
focal_class.class_method_signature: Task.removeCachedFiles(Map<String, Future<Path>> entries, FileCache fileCache)
focal_class.full_signature: private void removeCachedFiles(Map<String, Future<Path>> entries, FileCache fileCache)
focal_class.identifier: removeCachedFiles
focal_class.modifiers: private
focal_class.parameters: (Map<String, Future<Path>> entries, FileCache fileCache)
focal_class.return: void
focal_class.signature: void removeCachedFiles(Map<String, Future<Path>> entries, FileCache fileCache)
focal_class.class_method_signature: Task.notifyFinalState()
focal_class.full_signature: private void notifyFinalState()
focal_class.identifier: notifyFinalState
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void notifyFinalState()
focal_class.class_method_signature: Task.notifyFatalError(String message, Throwable cause)
focal_class.full_signature: private void notifyFatalError(String message, Throwable cause)
focal_class.identifier: notifyFatalError
focal_class.modifiers: private
focal_class.parameters: (String message, Throwable cause)
focal_class.return: void
focal_class.signature: void notifyFatalError(String message, Throwable cause)
focal_class.class_method_signature: Task.stopExecution()
focal_class.full_signature: public void stopExecution()
focal_class.identifier: stopExecution
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stopExecution()
focal_class.class_method_signature: Task.cancelExecution()
focal_class.full_signature: public void cancelExecution()
focal_class.identifier: cancelExecution
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cancelExecution()
focal_class.class_method_signature: Task.failExternally(Throwable cause)
focal_class.full_signature: public void failExternally(Throwable cause)
focal_class.identifier: failExternally
focal_class.modifiers: public
focal_class.parameters: (Throwable cause)
focal_class.return: void
focal_class.signature: void failExternally(Throwable cause)
focal_class.class_method_signature: Task.cancelOrFailAndCancelInvokable(ExecutionState targetState, Throwable cause)
focal_class.full_signature: private void cancelOrFailAndCancelInvokable(ExecutionState targetState, Throwable cause)
focal_class.identifier: cancelOrFailAndCancelInvokable
focal_class.modifiers: private
focal_class.parameters: (ExecutionState targetState, Throwable cause)
focal_class.return: void
focal_class.signature: void cancelOrFailAndCancelInvokable(ExecutionState targetState, Throwable cause)
focal_class.class_method_signature: Task.registerExecutionListener(ActorGateway listener)
focal_class.full_signature: public void registerExecutionListener(ActorGateway listener)
focal_class.identifier: registerExecutionListener
focal_class.modifiers: public
focal_class.parameters: (ActorGateway listener)
focal_class.return: void
focal_class.signature: void registerExecutionListener(ActorGateway listener)
focal_class.class_method_signature: Task.notifyObservers(ExecutionState newState, Throwable error)
focal_class.full_signature: private void notifyObservers(ExecutionState newState, Throwable error)
focal_class.identifier: notifyObservers
focal_class.modifiers: private
focal_class.parameters: (ExecutionState newState, Throwable error)
focal_class.return: void
focal_class.signature: void notifyObservers(ExecutionState newState, Throwable error)
focal_class.class_method_signature: Task.triggerCheckpointBarrier(final long checkpointID, final long checkpointTimestamp)
focal_class.full_signature: public void triggerCheckpointBarrier(final long checkpointID, final long checkpointTimestamp)
focal_class.identifier: triggerCheckpointBarrier
focal_class.modifiers: public
focal_class.parameters: (final long checkpointID, final long checkpointTimestamp)
focal_class.return: void
focal_class.signature: void triggerCheckpointBarrier(final long checkpointID, final long checkpointTimestamp)
focal_class.class_method_signature: Task.notifyCheckpointComplete(final long checkpointID)
focal_class.full_signature: public void notifyCheckpointComplete(final long checkpointID)
focal_class.identifier: notifyCheckpointComplete
focal_class.modifiers: public
focal_class.parameters: (final long checkpointID)
focal_class.return: void
focal_class.signature: void notifyCheckpointComplete(final long checkpointID)
focal_class.class_method_signature: Task.onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_class.full_signature: public void onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_class.identifier: onPartitionStateUpdate
focal_class.modifiers: public
focal_class.parameters: (
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_class.return: void
focal_class.signature: void onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_class.class_method_signature: Task.executeAsyncCallRunnable(Runnable runnable, String callName)
focal_class.full_signature: private void executeAsyncCallRunnable(Runnable runnable, String callName)
focal_class.identifier: executeAsyncCallRunnable
focal_class.modifiers: private
focal_class.parameters: (Runnable runnable, String callName)
focal_class.return: void
focal_class.signature: void executeAsyncCallRunnable(Runnable runnable, String callName)
focal_class.class_method_signature: Task.cancelInvokable()
focal_class.full_signature: private void cancelInvokable()
focal_class.identifier: cancelInvokable
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cancelInvokable()
focal_class.class_method_signature: Task.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_method.body: public void onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState) throws IOException, InterruptedException {
  
  		if (executionState == ExecutionState.RUNNING) {
  			final SingleInputGate inputGate = inputGatesById.get(resultId);
  
  			if (inputGate != null) {
  				if (partitionState == ExecutionState.RUNNING) {
  					// Retrigger the partition request
  					inputGate.retriggerPartitionRequest(partitionId);
  				}
  				else if (partitionState == ExecutionState.CANCELED
  						|| partitionState == ExecutionState.CANCELING
  						|| partitionState == ExecutionState.FAILED) {
  
  					cancelExecution();
  				}
  				else {
  					failExternally(new IllegalStateException("Received unexpected partition state "
  							+ partitionState + " for partition request. This is a bug."));
  				}
  			}
  			else {
  				failExternally(new IllegalStateException("Received partition state for " +
  						"unknown input gate " + resultId + ". This is a bug."));
  			}
  		}
  		else {
  			LOG.debug("Ignoring partition state notification for not running task.");
  		}
  	}
focal_method.class_method_signature: Task.onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_method.full_signature: public void onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_method.identifier: onPartitionStateUpdate
focal_method.invocations: get retriggerPartitionRequest cancelExecution failExternally failExternally debug
focal_method.modifiers: public
focal_method.parameters: (
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)
focal_method.return: void
focal_method.signature: void onPartitionStateUpdate(
  			IntermediateDataSetID resultId,
  			IntermediateResultPartitionID partitionId,
  			ExecutionState partitionState)