T
- Type of the elements in the Stream@Internal public class ForwardPartitioner<T> extends StreamPartitioner<T>
numberOfChannels
Constructor and Description |
---|
ForwardPartitioner() |
Modifier and Type | Method and Description |
---|---|
StreamPartitioner<T> |
copy() |
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.
|
boolean |
isPointwise() |
int |
selectChannel(SerializationDelegate<StreamRecord<T>> record)
Returns the logical channel index, to which the given record should be written.
|
String |
toString() |
equals, hashCode, isBroadcast, setup
public int selectChannel(SerializationDelegate<StreamRecord<T>> record)
ChannelSelector
UnsupportedOperationException
).record
- the record to determine the output channels for.public StreamPartitioner<T> copy()
copy
in class StreamPartitioner<T>
public boolean isPointwise()
isPointwise
in class StreamPartitioner<T>
public SubtaskStateMapper getDownstreamSubtaskStateMapper()
StreamPartitioner
getDownstreamSubtaskStateMapper
in class StreamPartitioner<T>
public SubtaskStateMapper getUpstreamSubtaskStateMapper()
StreamPartitioner
getUpstreamSubtaskStateMapper
in class StreamPartitioner<T>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.