 | InputChannel.AssignAdditionalPartitions Method |
Assigns additional partitions to this input channel.
Namespace: Ookii.Jumbo.Jet.ChannelsAssembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntaxpublic 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 IList<Int32>
- The additional partitions.
Implements
IInputChannel.AssignAdditionalPartitions(IList<Int32>)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 true.
See Also 
