PushTaskTInput, TOutputRun Method

Runs the task.

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

Syntax

C++

Copy

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 RecordReaderTInput: A RecordReaderT from which the task's input can be read.
output RecordWriterTOutput: 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, RecordWriterTOutput) and Finish(RecordWriterTOutput) are called directly.

Reference

PushTaskTInput, TOutput Class

Ookii.Jumbo.Jet Namespace