|
Change Variable Type writer : RecordWriter<IntegerRecord> to writer : RecordWriter<IntValue> in method public invoke() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest.BinaryRoundRobinSubtaskIndexSender |
From |
To |
|
Change Variable Type subtaskIndex : IntegerRecord to subtaskIndex : IntValue in method public invoke() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest.BinaryRoundRobinSubtaskIndexSender |
From |
To |
|
Change Variable Type subtaskIndex : IntegerRecord to subtaskIndex : IntValue in method public invoke() : void in class org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest.RoundRobinSubtaskIndexSender |
From |
To |
|
Change Variable Type selector : RoundRobinChannelSelector<StringRecord> to selector : RoundRobinChannelSelector<StringValue> in method public channelSelect() : void in class org.apache.flink.runtime.io.network.DefaultChannelSelectorTest |
From |
To |
|
Change Variable Type pipelinedWriter : RecordWriter<IntegerRecord> to pipelinedWriter : RecordWriter<IntValue> in method public registerInputOutput() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest.BinaryRoundRobinSubtaskIndexSender |
From |
To |
|
Change Variable Type dummy : IntegerRecord to dummy : IntValue in method public invoke() : void in class org.apache.flink.runtime.iterative.task.IterationSynchronizationSinkTask |
From |
To |
|
Change Variable Type blockingWriter : RecordWriter<IntegerRecord> to blockingWriter : RecordWriter<IntValue> in method public registerInputOutput() : void in class org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest.BinaryRoundRobinSubtaskIndexSender |
From |
To |
|
Change Variable Type record : IntegerRecord to record : IntValue in method public invoke() : void in class org.apache.flink.runtime.jobmanager.SlotCountExceedingParallelismTest.SubtaskIndexReceiver |
From |
To |
|
Change Variable Type dummyRecord : StringRecord to dummyRecord : StringValue in method public channelSelect() : void in class org.apache.flink.runtime.io.network.DefaultChannelSelectorTest |
From |
To |
|
Change Variable Type rec : IntegerRecord to rec : IntValue in method private speedTestStream(bufferSize int) : void in class org.apache.flink.runtime.io.disk.iomanager.IOManagerPerformanceBenchmark |
From |
To |