Click or drag to resize

TaskExecutionUtility Class

Encapsulates all the data and functionality needed to run a task and its pipelined tasks.
Inheritance Hierarchy

Namespace:  Ookii.Jumbo.Jet
Assembly:  Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
public abstract class TaskExecutionUtility : IDisposable

The TaskExecutionUtility type exposes the following members.

Protected propertyInputPartitionsFinished
Gets or sets the number of input partitions that have finished.
Protected propertyOutputWriter
Gets the output writer.
Protected propertyProcessesAllInputPartitions
Gets a value indicating whether a single task instance will process all input partitions.
Protected propertyTotalInputPartitions
Gets or sets the total number of input partitions this task will process (if the input is a channel and the PartitionsPerTask option was > 1).
Protected methodCheckDisposed
Throws an exception if this object was disposed.
Public methodStatic memberCreate
Creates a TaskExecutionUtility instance for the specified task.
Protected methodCreateOutputRecordWriter
Creates the output record writer.
Public methodDispose
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Protected methodDispose(Boolean)
Releases all resources used by this TaskExecutionUtility.
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Protected methodFinalizeTask
Calculates metrics, closes the output stream and moves any DFS output to its final location, for this task and all associated tasks.
Protected methodFinishTask
Runs the appropriate finish method (if any) on this task and all child tasks.
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Protected methodResetForNextPartition
Resets the task for the next partition.
Public methodRunTask
Runs the task.
Public methodStatic memberRunTask(Guid, String, String, TaskAttemptId, Boolean)
Executes a task on behalf of the task host. For Jumbo internal use only.
Protected methodRunTaskFinishMethod
Runs the task finish method if this task is a push task.
Protected methodStartProgressThread
Starts the progress thread.
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Protected methodWarnIfNoRecordReuse
Writes a warning to the log if the task doesn't support record reuse.
See Also