PrepartitionedPushTaskTInput, TOutputProcessRecord Method

Method called for each record in the task's input.

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

Syntax

public abstract void ProcessRecord(
	TInput record,
	int partition,
	PrepartitionedRecordWriter<TOutput> output
)

Public MustOverride Sub ProcessRecord ( 
	record As TInput,
	partition As Integer,
	output As PrepartitionedRecordWriter(Of TOutput)
)

public:
virtual void ProcessRecord(
	TInput record, 
	int partition, 
	PrepartitionedRecordWriter<TOutput>^ output
) abstract

abstract ProcessRecord : 
        record : 'TInput * 
        partition : int * 
        output : PrepartitionedRecordWriter<'TOutput> -> unit

record TInput: The record to process.
partition Int32: The partition of the record.
output PrepartitionedRecordWriterTOutput: The PrepartitionedRecordWriterT to which the task's output should be written.