@Internal public abstract class StreamPartitioner<T> extends Object implements ChannelSelector<SerializationDelegate<StreamRecord<T>>>, Serializable
ChannelSelector
for use in streaming programs.Modifier and Type | Field and Description |
---|---|
protected int |
numberOfChannels |
Constructor and Description |
---|
StreamPartitioner() |
Modifier and Type | Method and Description |
---|---|
abstract StreamPartitioner<T> |
copy() |
boolean |
equals(Object o) |
abstract SubtaskStateMapper |
getDownstreamSubtaskStateMapper()
Defines the behavior of this partitioner, when downstream rescaled during recovery of
in-flight data.
|
SubtaskStateMapper |
getUpstreamSubtaskStateMapper()
Defines the behavior of this partitioner, when upstream rescaled during recovery of in-flight
data.
|
int |
hashCode() |
boolean |
isBroadcast()
Returns whether the channel selector always selects all the output channels.
|
abstract boolean |
isPointwise() |
void |
setup(int numberOfChannels)
Initializes the channel selector with the number of output channels.
|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
selectChannel
public void setup(int numberOfChannels)
ChannelSelector
setup
in interface ChannelSelector<SerializationDelegate<StreamRecord<T>>>
numberOfChannels
- the total number of output channels which are attached to respective
output gate.public boolean isBroadcast()
ChannelSelector
isBroadcast
in interface ChannelSelector<SerializationDelegate<StreamRecord<T>>>
public abstract StreamPartitioner<T> copy()
public SubtaskStateMapper getUpstreamSubtaskStateMapper()
public abstract SubtaskStateMapper getDownstreamSubtaskStateMapper()
public abstract boolean isPointwise()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.