InputChannelAssignAdditionalPartitions 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 virtual void AssignAdditionalPartitions(
	IList<int> additionalPartitions
)

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

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

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

Parameters

additionalPartitions IListInt32: The additional partitions.

Implements

IInputChannelAssignAdditionalPartitions(IListInt32)

Remarks

Not all input channels need to support this.

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

InputChannel Class

Ookii.Jumbo.Jet.Channels Namespace