return keyGroupPartitioner.selectChannels(serializationDelegate); | return keyGroupPartitioner.selectChannel(serializationDelegate); | keyGroupPartitioner.selectChannels(serializationDelegate) | keyGroupPartitioner.selectChannel(serializationDelegate) | flink | be0aea724956ead1ee625bd327c9d43bc7f4a63b | org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest | | _1 | selectChannels |
---|
_2 | selectChannels |
---|
| v0 | keyGroupPartitioner |
---|
v1 | serializationDelegate |
---|
| | v0 | keyGroupPartitioner |
---|
v1 | serializationDelegate |
---|
| Returns | True |
selectedChannels = selector.selectChannels(serializationDelegate) | selectedChannel = selector.selectChannel(serializationDelegate) | selector.selectChannels(serializationDelegate) | selector.selectChannel(serializationDelegate) | flink | be0aea724956ead1ee625bd327c9d43bc7f4a63b | org.apache.flink.runtime.operators.util.OutputEmitterTest | | _1 | selectedChannels |
---|
_2 | selectedChannel |
---|
| v0 | selector |
---|
v1 | serializationDelegate |
---|
| | v0 | selector |
---|
v1 | serializationDelegate |
---|
| AssignedTo | True |
int[] selectedChannels=selector.selectChannels(serializationDelegate); | int selectedChannel=selector.selectChannel(serializationDelegate); | selector.selectChannels(serializationDelegate) | selector.selectChannel(serializationDelegate) | flink | be0aea724956ead1ee625bd327c9d43bc7f4a63b | org.apache.flink.runtime.operators.util.OutputEmitterTest | | _1 | selectedChannels |
---|
_2 | selectedChannel |
---|
| v0 | selector |
---|
v1 | serializationDelegate |
---|
| | v0 | selector |
---|
v1 | serializationDelegate |
---|
| AssignedTo | True |
actualResult = selector.selectChannels(record) | actualResult = selector.selectChannel(record) | selector.selectChannels(record) | selector.selectChannel(record) | flink | be0aea724956ead1ee625bd327c9d43bc7f4a63b | org.apache.flink.runtime.io.network.DefaultChannelSelectorTest | | _1 | actualResult |
---|
_2 | actualResult |
---|
| | | | AssignedTo | True |