TaskExecutionUtility Class

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

Inheritance Hierarchy

SystemObject
Ookii.Jumbo.JetTaskExecutionUtility

Namespace: Ookii.Jumbo.Jet
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0

Syntax

C++

Copy

public abstract class TaskExecutionUtility : IDisposable

Public MustInherit Class TaskExecutionUtility
	Implements IDisposable

public ref class TaskExecutionUtility abstract : IDisposable

[<AbstractClassAttribute>]
type TaskExecutionUtility =  
    class
        interface IDisposable
    end

The TaskExecutionUtility type exposes the following members.

Properties

	Name	Description
	InputPartitionsFinished	Gets or sets the number of input partitions that have finished.
	OutputWriter	Gets the output writer.
	ProcessesAllInputPartitions	Gets a value indicating whether a single task instance will process all input partitions.
	TotalInputPartitions	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).

Top

Methods

	Name	Description
	CheckDisposed	Throws an exception if this object was disposed.
	Create	Creates a TaskExecutionUtility instance for the specified task.
	CreateOutputRecordWriter	Creates the output record writer.
	Dispose	Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
	Dispose(Boolean)	Releases all resources used by this TaskExecutionUtility.
	Equals	Determines whether the specified object is equal to the current object. (Inherited from Object.)
	Finalize	Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.)
	FinalizeTask	Calculates metrics, closes the output stream and moves any DFS output to its final location, for this task and all associated tasks.
	FinishTask	Runs the appropriate finish method (if any) on this task and all child tasks.
	GetHashCode	Serves as the default hash function. (Inherited from Object.)
	GetType	Gets the Type of the current instance. (Inherited from Object.)
	MemberwiseClone	Creates a shallow copy of the current Object. (Inherited from Object.)
	ResetForNextPartition	Resets the task for the next partition.
	RunTask	Runs the task.
	RunTask(Guid, String, String, TaskAttemptId, Boolean)	Executes a task on behalf of the task host. For Jumbo internal use only.
	RunTaskFinishMethod	Runs the task finish method if this task is a push task.
	StartProgressThread	Starts the progress thread.
	ToString	Returns a string that represents the current object. (Inherited from Object.)
	WarnIfNoRecordReuse	Writes a warning to the log if the task doesn't support record reuse.

Top

Reference

Ookii.Jumbo.Jet Namespace