T- the type of record which is sent through the attached output gate
public interface ChannelSelector<T extends IOReadableWritable>
ChannelSelectordetermines to which logical channels a record should be written to.
int selectChannels(T record, int numChannels)
record- the record to the determine the output channels for
numChannels- the total number of output channels which are attached to respective output gate
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.