public class ProxyStreamPartitioner<T> extends org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>>
Constructor and Description |
---|
ProxyStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> wrappedStreamPartitioner) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>> |
copy() |
org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper |
getDownstreamSubtaskStateMapper() |
boolean |
isPointwise() |
int |
selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> record) |
void |
setup(int numberOfChannels) |
String |
toString() |
public ProxyStreamPartitioner(org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> wrappedStreamPartitioner)
public void setup(int numberOfChannels)
setup
in interface org.apache.flink.runtime.io.network.api.writer.ChannelSelector<org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>>>
setup
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>>
public org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>> copy()
copy
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>>
public org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper getDownstreamSubtaskStateMapper()
getDownstreamSubtaskStateMapper
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>>
public boolean isPointwise()
isPointwise
in class org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<IterationRecord<T>>
public int selectChannel(org.apache.flink.runtime.plugable.SerializationDelegate<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IterationRecord<T>>> record)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.