SortTaskT Class |
Namespace: Ookii.Jumbo.Jet.Tasks
The SortTaskT type exposes the following members.
Name | Description | |
---|---|---|
DfsConfiguration |
Gets or sets the configuration used to access the Distributed File System.
(Inherited from Configurable.) | |
JetConfiguration |
Gets or sets the configuration used to access the Jet servers.
(Inherited from Configurable.) | |
TaskContext |
Gets or sets the configuration for the task attempt.
(Inherited from Configurable.) |
Name | Description | |
---|---|---|
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.) | |
Finish |
Method called after the last record was processed.
(Overrides PrepartitionedPushTaskTInput, TOutputFinish(PrepartitionedRecordWriterTOutput).) | |
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.) | |
NotifyConfigurationChanged |
Indicates the configuration has been changed. ApplyConfiguration(Object, DfsConfiguration, JetConfiguration, TaskContext) calls this method
after setting the configuration.
(Overrides ConfigurableNotifyConfigurationChanged.) | |
ProcessRecord |
Method called for each record in the task's input.
(Overrides PrepartitionedPushTaskTInput, TOutputProcessRecord(TInput, Int32, PrepartitionedRecordWriterTOutput).) | |
Run |
Runs the task.
(Inherited from PrepartitionedPushTaskTInput, TOutput.) | |
ToString | Returns a string that represents the current object. (Inherited from Object.) |
Note |
---|
The class that generates the input for this task (which can be either another task if a pipeline channel is used, or a RecordReaderT) may not reuse the record instances for the records. |
Note |
---|
This task performs an in-memory sort of all records. Use it to sort small amounts of records only. For large (or unknown) numbers of records, use the file channel with SortSpill (e.g. using the SpillSortCombine(IOperationInput, Type, Type) function). |