PrepartitionedPushTaskTInput, TOutput Class

Base class for tasks that use the push model and can receive records of multiple partitions.

Inheritance Hierarchy

SystemObject
  Ookii.Jumbo.JetConfigurable
    Ookii.Jumbo.JetPrepartitionedPushTaskTInput, TOutput
      Ookii.Jumbo.Jet.TasksSortTaskT

Namespace: Ookii.Jumbo.Jet
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1

Syntax

C++

Copy

public abstract class PrepartitionedPushTask<TInput, TOutput> : Configurable, 
	ITask<TInput, TOutput>

Public MustInherit Class PrepartitionedPushTask(Of TInput, TOutput)
	Inherits Configurable
	Implements ITask(Of TInput, TOutput)

generic<typename TInput, typename TOutput>
public ref class PrepartitionedPushTask abstract : public Configurable, 
	ITask<TInput, TOutput>

[<AbstractClassAttribute>]
type PrepartitionedPushTask<'TInput, 'TOutput> = 
    class
        inherit Configurable
        interface ITask<'TInput, 'TOutput>
    end

Type Parameters

TInput: The type of the input.
TOutput: The type of the output.

The PrepartitionedPushTaskTInput, TOutput type exposes the following members.

Constructors

	Name	Description
	PrepartitionedPushTaskTInput, TOutput	Initializes a new instance of the PrepartitionedPushTaskTInput, TOutput class

Top

Properties

	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)

Top

Methods

	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.
	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. (Inherited from Configurable)
	ProcessRecord	Method called for each record in the task's input.
	Run	Runs the task.
	ToString	Returns a string that represents the current object. (Inherited from Object)

Top

Remarks

This task type is meant for use with receiving tasks of a pipeline channel with internal partitioning. It prevents the overhead of creating a TaskExecutionUtility and task instance for every partition.

If the task needs to know how many partitions there are it should check the InternalPartitionCount property of the StageConfiguration property.

Although tasks using this interface are free to change the partition a record belongs to, it cannot change the number of partitions. All output partition numbers must be between 0 inclusive and InternalPartitionCount exclusive.

Reference

Ookii.Jumbo.Jet Namespace