| SortTaskTProcessRecord Method |
Method called for each record in the task's input.
Namespace:
Ookii.Jumbo.Jet.Tasks
Assembly:
Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 2.0.0
Syntax public override void ProcessRecord(
T record,
int partition,
PrepartitionedRecordWriter<T> output
)
Public Overrides Sub ProcessRecord (
record As T,
partition As Integer,
output As PrepartitionedRecordWriter(Of T)
)
public:
virtual void ProcessRecord(
T record,
int partition,
PrepartitionedRecordWriter<T>^ output
) override
abstract ProcessRecord :
record : 'T *
partition : int *
output : PrepartitionedRecordWriter<'T> -> unit
override ProcessRecord :
record : 'T *
partition : int *
output : PrepartitionedRecordWriter<'T> -> unit
Parameters
- record
- Type: T
The record to process. - partition
- Type: SystemInt32
The partition of the record - output
- Type: Ookii.Jumbo.JetPrepartitionedRecordWriterT
The RecordWriterT to which the task's output should be written.
See Also