T
- Type of the elements in the Stream being partitioned@Internal public class GlobalPartitioner<T> extends StreamPartitioner<T>
Constructor and Description |
---|
GlobalPartitioner() |
Modifier and Type | Method and Description |
---|---|
StreamPartitioner<T> |
copy() |
int[] |
selectChannels(SerializationDelegate<StreamRecord<T>> record,
int numberOfOutputChannels)
Returns the logical channel indexes, to which the given record should be
written.
|
String |
toString() |
public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
ChannelSelector
record
- the record to the determine the output channels fornumberOfOutputChannels
- the total number of output channels which are attached to respective output gatepublic StreamPartitioner<T> copy()
copy
in class StreamPartitioner<T>
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.