The TaskExecutionUtility type exposes the following members.
Gets or sets the number of input partitions that have finished.
Gets the output writer.
Gets a value indicating whether a single task instance will process all input partitions.
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).
Throws an exception if this object was disposed.
Creates a TaskExecutionUtility instance for the specified task.
Creates the output record writer.
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Releases all resources used by this TaskExecutionUtility.
Determines whether the specified object is equal to the current object.(Inherited from Object.)
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.(Inherited from Object.)
Calculates metrics, closes the output stream and moves any DFS output to its final location, for this task and all associated tasks.
Runs the appropriate finish method (if any) on this task and all child tasks.
Serves as the default hash function.(Inherited from Object.)
Gets the Type of the current instance.(Inherited from Object.)
Creates a shallow copy of the current Object.(Inherited from Object.)
Resets the task for the next partition.
Runs the task.
|RunTask(Guid, String, String, TaskAttemptId, Boolean)|
Executes a task on behalf of the task host. For Jumbo internal use only.
Runs the task finish method if this task is a push task.
Starts the progress thread.
Returns a string that represents the current object.(Inherited from Object.)
Writes a warning to the log if the task doesn't support record reuse.