T- the type of record which is sent through the attached output gate
public class RoundRobinChannelSelector<T extends IOReadableWritable> extends Object implements ChannelSelector<T>
ChannelSelectorinterface. It represents a simple round-robin strategy, i.e. regardless of the record every attached exactly one output channel is selected at a time.
|Constructor and Description|
Constructs a new default channel selector.
|Modifier and Type||Method and Description|
Returns the logical channel indexes, to which the given record should be written.
public int selectChannels(T record, int numberOfOutputChannels)
ChannelSelector<T extends IOReadableWritable>
record- the record to the determine the output channels for
numberOfOutputChannels- the total number of output channels which are attached to respective output gate
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.