FileInputChannelAssignAdditionalPartitions Method

Assigns additional partitions to this input channel.

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

Syntax

C++

Copy

public override void AssignAdditionalPartitions(
	IList<int> additionalPartitions
)

Public Overrides Sub AssignAdditionalPartitions ( 
	additionalPartitions As IList(Of Integer)
)

public:
virtual void AssignAdditionalPartitions(
	IList<int>^ additionalPartitions
) override

abstract AssignAdditionalPartitions : 
        additionalPartitions : IList<int> -> unit 
override AssignAdditionalPartitions : 
        additionalPartitions : IList<int> -> unit

Parameters

additionalPartitions IListInt32: The additional partitions.

Implements

IInputChannelAssignAdditionalPartitions(IListInt32)

Remarks

This method will only be called after the task finished processing all previously assigned partitions.

This method will never be called if PartitionsPerTask is 1 or DisableDynamicPartitionAssignment is .

Reference

FileInputChannel Class

Ookii.Jumbo.Jet.Channels Namespace