OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return keyGroupPartitioner.selectChannels(serializationDelegate);return keyGroupPartitioner.selectChannel(serializationDelegate);keyGroupPartitioner.selectChannels(serializationDelegate)keyGroupPartitioner.selectChannel(serializationDelegate)flinkbe0aea724956ead1ee625bd327c9d43bc7f4a63borg.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest
_176
_266
_1selectChannels
_2selectChannels
v0keyGroupPartitioner
v1serializationDelegate
v0keyGroupPartitioner
v1serializationDelegate
ReturnsTrue
selectedChannels = selector.selectChannels(serializationDelegate)selectedChannel = selector.selectChannel(serializationDelegate)selector.selectChannels(serializationDelegate)selector.selectChannel(serializationDelegate)flinkbe0aea724956ead1ee625bd327c9d43bc7f4a63borg.apache.flink.runtime.operators.util.OutputEmitterTest
_1320
_2321
_1selectedChannels
_2selectedChannel
v0selector
v1serializationDelegate
v0selector
v1serializationDelegate
AssignedToTrue
int[] selectedChannels=selector.selectChannels(serializationDelegate);int selectedChannel=selector.selectChannel(serializationDelegate);selector.selectChannels(serializationDelegate)selector.selectChannel(serializationDelegate)flinkbe0aea724956ead1ee625bd327c9d43bc7f4a63borg.apache.flink.runtime.operators.util.OutputEmitterTest
_1320
_2321
_1selectedChannels
_2selectedChannel
v0selector
v1serializationDelegate
v0selector
v1serializationDelegate
AssignedToTrue
actualResult = selector.selectChannels(record)actualResult = selector.selectChannel(record)selector.selectChannels(record)selector.selectChannel(record)flinkbe0aea724956ead1ee625bd327c9d43bc7f4a63borg.apache.flink.runtime.io.network.DefaultChannelSelectorTest
_152
_252
_1actualResult
_2actualResult
v0selector
v1record
v0selector
v1record
AssignedToTrue