PrepartitionedPushTaskTInput, TOutputRun Method

Runs the task.

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

Syntax

public virtual void Run(
	RecordReader<TInput> input,
	RecordWriter<TOutput> output
)

Public Overridable Sub Run ( 
	input As RecordReader(Of TInput),
	output As RecordWriter(Of TOutput)
)

public:
virtual void Run(
	RecordReader<TInput>^ input, 
	RecordWriter<TOutput>^ output
)

abstract Run : 
        input : RecordReader<'TInput> * 
        output : RecordWriter<'TOutput> -> unit 
override Run : 
        input : RecordReader<'TInput> * 
        output : RecordWriter<'TOutput> -> unit

Parameters

input: Type: Ookii.Jumbo.IORecordReaderTInput
A RecordReaderT from which the task's input can be read.
output: Type: Ookii.Jumbo.IORecordWriterTOutput
A RecordWriterT to which the task's output should be written.

Implements

ITaskTInput, TOutputRun(RecordReaderTInput, RecordWriterTOutput)

Remarks

While it is possible to override this method, it is not guaranteed to be called in all scenarios (e.g. if this task is receiving data from a pipeline channel). The task must function correctly even if the ProcessRecord(TInput, Int32, PrepartitionedRecordWriterTOutput) and Finish(PrepartitionedRecordWriterTOutput) are called directly.

Reference

PrepartitionedPushTaskTInput, TOutput Class

Ookii.Jumbo.Jet Namespace

PrepartitionedPushTaskAddLanguageSpecificTextSet("LST649969DC_0?cs=&lt;|vb=(Of |cpp=&lt;|fs=&lt;'|nu=(");TInput, TOutputAddLanguageSpecificTextSet("LST649969DC_1?cs=&gt;|vb=)|cpp=&gt;|fs=&gt;|nu=)");AddLanguageSpecificTextSet("LST649969DC_2?cpp=::|nu=.");Run Method

Parameters

Implements

Reference

PrepartitionedPushTaskTInput, TOutputRun Method