org.apache.flink.runtime.profiling

Interface TaskManagerProfiler

public interface TaskManagerProfiler

This interface must be implemented by profiling components for the task manager manager.

Method Summary

Modifier and Type	Method and Description
void	registerTask(Task task, Configuration jobConfiguration) Registers a Task object for profiling.
void	shutdown() Shuts done the task manager's profiling component and stops all its internal processes.
void	unregisterTask(ExecutionAttemptID id) Unregisters all previously registered Task objects for the vertex identified by the given ID.

Method Detail

registerTask

void registerTask(Task task,
                  Configuration jobConfiguration)

Registers a Task object for profiling.

Parameters:

task - task to be register a profiling listener for

jobConfiguration - the job configuration sent with the task

unregisterTask

void unregisterTask(ExecutionAttemptID id)

Unregisters all previously registered Task objects for the vertex identified by the given ID.

Parameters:

id - the ID of the vertex to unregister the Task objects for

shutdown

void shutdown()

Shuts done the task manager's profiling component and stops all its internal processes.